一，編寫返回對象
|
1
2
3
4
5
6
7
8
|
public class HttpResult {// 響應(yīng)的狀態(tài)碼private int code;// 響應(yīng)的響應(yīng)體private String body;get/set…} |
二，封裝HttpClient
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
|
package cn.xxxxxx.httpclient;import java.util.ArrayList;import java.util.List;import java.util.Map;import org.apache.http.NameValuePair;import org.apache.http.client.entity.UrlEncodedFormEntity;import org.apache.http.client.methods.CloseableHttpResponse;import org.apache.http.client.methods.HttpDelete;import org.apache.http.client.methods.HttpGet;import org.apache.http.client.methods.HttpPost;import org.apache.http.client.methods.HttpPut;import org.apache.http.client.utils.URIBuilder;import org.apache.http.impl.client.CloseableHttpClient;import org.apache.http.impl.client.HttpClients;import org.apache.http.message.BasicNameValuePair;import org.apache.http.util.EntityUtils;public class APIService { private CloseableHttpClient httpClient; public APIService() { // 1 創(chuàng)建HttpClinet，相當(dāng)于打開瀏覽器 this.httpClient = HttpClients.createDefault(); } /** * 帶參數(shù)的get請求 * * @param url * @param map * @return * @throws Exception */ public HttpResult doGet(String url, Map<String, Object> map) throws Exception { // 聲明URIBuilder URIBuilder uriBuilder = new URIBuilder(url); // 判斷參數(shù)map是否為非空 if (map != null) { // 遍歷參數(shù) for (Map.Entry<String, Object> entry : map.entrySet()) { // 設(shè)置參數(shù) uriBuilder.setParameter(entry.getKey(), entry.getValue().toString()); } } // 2 創(chuàng)建httpGet對象，相當(dāng)于設(shè)置url請求地址 HttpGet httpGet = new HttpGet(uriBuilder.build()); // 3 使用HttpClient執(zhí)行httpGet，相當(dāng)于按回車，發(fā)起請求 CloseableHttpResponse response = this.httpClient.execute(httpGet); // 4 解析結(jié)果，封裝返回對象httpResult，相當(dāng)于顯示相應(yīng)的結(jié)果 // 狀態(tài)碼 // response.getStatusLine().getStatusCode(); // 響應(yīng)體，字符串，如果response.getEntity()為空，下面這個(gè)代碼會報(bào)錯(cuò),所以解析之前要做非空的判斷 // EntityUtils.toString(response.getEntity(), "UTF-8"); HttpResult httpResult = null; // 解析數(shù)據(jù)封裝HttpResult if (response.getEntity() != null) { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), EntityUtils.toString(response.getEntity(), "UTF-8")); } else { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), ""); } // 返回 return httpResult; } /** * 不帶參數(shù)的get請求 * * @param url * @return * @throws Exception */ public HttpResult doGet(String url) throws Exception { HttpResult httpResult = this.doGet(url, null); return httpResult; } /** * 帶參數(shù)的post請求 * * @param url * @param map * @return * @throws Exception */ public HttpResult doPost(String url, Map<String, Object> map) throws Exception { // 聲明httpPost請求 HttpPost httpPost = new HttpPost(url); // 判斷map不為空 if (map != null) { // 聲明存放參數(shù)的List集合 List<NameValuePair> params = new ArrayList<NameValuePair>(); // 遍歷map，設(shè)置參數(shù)到list中 for (Map.Entry<String, Object> entry : map.entrySet()) { params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString())); } // 創(chuàng)建form表單對象 UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "UTF-8"); // 把表單對象設(shè)置到httpPost中 httpPost.setEntity(formEntity); } // 使用HttpClient發(fā)起請求，返回response CloseableHttpResponse response = this.httpClient.execute(httpPost); // 解析response封裝返回對象httpResult HttpResult httpResult = null; if (response.getEntity() != null) { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), EntityUtils.toString(response.getEntity(), "UTF-8")); } else { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), ""); } // 返回結(jié)果 return httpResult; } /** * 不帶參數(shù)的post請求 * * @param url * @return * @throws Exception */ public HttpResult doPost(String url) throws Exception { HttpResult httpResult = this.doPost(url, null); return httpResult; } /** * 帶參數(shù)的Put請求 * * @param url * @param map * @return * @throws Exception */ public HttpResult doPut(String url, Map<String, Object> map) throws Exception { // 聲明httpPost請求 HttpPut httpPut = new HttpPut(url); // 判斷map不為空 if (map != null) { // 聲明存放參數(shù)的List集合 List<NameValuePair> params = new ArrayList<NameValuePair>(); // 遍歷map，設(shè)置參數(shù)到list中 for (Map.Entry<String, Object> entry : map.entrySet()) { params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString())); } // 創(chuàng)建form表單對象 UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "UTF-8"); // 把表單對象設(shè)置到httpPost中 httpPut.setEntity(formEntity); } // 使用HttpClient發(fā)起請求，返回response CloseableHttpResponse response = this.httpClient.execute(httpPut); // 解析response封裝返回對象httpResult HttpResult httpResult = null; if (response.getEntity() != null) { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), EntityUtils.toString(response.getEntity(), "UTF-8")); } else { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), ""); } // 返回結(jié)果 return httpResult; } /** * 帶參數(shù)的Delete請求 * * @param url * @param map * @return * @throws Exception */ public HttpResult doDelete(String url, Map<String, Object> map) throws Exception { // 聲明URIBuilder URIBuilder uriBuilder = new URIBuilder(url); // 判斷參數(shù)map是否為非空 if (map != null) { // 遍歷參數(shù) for (Map.Entry<String, Object> entry : map.entrySet()) { // 設(shè)置參數(shù) uriBuilder.setParameter(entry.getKey(), entry.getValue().toString()); } } // 2 創(chuàng)建httpGet對象，相當(dāng)于設(shè)置url請求地址 HttpDelete httpDelete = new HttpDelete(uriBuilder.build()); // 3 使用HttpClient執(zhí)行httpGet，相當(dāng)于按回車，發(fā)起請求 CloseableHttpResponse response = this.httpClient.execute(httpDelete); // 4 解析結(jié)果，封裝返回對象httpResult，相當(dāng)于顯示相應(yīng)的結(jié)果 // 狀態(tài)碼 // response.getStatusLine().getStatusCode(); // 響應(yīng)體，字符串，如果response.getEntity()為空，下面這個(gè)代碼會報(bào)錯(cuò),所以解析之前要做非空的判斷 // EntityUtils.toString(response.getEntity(), "UTF-8"); HttpResult httpResult = null; // 解析數(shù)據(jù)封裝HttpResult if (response.getEntity() != null) { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), EntityUtils.toString(response.getEntity(), "UTF-8")); } else { httpResult = new HttpResult(response.getStatusLine().getStatusCode(), ""); } // 返回 return httpResult; }} |
- package cn.xxxxxx.httpclient.test;
- import java.util.HashMap;
- import java.util.Map;
- import org.junit.Before;
- import org.junit.Test;
- import cn.itcast.httpclient.APIService;
- import cn.itcast.httpclient.HttpResult;
- public class APIServiceTest {
- private APIService apiService;
- @Before
- public void init() {
- this.apiService = new APIService();
- }
- // 查詢
- @Test
- public void testQueryItemById() throws Exception {
- // http://manager.aaaaaa.com/rest/item/interface/{id}
- String url = "http://manager.aaaaaa.com/rest/item/interface/42";
- HttpResult httpResult = this.apiService.doGet(url);
- System.out.println(httpResult.getCode());
- System.out.println(httpResult.getBody());
- }
- // 新增
- @Test
- public void testSaveItem() throws Exception {
- // http://manager.aaaaaa.com/rest/item/interface/{id}
- String url = "http://manager.aaaaaa.com/rest/item/interface";
- Map<String, Object> map = new HashMap<String, Object>();
- // title=測試RESTful風(fēng)格的接口&price=1000&num=1&cid=888&status=1
- map.put("title", "測試APIService調(diào)用新增接口");
- map.put("price", "1000");
- map.put("num", "1");
- map.put("cid", "666");
- map.put("status", "1");
- HttpResult httpResult = this.apiService.doPost(url, map);
- System.out.println(httpResult.getCode());
- System.out.println(httpResult.getBody());
- }
- // 修改
- @Test
- public void testUpdateItem() throws Exception {
- // http://manager.aaaaaa.com/rest/item/interface/{id}
- String url = "http://manager.aaaaaa.com/rest/item/interface";
- Map<String, Object> map = new HashMap<String, Object>();
- // title=測試RESTful風(fēng)格的接口&price=1000&num=1&cid=888&status=1
- map.put("title", "測試APIService調(diào)用修改接口");
- map.put("id", "44");
- HttpResult httpResult = this.apiService.doPut(url, map);
- System.out.println(httpResult.getCode());
- System.out.println(httpResult.getBody());
- }
- // 刪除
- @Test
- public void testDeleteItemById() throws Exception {
- // http://manager.aaaaaa.com/rest/item/interface/{id}
- String url = "http://manager.aaaaaa.com/rest/item/interface/44";
- HttpResult httpResult = this.apiService.doDelete(url, null);
- System.out.println(httpResult.getCode());
- System.out.println(httpResult.getBody());
- }
- }
以上這篇使用HttpClient調(diào)用接口的實(shí)例講解就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持服務(wù)器之家。
原文鏈接：http://www.cnblogs.com/javaxiaoxin/archive/2017/10/06/7633017.html
