java http apache_java实现HTTP请求的三种方式

落日映苍穹つ 2022-11-03 11:11 202阅读 0赞

1 packagecom.powerX.httpClient;2

3 importjava.io.BufferedReader;4 importjava.io.IOException;5 importjava.io.InputStream;6 importjava.io.InputStreamReader;7 importjava.io.UnsupportedEncodingException;8 importjava.util.Iterator;9 importjava.util.Map;10 importjava.util.Map.Entry;11 importjava.util.Set;12

13 importorg.apache.commons.httpclient.DefaultHttpMethodRetryHandler;14 importorg.apache.commons.httpclient.HttpClient;15 importorg.apache.commons.httpclient.HttpStatus;16 importorg.apache.commons.httpclient.NameValuePair;17 importorg.apache.commons.httpclient.methods.GetMethod;18 importorg.apache.commons.httpclient.methods.PostMethod;19 importorg.apache.commons.httpclient.params.HttpMethodParams;20

21 public classHttpClient3 \{22

23 public staticString doGet(String url) \{24 //输入流

25 InputStream is = null;26 BufferedReader br = null;27 String result = null;28 //创建httpClient实例

29 HttpClient httpClient = newHttpClient();30 //设置http连接主机服务超时时间：15000毫秒31 //先获取连接管理器对象，再获取参数对象,再进行参数的赋值

32 httpClient.getHttpConnectionManager().getParams().setConnectionTimeout(15000);33 //创建一个Get方法实例对象

34 GetMethod getMethod = newGetMethod(url);35 //设置get请求超时为60000毫秒

36 getMethod.getParams().setParameter(HttpMethodParams.SO\_TIMEOUT, 60000);37 //设置请求重试机制，默认重试次数：3次，参数设置为true，重试机制可用，false相反

38 getMethod.getParams().setParameter(HttpMethodParams.RETRY\_HANDLER, new DefaultHttpMethodRetryHandler(3, true));39 try\{40 //执行Get方法

41 int statusCode =httpClient.executeMethod(getMethod);42 //判断返回码

43 if (statusCode !=HttpStatus.SC\_OK) \{44 //如果状态码返回的不是ok,说明失败了,打印错误信息

45 System.err.println("Method faild: " +getMethod.getStatusLine());46 \} else\{47 //通过getMethod实例，获取远程的一个输入流

48 is =getMethod.getResponseBodyAsStream();49 //包装输入流

50 br = new BufferedReader(new InputStreamReader(is, "UTF-8"));51

52 StringBuffer sbf = newStringBuffer();53 //读取封装的输入流

54 String temp = null;55 while ((temp = br.readLine()) != null) \{56 sbf.append(temp).append("\\r\\n");57 \}58

59 result =sbf.toString();60 \}61

62 \} catch(IOException e) \{63 e.printStackTrace();64 \} finally\{65 //关闭资源

66 if (null !=br) \{67 try\{68 br.close();69 \} catch(IOException e) \{70 e.printStackTrace();71 \}72 \}73 if (null !=is) \{74 try\{75 is.close();76 \} catch(IOException e) \{77 e.printStackTrace();78 \}79 \}80 //释放连接

81 getMethod.releaseConnection();82 \}83 returnresult;84 \}85

86 public static String doPost(String url, MapparamMap) \{87 //获取输入流

88 InputStream is = null;89 BufferedReader br = null;90 String result = null;91 //创建httpClient实例对象

92 HttpClient httpClient = newHttpClient();93 //设置httpClient连接主机服务器超时时间：15000毫秒

94 httpClient.getHttpConnectionManager().getParams().setConnectionTimeout(15000);95 //创建post请求方法实例对象

96 PostMethod postMethod = newPostMethod(url);97 //设置post请求超时时间

98 postMethod.getParams().setParameter(HttpMethodParams.SO\_TIMEOUT, 60000);99

100 NameValuePair\[\] nvp = null;101 //判断参数map集合paramMap是否为空

102 if (null != paramMap && paramMap.size() > 0) \{//不为空103 //创建键值参数对象数组，大小为参数的个数

104 nvp = newNameValuePair\[paramMap.size()\];105 //循环遍历参数集合map

106 Set> entrySet =paramMap.entrySet();107 //获取迭代器

108 Iterator> iterator =entrySet.iterator();109

110 int index = 0;111 while(iterator.hasNext()) \{112 Entry mapEntry =iterator.next();113 //从mapEntry中获取key和value创建键值对象存放到数组中

114 try\{115 nvp\[index\] = newNameValuePair(mapEntry.getKey(),116 new String(mapEntry.getValue().toString().getBytes("UTF-8"), "UTF-8"));117 \} catch(UnsupportedEncodingException e) \{118 e.printStackTrace();119 \}120 index++;121 \}122 \}123 //判断nvp数组是否为空

124 if (null != nvp && nvp.length > 0) \{125 //将参数存放到requestBody对象中

126 postMethod.setRequestBody(nvp);127 \}128 //执行POST方法

129 try\{130 int statusCode =httpClient.executeMethod(postMethod);131 //判断是否成功

132 if (statusCode !=HttpStatus.SC\_OK) \{133 System.err.println("Method faild: " +postMethod.getStatusLine());134 \}135 //获取远程返回的数据

136 is =postMethod.getResponseBodyAsStream();137 //封装输入流

138 br = new BufferedReader(new InputStreamReader(is, "UTF-8"));139

140 StringBuffer sbf = newStringBuffer();141 String temp = null;142 while ((temp = br.readLine()) != null) \{143 sbf.append(temp).append("\\r\\n");144 \}145

146 result =sbf.toString();147 \} catch(IOException e) \{148 e.printStackTrace();149 \} finally\{150 //关闭资源

151 if (null !=br) \{152 try\{153 br.close();154 \} catch(IOException e) \{155 e.printStackTrace();156 \}157 \}158 if (null !=is) \{159 try\{160 is.close();161 \} catch(IOException e) \{162 e.printStackTrace();163 \}164 \}165 //释放连接

166 postMethod.releaseConnection();167 \}168 returnresult;169 \}170 \}