http方式调用webservice

Love The Way You Lie 2022-07-27 14:54 248阅读 0赞

http方式调用webservice 

  1. import org.apache.commons.httpclient.HttpStatus;
  2. import org.apache.http.HttpEntity;
  3. import org.apache.http.client.methods.HttpPost;
  4. import org.apache.http.client.methods.CloseableHttpResponse;
  5. import org.apache.http.client.ClientProtocolException;
  6. import org.apache.http.entity.StringEntity;
  7. import org.apache.http.impl.client.CloseableHttpClient;
  8. import org.apache.http.util.EntityUtils;
  9. import org.slf4j.Logger;
  10. import org.slf4j.LoggerFactory;
  11. import org.springframework.beans.factory.annotation.Autowired;
  13. import java.io.IOException;
  15. /**
  16.  * 通过Http Post调用webservice服务
  17.  * 
  18.  *
  19.  */
  20. public class CommonWebServiceClient {
  22.     private static Logger logger = LoggerFactory.getLogger(CommonWebServiceClient.class);
  24.     @Autowired
  25.     private CommonHttpServiceClient commonHttpServiceClient;
  27.     private String requestCharSet;
  29.     private String responseCharSet;
  31.     /**
  32.      * 
  33.      * @param postUrl webservice地址 
  34.      * @param requestXML 请求报文（soapUI工具请求报文）
  35.      * @param connectionTimeout 连接超时时间
  36.      * @param requestTimeout 请求超时时间
  37.      * @return
  38.      * @throws ClientProtocolException
  39.      * @throws IOException
  40.      */
  41.     public String invokeService(String postUrl, String requestXML, int connectionTimeout, int requestTimeout)
  42.             throws ClientProtocolException, IOException {
  44.         CloseableHttpClient httpClient = commonHttpServiceClient.getConnection(connectionTimeout, requestTimeout);
  45.         HttpPost httpPost = new HttpPost(postUrl);
  47.         StringEntity entity = new StringEntity(requestXML, requestCharSet);
  48.         httpPost.setEntity(entity);
  49.         httpPost.setHeader("Content-Type", "text/xml; charset="+requestCharSet);
  50.         httpPost.setHeader("SOAPAction", "");
  51.         CloseableHttpResponse httpResponse = httpClient.execute(httpPost);
  53.         String result = null;
  54.         int iCode = httpResponse.getStatusLine().getStatusCode();
  55.         if (HttpStatus.SC_OK == iCode) {
  56.             HttpEntity httpEntity = httpResponse.getEntity();
  57.             result = EntityUtils.toString(httpEntity, responseCharSet);
  58.         } else { // 如果返回非200，则手动关闭连接
  59.             httpPost.abort();
  60.             logger.info("get status code {} from server", httpResponse.getStatusLine().getStatusCode());
  61.         }
  62.         return result;
  63.     }
  65.     public void setRequestCharSet(String requestCharSet) {
  66.         this.requestCharSet = requestCharSet;
  67.     }
  69.     public void setResponseCharSet(String responseCharSet) {
  70.         this.responseCharSet = responseCharSet;
  71.     }
  73.     public String getRequestCharSet() {
  74.         return requestCharSet;
  75.     }
  77.     public String getResponseCharSet() {
  78.         return responseCharSet;
  79.     }
  80. }

http 连接池

  1. import org.apache.commons.lang3.StringUtils;
  2. import org.apache.http.client.config.RequestConfig;
  3. import org.apache.http.config.Registry;
  4. import org.apache.http.config.RegistryBuilder;
  5. import org.apache.http.config.SocketConfig;
  6. import org.apache.http.conn.socket.ConnectionSocketFactory;
  7. import org.apache.http.conn.socket.PlainConnectionSocketFactory;
  8. import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
  9. import org.apache.http.conn.ssl.SSLContexts;
  11. import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
  12. import org.apache.http.conn.ssl.X509HostnameVerifier;
  13. import org.apache.http.impl.client.CloseableHttpClient;
  14. import org.apache.http.impl.client.HttpClients;
  15. import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
  16. import org.slf4j.Logger;
  17. import org.slf4j.LoggerFactory;
  18. import javax.annotation.PostConstruct;
  19. import javax.net.ssl.SSLContext;
  21. import java.net.URI;
  22. import java.util.ArrayList;
  23. import java.util.Iterator;
  24. import java.util.Map;
  26. /**
  27.  * 
  28.  * 该类主要提供http相关的服务功能：(1)连接池
  29.  */
  30. public class CommonHttpServiceClient {
  32.     private final static Logger logger = LoggerFactory.getLogger(CommonHttpServiceClient.class);
  34.     private static PoolingHttpClientConnectionManager poolConnManager;
  36.     private int maxConnection;
  37.     private int maxConnPerRoute;
  38.     private int socketTimeout;
  40.     @PostConstruct
  41.     public void init() {
  42.         try {
  43.             SSLContext sslcontext = SSLContexts.custom().loadTrustMaterial(null,
  44.                     new TrustSelfSignedStrategy())
  45.                     .build();
  46.             X509HostnameVerifier hostnameVerifier = SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER;
  47.             SSLConnectionSocketFactory sslConnectionSocketFactory = new SSLConnectionSocketFactory(sslcontext, hostnameVerifier);
  48.             Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
  49.                     .register("http", PlainConnectionSocketFactory.getSocketFactory())
  50.                     .register("https", sslConnectionSocketFactory)
  51.                     .build();
  52.             poolConnManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
  53.             poolConnManager.setMaxTotal(getMaxConnection());
  54.             poolConnManager.setDefaultMaxPerRoute(getMaxConnPerRoute());
  55.             SocketConfig socketConfig = SocketConfig.custom().setSoTimeout(getSocketTimeout()).build();
  56.             poolConnManager.setDefaultSocketConfig(socketConfig);
  57.         } catch (Exception e) {
  58.             logger.error("catch exception when init PoolingHttpClientConnectionManager:" + e);
  59.         }
  60.     }
  62.     public CloseableHttpClient getConnection(int connectionTimeout, int requestTimeout) {
  63.         RequestConfig requestConfig = RequestConfig.custom().setConnectionRequestTimeout(connectionTimeout)
  64.                 .setConnectTimeout(connectionTimeout).setSocketTimeout(requestTimeout).build();
  65.         CloseableHttpClient httpClient = HttpClients.custom()
  66.                 .setConnectionManager(poolConnManager).setDefaultRequestConfig(requestConfig).build();
  67.         if (null != poolConnManager && null != poolConnManager.getTotalStats()) {
  68.             logger.info("now client pool " + poolConnManager.getTotalStats().toString());
  69.         }
  70.         return httpClient;
  71.     }
  73.     public static URI buildUri(String url, Map<String, String> parametersMap) {
  74.         if (null == parametersMap || parametersMap.isEmpty()) {
  75.             return URI.create(url);
  76.         }
  77.         ArrayList list = new ArrayList(parametersMap.size());
  78.         Iterator iterator = parametersMap.entrySet().iterator();
  80.         while (iterator.hasNext()) {
  81.             Map.Entry entry = (Map.Entry) iterator.next();
  82.             list.add(entry.getKey().toString().trim() + "=" + entry.getValue().toString().trim());
  83.         }
  84.         return list.isEmpty() ? URI.create(url) : URI.create(url + "?" + StringUtils.join(list, "&"));
  85.     }
  87.     public int getMaxConnection() {
  88.         return maxConnection;
  89.     }
  91.     public void setMaxConnection(int maxConnection) {
  92.         this.maxConnection = maxConnection;
  93.     }
  95.     public int getMaxConnPerRoute() {
  96.         return maxConnPerRoute;
  97.     }
  99.     public void setMaxConnPerRoute(int maxConnPerRoute) {
  100.         this.maxConnPerRoute = maxConnPerRoute;
  101.     }
  103.     public int getSocketTimeout() {
  104.         return socketTimeout;
  105.     }
  107.     public void setSocketTimeout(int socketTimeout) {
  108.         this.socketTimeout = socketTimeout;
  109.     }
  110. }

配置文件

  1. <bean id="commonHttpServiceClient" class="com.service.client.impl.CommonHttpServiceClient">
  2.         <property name="maxConnection" value="${http.connection.pool.max.connecton}"/>
  3.         <property name="maxConnPerRoute" value="${http.connection.pool.max.connection.per.router}"/>
  4.         <property name="socketTimeout" value="${http.connection.pool.socket.timeout}"/>
  5.     </bean>

值：

  1. http.connection.pool.max.connecton=2000
  2. http.connection.pool.max.connection.per.router=50
  3. http.connection.pool.socket.timeout=5000

如果出现httpclient一段时间后首次访问缓慢，可能是由于长连接被异常关闭，选择关闭长连接使用get方式 

  1. HttpGet get = new HttpGet("https://www.baidu.com");
  2.         get.setHeader("Connection", "close");

发表评论

表情：
评论列表 （有 0 条评论，248人围观）

还没有评论，来说两句吧...

相关阅读