个人随笔
目录
调用微服务的Http请求工具类
2020-09-11 22:47:41

下面是Http get和post请求的工具类，在调用微服务接口的时候很实用，当然是外部调用微服务而不是服务之间的调用哦，服务之间的调用用feign比较方便，代码如下

  1. package cn.myforever.utils;
  3. import java.io.IOException;
  4. import java.security.KeyManagementException;
  5. import java.security.NoSuchAlgorithmException;
  6. import java.security.cert.CertificateException;
  7. import java.security.cert.X509Certificate;
  8. import java.util.ArrayList;
  9. import java.util.Arrays;
  10. import java.util.List;
  11. import java.util.Map;
  13. import javax.net.ssl.SSLContext;
  14. import javax.net.ssl.TrustManager;
  15. import javax.net.ssl.X509TrustManager;
  17. import org.apache.http.HttpEntity;
  18. import org.apache.http.HttpResponse;
  19. import org.apache.http.NameValuePair;
  20. import org.apache.http.client.HttpClient;
  21. import org.apache.http.client.config.AuthSchemes;
  22. import org.apache.http.client.config.CookieSpecs;
  23. import org.apache.http.client.config.RequestConfig;
  24. import org.apache.http.client.entity.UrlEncodedFormEntity;
  25. import org.apache.http.client.methods.HttpGet;
  26. import org.apache.http.client.methods.HttpPost;
  27. import org.apache.http.config.Registry;
  28. import org.apache.http.config.RegistryBuilder;
  29. import org.apache.http.conn.socket.ConnectionSocketFactory;
  30. import org.apache.http.conn.socket.PlainConnectionSocketFactory;
  31. import org.apache.http.conn.ssl.NoopHostnameVerifier;
  32. import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
  33. import org.apache.http.entity.StringEntity;
  34. import org.apache.http.impl.client.CloseableHttpClient;
  35. import org.apache.http.impl.client.HttpClientBuilder;
  36. import org.apache.http.impl.client.HttpClients;
  37. import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
  38. import org.apache.http.message.BasicNameValuePair;
  39. import org.apache.http.util.EntityUtils;
  40. import org.slf4j.Logger;
  41. import org.slf4j.LoggerFactory;
  42. /**
  43.  * setConnectTimeout：设置连接超时时间，单位毫秒。
  45. setConnectionRequestTimeout：设置从connect Manager(连接池)获取Connection 超时时间，单位毫秒。这个属性是新加的属性，因为目前版本是可以共享连接池的。
  47. setSocketTimeout：请求获取数据的超时时间(即响应时间)，单位毫秒。 如果访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。
  48.  */
  49. /**
  50.  * http请求工具类
  51.  * @author lwh
  52.  * @date 20181130
  53.  */
  54. public class HttpUtils {
  55. private static final Integer  CONNECT_TIMEOUT = 5000;//接超时时间，单位毫秒
  56. private static final Integer  CONNECT_REQUEST_TIMEOUT = 1000;//从connect Manager(连接池)获取Connection 超时时间，单位毫秒。
  57. private static final Integer  SOCKET_TIMEOUT = 5000;//响应时间
  58. private static final Logger log = LoggerFactory.getLogger(HttpUtils.class);
  59.     /**
  60.      * url get请求
  61.      * @param url 访问的url
  62.      * @return
  63.      * @throws Exception
  64.      */
  65.     public static String doGet(String url) throws Exception {
  66.     log.info("请求的url:"+url);
  67.     HttpResponse response = doGet(url, null, CONNECT_TIMEOUT, CONNECT_REQUEST_TIMEOUT, SOCKET_TIMEOUT);
  68.     String result = getString(response);
  69.     log.info("返回的值："+result);
  70.     return result;
  71.     }
  72.     /**
  73.      * url post请求
  74.      * @param url 请求的url
  75.      * @param json 传输的json信息，建议全部转换成json回来
  76.      * @return
  77.      * @throws Exception
  78.      */
  79.     public static String doPost(String url,String json) throws Exception {
  80.     log.info("请求的url:"+url);
  81.     HttpResponse response = doPost(url, json, CONNECT_TIMEOUT, CONNECT_REQUEST_TIMEOUT, SOCKET_TIMEOUT);
  82.     String result = getString(response);
  83.     log.info("返回的值："+result);
  84.     return result;
  85.     }
  88.     public static HttpResponse doGet(String path,Map<String, String> querys,Integer connectTimeout,Integer ConnectionRequestTimeout,Integer responseConnectTimeout)
  89.             throws Exception {
  90.         HttpClient httpClient = wrapClient(path);
  91.         HttpGet request = new HttpGet(path);
  92.         RequestConfig requestConfig = RequestConfig.custom()  
  93.                 .setConnectTimeout(connectTimeout).setConnectionRequestTimeout(ConnectionRequestTimeout)  
  94.                 .setSocketTimeout(responseConnectTimeout).build();  
  95.         request.setConfig(requestConfig);  
  97.         return httpClient.execute(request);
  98.     }
  99.     public static HttpResponse doPost(String path,
  100.                                       Map<String, Object> bodys,Integer connectTimeout,Integer ConnectionRequestTimeout,Integer responseConnectTimeout)
  101.             throws Exception {
  102.         HttpClient httpClient = wrapClient(path);
  103.         HttpPost request = new HttpPost(path);
  104.         RequestConfig requestConfig = RequestConfig.custom()  
  105.                 .setConnectTimeout(5000).setConnectionRequestTimeout(1000)  
  106.                 .setSocketTimeout(5000).build();  
  107.         request.setConfig(requestConfig);  
  108.         if (bodys != null) {
  109.             List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
  110.             for (String key : bodys.keySet()) {
  111.                 nameValuePairList.add(new BasicNameValuePair(key, bodys.get(key).toString()));
  112.             }
  113.             UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
  114.             formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
  115.             request.setEntity(formEntity);
  116.         }
  117.         return httpClient.execute(request);
  118.     }
  119.     public static HttpResponse doPost(String path,
  120.            String  jsonBody,Integer connectTimeout,Integer ConnectionRequestTimeout,Integer responseConnectTimeout)
  121.             throws Exception {
  122.     HttpClient httpClient = wrapClient(path);
  123.     HttpPost request = new HttpPost(path);
  124.     RequestConfig requestConfig = RequestConfig.custom()  
  125.                 .setConnectTimeout(5000).setConnectionRequestTimeout(1000)  
  126.                 .setSocketTimeout(5000).build();  
  127.         request.setConfig(requestConfig); 
  128.     if (jsonBody != null) {
  129.     @SuppressWarnings("deprecation")
  130. StringEntity entity = new StringEntity(jsonBody, "text/xml", "utf-8");
  131.     entity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
  132.     request.setEntity(entity);
  133.     }
  134.     return httpClient.execute(request);
  135. }
  138.     /**
  139.      * 获取 HttpClient
  140.      * @param path
  141.      * @return
  142.      */
  143.     private static HttpClient wrapClient(String path) {
  144.         HttpClient httpClient = HttpClientBuilder.create().build();
  145.         if (path != null && path.startsWith("https://")) {
  146.             return sslClient();
  147.         }
  148.         return httpClient;
  149.     }
  151.     /**
  152.      * 在调用SSL之前需要重写验证方法，取消检测SSL
  153.      * 创建ConnectionManager，添加Connection配置信息
  154.      * @return HttpClient 支持https
  155.      */
  156.     private static HttpClient sslClient() {
  157.         try {
  158.             // 在调用SSL之前需要重写验证方法，取消检测SSL
  159.             X509TrustManager trustManager = new X509TrustManager() {
  160. public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {}
  161. public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {}
  162. public X509Certificate[] getAcceptedIssuers() {
  163. return null;
  164. }
  165.             };
  166.             SSLContext ctx = SSLContext.getInstance(SSLConnectionSocketFactory.TLS);
  167.             ctx.init(null, new TrustManager[] { trustManager }, null);
  168.             SSLConnectionSocketFactory socketFactory = new SSLConnectionSocketFactory(ctx, NoopHostnameVerifier.INSTANCE);
  169.             // 创建Registry
  170.             RequestConfig requestConfig = RequestConfig.custom().setCookieSpec(CookieSpecs.STANDARD_STRICT)
  171.                     .setExpectContinueEnabled(Boolean.TRUE).setTargetPreferredAuthSchemes(Arrays.asList(AuthSchemes.NTLM,AuthSchemes.DIGEST))
  172.                     .setProxyPreferredAuthSchemes(Arrays.asList(AuthSchemes.BASIC)).build();
  173.             Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
  174.                     .register("http", PlainConnectionSocketFactory.INSTANCE)
  175.                     .register("https",socketFactory).build();
  176.             // 创建ConnectionManager，添加Connection配置信息
  177.             PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
  178.             CloseableHttpClient closeableHttpClient = HttpClients.custom().setConnectionManager(connectionManager)
  179.                     .setDefaultRequestConfig(requestConfig).build();
  180.             return closeableHttpClient;
  181.         } catch (KeyManagementException ex) {
  182.             throw new RuntimeException(ex);
  183.         } catch (NoSuchAlgorithmException ex) {
  184.             throw new RuntimeException(ex);
  185.         }
  186.     }
  187.     public static String getString(HttpResponse httpResponse) throws IOException {
  188.         HttpEntity entity = httpResponse.getEntity();
  189.         String resp = EntityUtils.toString(entity, "UTF-8");
  190.         return resp;
  191.     }
  192. }

当然，需要在maven中引入如下内容

  1. <dependency>
  2.     <groupId>org.apache.httpcomponents</groupId>
  3.     <artifactId>httpclient</artifactId>
  4.       <version>4.4</version>
  5.     </dependency>
  6. <dependency>

其实上面的也不是我自己写的啦，也不知道是网上哪一个大神写的，忘记了，若是谁看到了，说侵权我就删了

 418

啊！这个可能是世界上最丑的留言输入框功能~


当然，也是最丑的留言列表

有疑问发邮件到 : suibibk@qq.com 侵权立删
Copyright : 个人随笔   备案号 : 粤ICP备18099399号-2