设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

关于Java去连接HTTP地址的操作

2017-2-7 13:41| 发布者: zhangjf| 查看: 546| 评论: 0

摘要: 使用HTTPClient进行操作,可以忽略SSL /** * @author Kai * @Date 2015-7-28 19:47:16 */public class HTTPClient { //HTTP请求读取超时时间 private static final int SOCKET_TIME_OUT = 5000; //HTTP请求 ...

使用HTTPClient进行操作,可以忽略SSL

  1. /**
  2. * @author Kai
  3. * @Date 2015-7-28 19:47:16
  4. */
  5. public class HTTPClient {
  7. //HTTP请求读取超时时间
  8. private static final int SOCKET_TIME_OUT = 5000;
  9. //HTTP请求连接时间
  10. private static final int CONNECT_TIME_OUT = 5000;
  11. //请求重试次数
  12. private static final int RETRY_TIMES = 3;
  14. /**
  15. *
  16. * @param address 请求地址
  17. * @param method 请求方式
  18. * @param params 请求参数
  19. * @param paramSendType 发送类型
  20. * @param cookies 设置cookies值发送
  21. * @return
  22. */
  23. public String request(String address, String method, String params, String paramSendType, String cookies) {
  24. address = address.trim();
  25. CloseableHttpResponse closeableHttpResponse = null;
  26. if (SupportProtocol.HTTP_METHOD_GET.equalsIgnoreCase(method)) {
  27. closeableHttpResponse = this.GET(address, params, paramSendType, cookies);
  28. } else if (SupportProtocol.HTTP_METHOD_POST.equalsIgnoreCase(method)) {
  29. closeableHttpResponse = this.POST(address, params, paramSendType, cookies);
  30. } else if (SupportProtocol.HTTP_METHOD_PUT.equalsIgnoreCase(method)) {
  31. closeableHttpResponse = this.PUT(address, params, paramSendType, cookies);
  32. } else {
  33. closeableHttpResponse = this.POST(address, params, paramSendType, cookies);
  34. }
  36. return this.buildReponseMsg(closeableHttpResponse);
  37. }
  39. private CloseableHttpResponse PUT(String address, String params, String paramSendType, String cookies) {
  40. try {
  41. URI uri = URI.create(address);
  42. HttpPut httpPut = new HttpPut(uri);
  43. RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(SOCKET_TIME_OUT).setConnectTimeout(CONNECT_TIME_OUT).build();
  44. httpPut.setConfig(requestConfig);
  46. if (SupportProtocol.SUPPORT_JSON.equalsIgnoreCase(paramSendType)) {
  47. httpPut.setHeader("Content-Type", "application/json; charset=UTF-8");
  48. StringEntity entity = new StringEntity(params, ContentType.APPLICATION_JSON);
  49. httpPut.setEntity(entity);
  50. } else if (SupportProtocol.SUPPORT_JSON.equalsIgnoreCase(paramSendType)) {
  51. httpPut.setHeader("Content-Type", "application/xml; charset=UTF-8");
  52. StringEntity entity = new StringEntity(params, ContentType.APPLICATION_XML);
  53. httpPut.setEntity(entity);
  54. } else {
  55. httpPut.setHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
  56. StringEntity entity = new StringEntity(params, ContentType.APPLICATION_FORM_URLENCODED);
  57. httpPut.setEntity(entity);
  58. }
  60. if (StrUtil.isNotEmpty(cookies)) {
  61. httpPut.setHeader("Cookie", cookies);
  62. }
  64. CloseableHttpClient httpClient = HttpClients.createDefault();
  66. if (address.toLowerCase().startsWith("https")) {
  67. httpClient = this.createSSLClientDefault();
  68. }
  70. return httpClient.execute(httpPut);
  71. } catch (Exception ex) {
  72. LogUtil.error(ex);
  73. }
  74. return null;
  75. }
  77. private CloseableHttpResponse GET(String address, String params, String paramSendType, String cookies) {
  78. try {
  79. URI uri;
  80. if (EmptyUtil.isNotEmpty(params)) {
  81. uri = URI.create(String.format("%s?%s", address, params));
  82. } else {
  83. uri = URI.create(address);
  84. }
  86. HttpGet httpGet = new HttpGet(uri);
  87. RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(SOCKET_TIME_OUT).setConnectTimeout(CONNECT_TIME_OUT).build();
  88. httpGet.setConfig(requestConfig);
  90. if (SupportProtocol.SUPPORT_JSON.equalsIgnoreCase(paramSendType)) {
  91. httpGet.setHeader("Content-Type", "application/json; charset=UTF-8");
  92. } else if (SupportProtocol.SUPPORT_XML.equalsIgnoreCase(paramSendType)) {
  93. httpGet.setHeader("Content-Type", "application/xml; charset=UTF-8");
  94. } else {
  95. httpGet.setHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
  96. }
  98. if (StrUtil.isNotEmpty(cookies)) {
  99. httpGet.setHeader("Cookie", cookies);
  100. }
  101. CloseableHttpClient httpClient = HttpClients.createDefault();
  102. if (address.toLowerCase().startsWith("https")) {
  103. httpClient = this.createSSLClientDefault();
  104. }
  105. return httpClient.execute(httpGet);
  106. } catch (Exception ex) {
  107. LogUtil.error(ex);
  108. }
  109. return null;
  110. }
  112. private CloseableHttpResponse POST(String address, String params, String paramSendType, String cookies) {
  113. try {
  114. URI uri = URI.create(address);
  115. HttpPost httpPost = new HttpPost(uri);
  116. RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(SOCKET_TIME_OUT).setConnectTimeout(CONNECT_TIME_OUT).build();
  117. httpPost.setConfig(requestConfig);
  119. if (SupportProtocol.SUPPORT_JSON.equalsIgnoreCase(paramSendType)) {
  120. httpPost.setHeader("Content-Type", "application/json; charset=UTF-8");
  121. StringEntity entity = new StringEntity(params, ContentType.APPLICATION_JSON);
  122. httpPost.setEntity(entity);
  123. } else if (SupportProtocol.SUPPORT_XML.equalsIgnoreCase(paramSendType)) {
  124. httpPost.setHeader("Content-Type", "application/xml; charset=UTF-8");
  125. StringEntity entity = new StringEntity(params, ContentType.APPLICATION_XML);
  126. httpPost.setEntity(entity);
  127. } else {
  128. httpPost.setHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
  129. StringEntity entity = new StringEntity(params, ContentType.APPLICATION_FORM_URLENCODED);
  130. httpPost.setEntity(entity);
  131. }
  133. if (StrUtil.isNotEmpty(cookies)) {
  134. httpPost.setHeader("Cookie", cookies);
  135. }
  137. CloseableHttpClient httpClient = HttpClients.createDefault();
  138. if (address.toLowerCase().startsWith("https")) {
  139. httpClient = this.createSSLClientDefault();
  140. }
  141. return httpClient.execute(httpPost);
  142. } catch (Exception ex) {
  143. LogUtil.error(ex);
  144. }
  145. return null;
  146. }
  148. private CloseableHttpClient createSSLClientDefault() {
  149. try {
  150. SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
  151. @Override
  152. public boolean isTrusted(X509Certificate[] chain,
  153. String authType) throws CertificateException {
  154. return true;
  155. }
  156. }).build();
  157. SSLSocketFactory ssf = new SSLSocketFactory(sslContext, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
  158. return HttpClients.custom().setSSLSocketFactory(ssf).build();
  159. } catch (Exception e) {
  160. LogUtil.error(e.getMessage());
  161. }
  162. return HttpClients.createDefault();
  163. }
  165. private String buildReponseMsg(CloseableHttpResponse closeableHttpResponse) {
  166. if (closeableHttpResponse == null) {
  167. return null;
  168. }
  169. try {
  170. int code = closeableHttpResponse.getStatusLine().getStatusCode();
  171. String msg = EntityUtils.toString(closeableHttpResponse.getEntity());
  172. if (code == HttpStatus.SC_OK) {
  173. return msg;
  174. }
  175. } catch (Exception ex) {
  176. LogUtil.error(ex);
  177. }
  178. return null;
  179. }
  180. }
复制代码


使用URLConnection读取数据,访问HTTPS貌似有问题

  1. package com.k.ctc.http;
  3. import java.io.BufferedReader;
  4. import java.io.InputStreamReader;
  5. import java.io.OutputStreamWriter;
  6. import java.io.UnsupportedEncodingException;
  7. import java.net.URL;
  8. import java.net.URLConnection;
  9. import java.net.URLEncoder;
  10. import java.util.Map;
  12. /**
  13. *
  14. * @author Kai
  15. */
  16. public class Connector {
  18. public String GET(String address, Map<String, String> params) throws Exception {
  19. String param = this.buildParams(params);
  20. URL url = new URL(address + "?" + param);
  21. URLConnection conn = url.openConnection();
  22. return this.readData(conn);
  23. }
  25. public String GET(String address, String params) throws Exception {
  26. URL url = new URL(address + "?" + params);
  27. URLConnection conn = url.openConnection();
  28. return this.readData(conn);
  29. }
  31. public String POST(String address, Map<String, String> params) throws Exception {
  32. String param = this.buildParams(params);
  33. URL url = new URL(address);
  34. URLConnection conn = url.openConnection();
  35. this.postData(conn, param);
  36. return this.readData(conn);
  37. }
  39. public String POST(String address, String param) throws Exception {
  40. URL url = new URL(address);
  41. URLConnection conn = url.openConnection();
  42. this.postData(conn, param);
  43. return this.readData(conn);
  44. }
  46. private String buildParams(Map<String, String> params) throws UnsupportedEncodingException {
  47. StringBuilder sb = new StringBuilder();
  48. for (Map.Entry<String, String> param : params.entrySet()) {
  49. sb.append(param.getKey()).append("=");
  50. sb.append(URLEncoder.encode(param.getValue(), "UTF-8"));
  51. sb.append("&");
  52. }
  53. return sb.toString();
  54. }
  56. private void postData(final URLConnection conn, String requestData) throws Exception {
  57. conn.setDoOutput(true);
  58. OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream());
  59. wr.write(requestData);
  60. wr.flush();
  61. wr.close();
  62. }
  64. private String readData(final URLConnection conn) throws Exception {
  65. String responseData = "";
  66. BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
  67. String line;
  68. while ((line = rd.readLine()) != null) {
  69. responseData += line;
  70. }
  71. responseData = new String(responseData.getBytes(), "UTF-8");
  72. rd.close();
  73. return responseData;
  74. }
  75. }
复制代码


做个代码记录 Maven引用

  1. <dependency>
  2. <groupId>org.apache.httpcomponents</groupId>
  3. <artifactId>httpclient</artifactId>
  4. <version>4.4</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.apache.httpcomponents</groupId>
  8. <artifactId>httpcore</artifactId>
  9. <version>4.4</version>
  10. </dependency>
  11. <dependency>
  12. <groupId>org.apache.httpcomponents</groupId>
  13. <artifactId>httpcore-nio</artifactId>
  14. <version>4.4</version>
  15. </dependency>
复制代码



来自： http://my.oschina.net/Kxvz/blog/599039

收藏 邀请
上一篇：java中OutOfMemory种类和解决方法下一篇：Java显示两个时间相差几天几小时几分几秒

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-7-9 09:43

Copyright 2015-2025 djqfx

返回顶部