一,編寫返回對象
1
2
3
4
5
6
7
8
|
public class HttpResult { // 響應的狀態碼 private int code; // 響應的響應體 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 創建HttpClinet,相當于打開瀏覽器 this.httpClient = HttpClients.createDefault(); } /** * 帶參數的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); // 判斷參數map是否為非空 if (map != null) { // 遍歷參數 for (Map.Entry< String , Object> entry : map.entrySet()) { // 設置參數 uriBuilder.setParameter(entry.getKey(), entry.getValue().toString()); } } // 2 創建httpGet對象,相當于設置url請求地址 HttpGet httpGet = new HttpGet(uriBuilder.build()); // 3 使用HttpClient執行httpGet,相當于按回車,發起請求 CloseableHttpResponse response = this.httpClient.execute(httpGet); // 4 解析結果,封裝返回對象httpResult,相當于顯示相應的結果 // 狀態碼 // response.getStatusLine().getStatusCode(); // 響應體,字符串,如果response.getEntity()為空,下面這個代碼會報錯,所以解析之前要做非空的判斷 // EntityUtils.toString(response.getEntity(), "UTF-8"); HttpResult httpResult = null; // 解析數據封裝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; } /** * 不帶參數的get請求 * * @param url * @return * @throws Exception */ public HttpResult doGet(String url) throws Exception { HttpResult httpResult = this.doGet(url, null); return httpResult; } /** * 帶參數的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) { // 聲明存放參數的List集合 List< NameValuePair > params = new ArrayList< NameValuePair >(); // 遍歷map,設置參數到list中 for (Map.Entry< String , Object> entry : map.entrySet()) { params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString())); } // 創建form表單對象 UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "UTF-8"); // 把表單對象設置到httpPost中 httpPost.setEntity(formEntity); } // 使用HttpClient發起請求,返回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(), ""); } // 返回結果 return httpResult; } /** * 不帶參數的post請求 * * @param url * @return * @throws Exception */ public HttpResult doPost(String url) throws Exception { HttpResult httpResult = this.doPost(url, null); return httpResult; } /** * 帶參數的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) { // 聲明存放參數的List集合 List< NameValuePair > params = new ArrayList< NameValuePair >(); // 遍歷map,設置參數到list中 for (Map.Entry< String , Object> entry : map.entrySet()) { params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString())); } // 創建form表單對象 UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "UTF-8"); // 把表單對象設置到httpPost中 httpPut.setEntity(formEntity); } // 使用HttpClient發起請求,返回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(), ""); } // 返回結果 return httpResult; } /** * 帶參數的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); // 判斷參數map是否為非空 if (map != null) { // 遍歷參數 for (Map.Entry< String , Object> entry : map.entrySet()) { // 設置參數 uriBuilder.setParameter(entry.getKey(), entry.getValue().toString()); } } // 2 創建httpGet對象,相當于設置url請求地址 HttpDelete httpDelete = new HttpDelete(uriBuilder.build()); // 3 使用HttpClient執行httpGet,相當于按回車,發起請求 CloseableHttpResponse response = this.httpClient.execute(httpDelete); // 4 解析結果,封裝返回對象httpResult,相當于顯示相應的結果 // 狀態碼 // response.getStatusLine().getStatusCode(); // 響應體,字符串,如果response.getEntity()為空,下面這個代碼會報錯,所以解析之前要做非空的判斷 // EntityUtils.toString(response.getEntity(), "UTF-8"); HttpResult httpResult = null; // 解析數據封裝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風格的接口&price=1000&num=1&cid=888&status=1
- map.put("title", "測試APIService調用新增接口");
- 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風格的接口&price=1000&num=1&cid=888&status=1
- map.put("title", "測試APIService調用修改接口");
- 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調用接口的實例講解就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持服務器之家。
原文鏈接:http://www.cnblogs.com/javaxiaoxin/archive/2017/10/06/7633017.html