yaml配置类
# http线程池 http-pool:# 对同一个目标域名/IP:端口，最多建立多少个连接 maxPerRoute:200# 当前应用调用所有下游服务时，连接池最多保留多少个连接 maxTotal:1000# 从连接池租借连接的最长等待时间，单位：毫秒 connectionRequestTimeout:10000#TCP建连超时，单位：毫秒 connectTimeout:5000# 建连后等待下游响应数据的超时时间，单位：毫秒 socketTimeout:10000# 空闲连接回收时间，单位：分钟 maxIdleTime:5@ConfigurationpublicclassClientHttpPoolConfiguration{privatestaticfinallongDEFAULT_KEEP_ALIVE_MILLIS=20_000L;@AutowiredprivateHttpConnectionPoolConfigurationpoolConfiguration;@BeanpublicPoolingHttpClientConnectionManagerpoolingHttpClientConnectionManager(){PoolingHttpClientConnectionManagerresult=newPoolingHttpClientConnectionManager();result.setDefaultMaxPerRoute(poolConfiguration.getMaxPerRoute());result.setMaxTotal(poolConfiguration.getMaxTotal());returnresult;}@BeanpublicRequestConfigrequestConfig(){returnRequestConfig.custom().setConnectionRequestTimeout(poolConfiguration.getConnectionRequestTimeout()).setConnectTimeout(poolConfiguration.getConnectTimeout()).setSocketTimeout(poolConfiguration.getSocketTimeout()).build();}@BeanpublicCloseableHttpClienthttpClient(PoolingHttpClientConnectionManagerconnectionManager,RequestConfigrequestConfig){returnHttpClientBuilder.create().setConnectionManager(connectionManager).setDefaultRequestConfig(requestConfig).setKeepAliveStrategy((response,context)->{HeaderElementIteratoriterator=newBasicHeaderElementIterator(response.headerIterator(HTTP.CONN_KEEP_ALIVE));while(iterator.hasNext()){HeaderElementelement=iterator.nextElement();Stringname=element.getName();Stringvalue=element.getValue();if("timeout".equalsIgnoreCase(name)&&StringUtils.isNumeric(value)){returnLong.parseLong(value)*1000L;}}returnDEFAULT_KEEP_ALIVE_MILLIS;}).evictExpiredConnections().evictIdleConnections(poolConfiguration.getMaxIdleTime(),TimeUnit.MINUTES).build();}@BeanpublicPoolingHttpClientConnectionManagerpoolingHttpClientConnectionManager(){PoolingHttpClientConnectionManagermanager=newPoolingHttpClientConnectionManager();manager.setDefaultMaxPerRoute(poolConfiguration.getMaxPerRoute());manager.setMaxTotal(poolConfiguration.getMaxTotal());// 连接空闲超过 2 秒，再借出前进行有效性校验manager.setValidateAfterInactivity(2_000);returnmanager;}}@Component@ConfigurationProperties(prefix="http-pool")@DatapublicclassHttpConnectionPoolConfiguration{/** * 对同一个目标域名/IP:端口，最多建立多少个连接 */privateIntegermaxPerRoute;/** * 当前应用调用所有下游服务时，连接池最多保留多少个连接 */privateIntegermaxTotal;/** * 从连接池租借连接的最长等待时间，单位：毫秒 */privateIntegerconnectionRequestTimeout;/** * TCP 建连超时，单位：毫秒 */privateIntegerconnectTimeout;/** * 建连后等待下游响应数据的超时时间，单位：毫秒 */privateIntegersocketTimeout;/** * 空闲连接回收时间，单位：分钟 */privateIntegermaxIdleTime;/** * 连接空闲超过 2 秒，再借出前进行有效性校验 */privateIntegervalidateAfterInactivity;}@Configuration@Slf4jpublicclassRestTemplateConfiguration{@BeanpublicRestTemplaterestTemplate(HttpClienthttpClient){HttpComponentsClientHttpRequestFactoryfactory=newHttpComponentsClientHttpRequestFactory(httpClient);RestTemplaterestTemplate=newRestTemplate(factory);restTemplate.getMessageConverters().removeIf(converter->converterinstanceofStringHttpMessageConverter);restTemplate.getMessageConverters().add(0,newStringHttpMessageConverter(StandardCharsets.UTF_8));restTemplate.setErrorHandler(newMyResponseErrorHandler());returnrestTemplate;}}@Slf4jpublicclassMyResponseErrorHandlerextendsDefaultResponseErrorHandler{@OverridepublicvoidhandleError(URIurl,HttpMethodmethod,ClientHttpResponseresponse)throwsIOException{log.error("RestTemplate调用失败, url={}, method={}, statusCode={}",url,method.name(),response.getStatusCode().value());super.handleError(url,method,response);}}
