HttpUtils.java 9.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268
  1. package com.usky.dxtop.common.utils.http;
  2. import com.usky.dxtop.common.constant.Constants;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  5. import javax.net.ssl.*;
  6. import java.io.*;
  7. import java.net.ConnectException;
  8. import java.net.SocketTimeoutException;
  9. import java.net.URL;
  10. import java.net.URLConnection;
  11. import java.security.cert.X509Certificate;
  12. import java.util.Map;
  13. /**
  14. * 通用http发送方法
  15. *
  16. * @author yq
  17. */
  18. public class HttpUtils
  19. {
  20. private static final Logger log = LoggerFactory.getLogger(HttpUtils.class);
  21. /**
  22. * 向指定 URL 发送GET方法的请求
  23. *
  24. * @param url 发送请求的 URL
  25. * @param param 请求参数,请求参数应该是 name1=value1&name2=value2 的形式。
  26. * @return 所代表远程资源的响应结果
  27. */
  28. public static String sendGet(String url, String param, Map<String,String> map)
  29. {
  30. return sendGet(url, param, Constants.UTF8,map);
  31. }
  32. /**
  33. * 向指定 URL 发送GET方法的请求
  34. *
  35. * @param url 发送请求的 URL
  36. * @param param 请求参数,请求参数应该是 name1=value1&name2=value2 的形式。
  37. * @param contentType 编码类型
  38. * @return 所代表远程资源的响应结果
  39. */
  40. public static String sendGet(String url, String param, String contentType, Map<String,String> map)
  41. {
  42. StringBuilder result = new StringBuilder();
  43. BufferedReader in = null;
  44. try
  45. {
  46. String urlNameString = url + "?" + param;
  47. URL realUrl = new URL(urlNameString);
  48. URLConnection connection = realUrl.openConnection();
  49. connection.setRequestProperty("accept", "*/*");
  50. connection.setRequestProperty("connection", "Keep-Alive");
  51. connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  52. if (null != map && !map.isEmpty()){
  53. for (String key:map.keySet()) {
  54. connection.setRequestProperty(key,map.get(key));
  55. }
  56. }
  57. connection.connect();
  58. in = new BufferedReader(new InputStreamReader(connection.getInputStream(), contentType));
  59. String line;
  60. while ((line = in.readLine()) != null)
  61. {
  62. result.append(line);
  63. }
  64. }
  65. catch (ConnectException e)
  66. {
  67. log.error("调用HttpUtils.sendGet ConnectException, url=" + url + ",param=" + param, e);
  68. }
  69. catch (SocketTimeoutException e)
  70. {
  71. log.error("调用HttpUtils.sendGet SocketTimeoutException, url=" + url + ",param=" + param, e);
  72. }
  73. catch (IOException e)
  74. {
  75. log.error("调用HttpUtils.sendGet IOException, url=" + url + ",param=" + param, e);
  76. }
  77. catch (Exception e)
  78. {
  79. log.error("调用HttpsUtil.sendGet Exception, url=" + url + ",param=" + param, e);
  80. }
  81. finally
  82. {
  83. try
  84. {
  85. if (in != null)
  86. {
  87. in.close();
  88. }
  89. }
  90. catch (Exception ex)
  91. {
  92. log.error("调用in.close Exception, url=" + url + ",param=" + param, ex);
  93. }
  94. }
  95. return result.toString();
  96. }
  97. /**
  98. * 向指定 URL 发送POST方法的请求
  99. *
  100. * @param url 发送请求的 URL
  101. * @param param 请求参数,请求参数应该是 name1=value1&name2=value2 的形式。
  102. * @return 所代表远程资源的响应结果
  103. */
  104. public static String sendPost(String url, String param, Map<String,String> map)
  105. {
  106. PrintWriter out = null;
  107. BufferedReader in = null;
  108. StringBuilder result = new StringBuilder();
  109. try
  110. {
  111. String urlNameString = url;
  112. log.info("sendPost - {}", urlNameString);
  113. URL realUrl = new URL(urlNameString);
  114. URLConnection conn = realUrl.openConnection();
  115. conn.setRequestProperty("accept", "*/*");
  116. conn.setRequestProperty("connection", "Keep-Alive");
  117. conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  118. conn.setRequestProperty("Accept-Charset", "utf-8");
  119. conn.setRequestProperty("contentType", "utf-8");
  120. conn.setDoOutput(true);
  121. conn.setDoInput(true);
  122. if (null != map && !map.isEmpty()){
  123. for (String key:map.keySet()) {
  124. conn.setRequestProperty(key,map.get(key));
  125. }
  126. }
  127. out = new PrintWriter(conn.getOutputStream());
  128. out.print(param);
  129. out.flush();
  130. in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"));
  131. String line;
  132. while ((line = in.readLine()) != null)
  133. {
  134. result.append(line);
  135. }
  136. log.info("recv - {}", result);
  137. }
  138. catch (ConnectException e)
  139. {
  140. log.error("调用HttpUtils.sendPost ConnectException, url=" + url + ",param=" + param, e);
  141. }
  142. catch (SocketTimeoutException e)
  143. {
  144. log.error("调用HttpUtils.sendPost SocketTimeoutException, url=" + url + ",param=" + param, e);
  145. }
  146. catch (IOException e)
  147. {
  148. log.error("调用HttpUtils.sendPost IOException, url=" + url + ",param=" + param, e);
  149. }
  150. catch (Exception e)
  151. {
  152. log.error("调用HttpsUtil.sendPost Exception, url=" + url + ",param=" + param, e);
  153. }
  154. finally
  155. {
  156. try
  157. {
  158. if (out != null)
  159. {
  160. out.close();
  161. }
  162. if (in != null)
  163. {
  164. in.close();
  165. }
  166. }
  167. catch (IOException ex)
  168. {
  169. log.error("调用in.close Exception, url=" + url + ",param=" + param, ex);
  170. }
  171. }
  172. return result.toString();
  173. }
  174. public static String sendSSLPost(String url, String param, Map<String,String> map)
  175. {
  176. StringBuilder result = new StringBuilder();
  177. String urlNameString = url + "?" + param;
  178. try
  179. {
  180. log.info("sendSSLPost - {}", urlNameString);
  181. SSLContext sc = SSLContext.getInstance("SSL");
  182. sc.init(null, new TrustManager[] { new TrustAnyTrustManager() }, new java.security.SecureRandom());
  183. URL console = new URL(urlNameString);
  184. HttpsURLConnection conn = (HttpsURLConnection) console.openConnection();
  185. conn.setRequestProperty("accept", "*/*");
  186. conn.setRequestProperty("connection", "Keep-Alive");
  187. conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  188. conn.setRequestProperty("Accept-Charset", "utf-8");
  189. conn.setRequestProperty("contentType", "utf-8");
  190. if (null != map && !map.isEmpty()){
  191. for (String key:map.keySet()) {
  192. conn.setRequestProperty(key,map.get(key));
  193. }
  194. }
  195. conn.setDoOutput(true);
  196. conn.setDoInput(true);
  197. conn.setSSLSocketFactory(sc.getSocketFactory());
  198. conn.setHostnameVerifier(new TrustAnyHostnameVerifier());
  199. conn.connect();
  200. InputStream is = conn.getInputStream();
  201. BufferedReader br = new BufferedReader(new InputStreamReader(is));
  202. String ret = "";
  203. while ((ret = br.readLine()) != null)
  204. {
  205. if (ret != null && !"".equals(ret.trim()))
  206. {
  207. result.append(new String(ret.getBytes("ISO-8859-1"), "utf-8"));
  208. }
  209. }
  210. log.info("recv - {}", result);
  211. conn.disconnect();
  212. br.close();
  213. }
  214. catch (ConnectException e)
  215. {
  216. log.error("调用HttpUtils.sendSSLPost ConnectException, url=" + url + ",param=" + param, e);
  217. }
  218. catch (SocketTimeoutException e)
  219. {
  220. log.error("调用HttpUtils.sendSSLPost SocketTimeoutException, url=" + url + ",param=" + param, e);
  221. }
  222. catch (IOException e)
  223. {
  224. log.error("调用HttpUtils.sendSSLPost IOException, url=" + url + ",param=" + param, e);
  225. }
  226. catch (Exception e)
  227. {
  228. log.error("调用HttpsUtil.sendSSLPost Exception, url=" + url + ",param=" + param, e);
  229. }
  230. return result.toString();
  231. }
  232. private static class TrustAnyTrustManager implements X509TrustManager
  233. {
  234. @Override
  235. public void checkClientTrusted(X509Certificate[] chain, String authType)
  236. {
  237. }
  238. @Override
  239. public void checkServerTrusted(X509Certificate[] chain, String authType)
  240. {
  241. }
  242. @Override
  243. public X509Certificate[] getAcceptedIssuers()
  244. {
  245. return new X509Certificate[] {};
  246. }
  247. }
  248. private static class TrustAnyHostnameVerifier implements HostnameVerifier
  249. {
  250. @Override
  251. public boolean verify(String hostname, SSLSession session)
  252. {
  253. return true;
  254. }
  255. }
  256. }