Http请求get及post请求方法

​x
1
package com.qyfr.util;
2
​
3
import java.io.IOException;
4
import java.io.InputStreamReader;
5
import java.io.UnsupportedEncodingException;
6
import java.net.URISyntaxException;
7
import java.util.ArrayList;
8
import java.util.List;
9
import java.util.Map;
10
​
11
import org.apache.http.HttpEntity;
12
import org.apache.http.NameValuePair;
13
import org.apache.http.client.ClientProtocolException;
14
import org.apache.http.client.entity.UrlEncodedFormEntity;
15
import org.apache.http.client.methods.CloseableHttpResponse;
16
import org.apache.http.client.methods.HttpGet;
17
import org.apache.http.client.methods.HttpPost;
18
import org.apache.http.client.methods.HttpRequestBase;
19
import org.apache.http.client.utils.URIBuilder;
20
import org.apache.http.entity.ByteArrayEntity;
21
import org.apache.http.impl.client.CloseableHttpClient;
22
import org.apache.http.impl.client.HttpClients;
23
import org.apache.http.message.BasicNameValuePair;
24
import org.apache.http.util.CharArrayBuffer;
25
import org.apache.http.util.EntityUtils;
26
​
27
/**
28
 * HttpClient工具
29
 */
30
public class HttpClient {
31
​
32
    public static String get(String url) {
33
        return get(url, null, null, "UTF-8");
34
    }
35
​
36
    public static String post(String url, Map<String, String> form) {
37
        return post(url, form, null, "UTF-8");
38
    }
39
    
40
    public static String post(String url, String jsonForm) {
41
        return postJson(url, jsonForm, null, "UTF-8");
42
    }
43
    
44
    /**
45
     * Get请求
46
     * 
47
     * @param url
48
     * @param headerMap
49
     * @param paramMap
50
     * @param codeType
51
     * @return
52
     */
53
    public static String get(String url, Map<String, String> headerMap, Map<String, String> paramMap, String codeType) {
54
        String result = null;
55
        CloseableHttpClient httpClient = HttpClients.createDefault();
56
        List<NameValuePair> pairs = new ArrayList<NameValuePair>();
57
        if (paramMap != null) {
58
            for (Map.Entry<String, String> entry : paramMap.entrySet()) {
59
                pairs.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
60
            }
61
        }
62
        CloseableHttpResponse response = null;
63
        try {
64
            URIBuilder builder = new URIBuilder(url);
65
            builder.setParameters(pairs);
66
            HttpRequestBase httpRequestBase = new HttpGet(builder.build());
67
            if (headerMap != null) {
68
                headerMap.forEach((name, value) -> {
69
                    httpRequestBase.removeHeaders(name);
70
                    httpRequestBase.addHeader(name, value);
71
                });
72
            }
73
            httpRequestBase.addHeader("User-Agent", "Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:1.7.6)");
74
            response = httpClient.execute(httpRequestBase);
75
            response.setHeader("Content-type", "text/html;charset=UTF-8");
76
            if (response != null && response.getStatusLine().getStatusCode() == 200) {
77
                HttpEntity entity = response.getEntity();
78
                // result = EntityUtils.toString(entity, "UTF-8");
79
                result = entityToString(entity, codeType);
80
            }
81
            return result;
82
        } catch (URISyntaxException e) {
83
            e.printStackTrace();
84
        } catch (ClientProtocolException e) {
85
            e.printStackTrace();
86
        } catch (IOException e) {
87
            e.printStackTrace();
88
        } finally {
89
            try {
90
                httpClient.close();
91
                if (response != null) {
92
                    response.close();
93
                }
94
            } catch (IOException e) {
95
                e.printStackTrace();
96
            }
97
        }
98
​
99
        return null;
100
    }
101
​
102
    /**
103
     * 发送post请求，参数用map接收
104
     * 
105
     * @param url地址
106
     * @param map参数
107
     * @return 
108
     */
109
    public static String post(String url, Map<String, String> form, Map<String, String> header, String codeType) {
110
        String result = null;
111
        CloseableHttpClient httpClient = HttpClients.createDefault();
112
        HttpPost post = new HttpPost(url);
113
        List<NameValuePair> pairs = new ArrayList<NameValuePair>();
114
        for (Map.Entry<String, String> entry : form.entrySet()) {
115
            pairs.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
116
        }
117
        CloseableHttpResponse response = null;
118
        try {
119
            post.setEntity(new UrlEncodedFormEntity(pairs, "UTF-8"));
120
​
121
            // 请求头
122
            if (null != header) {
123
                for (Map.Entry<String, String> entry : header.entrySet()) {
124
                    post.addHeader(entry.getKey(), entry.getValue());
125
                }
126
            }
127
            response = httpClient.execute(post);
128
            if (response != null && response.getStatusLine().getStatusCode() == 200) {
129
                HttpEntity entity = response.getEntity();
130
                result = entityToString(entity, codeType);
131
            }
132
            return result;
133
        } catch (UnsupportedEncodingException e) {
134
            e.printStackTrace();
135
        } catch (ClientProtocolException e) {
136
            e.printStackTrace();
137
        } catch (IOException e) {
138
            e.printStackTrace();
139
        } finally {
140
            try {
141
                httpClient.close();
142
                if (response != null) {
143
                    response.close();
144
                }
145
            } catch (IOException e) {
146
                e.printStackTrace();
147
            }
148
​
149
        }
150
        return null;
151
    }
152
​
153
    /**
154
     * post请求参数为json字符串
155
     * @param url
156
     * @param jsonString
157
     * @param header
158
     * @param codeType
159
     * @return
160
     */
161
    public static String postJson(String url, String jsonString, Map<String, String> header, String codeType) {
162
        String result = null;
163
        CloseableHttpClient httpClient = HttpClients.createDefault();
164
        HttpPost post = new HttpPost(url);
165
        CloseableHttpResponse response = null;
166
        try {
167
            post.setEntity(new ByteArrayEntity(jsonString.getBytes("UTF-8")));
168
            // 请求头
169
            if (null != header) {
170
                for (Map.Entry<String, String> entry : header.entrySet()) {
171
                    post.addHeader(entry.getKey(), entry.getValue());
172
                }
173
            }
174
            response = httpClient.execute(post);
175
            if (response != null && response.getStatusLine().getStatusCode() == 200) {
176
                HttpEntity entity = response.getEntity();
177
                result = entityToString(entity, codeType);
178
            }
179
            return result;
180
        } catch (UnsupportedEncodingException e) {
181
            e.printStackTrace();
182
        } catch (ClientProtocolException e) {
183
            e.printStackTrace();
184
        } catch (IOException e) {
185
            e.printStackTrace();
186
        } finally {
187
            try {
188
                httpClient.close();
189
                if (response != null) {
190
                    response.close();
191
                }
192
            } catch (IOException e) {
193
                e.printStackTrace();
194
            }
195
        }
196
        return null;
197
    }
198
​
199
    private static String entityToString(HttpEntity entity, String codeType) throws IOException {
200
        String result = null;
201
        if (entity != null) {
202
            long lenth = entity.getContentLength();
203
            if (lenth != -1 && lenth < 2048) {
204
                result = EntityUtils.toString(entity, codeType);
205
            } else {
206
                InputStreamReader reader1 = new InputStreamReader(entity.getContent(), "UTF-8");
207
                CharArrayBuffer buffer = new CharArrayBuffer(2048);
208
                char[] tmp = new char[1024];
209
                int l;
210
                while ((l = reader1.read(tmp)) != -1) {
211
                    buffer.append(tmp, 0, l);
212
                }
213
                result = buffer.toString();
214
            }
215
        }
216
        return result;
217
    }
218
}