RestTemplate优化

分手后的思念是犯贱 2022-04-13 11:26 639阅读 0赞

[附：SpringCloud之系列汇总跳转地址][SpringCloud]

RestTemplateConfig

package com.newland.iot.config;
    
    import org.apache.http.client.HttpClient;
    import org.apache.http.impl.client.DefaultConnectionKeepAliveStrategy;
    import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
    import org.apache.http.impl.client.HttpClientBuilder;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.http.client.ClientHttpRequestFactory;
    import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
    import org.springframework.web.client.RestTemplate;
    import java.util.concurrent.TimeUnit;
    
    @Configuration
    public class RestTemplateConfig {
    
    	@Bean
    	@LoadBalanced
    	public RestTemplate restTemplate() {
    		RestTemplate restTemplate = new RestTemplate(RestTemplateConfig.newClientHttpRequestFactory());
    	return restTemplate;
    	}
    
    	/**
    	 * 自定义RestTemplate配置
    	 * 1、设置最大连接数
    	 * 2、设置路由并发数
    	 * 3、设置重试次数
    	 * @author Hux
    	 * @return
    	 */
    	public static ClientHttpRequestFactory newClientHttpRequestFactory() {
    		
    		// 长连接保持时长30秒
    		PoolingHttpClientConnectionManager pollingConnectionManager = new PoolingHttpClientConnectionManager(
    				30, TimeUnit.SECONDS);
    		// 最大连接数
    		pollingConnectionManager.setMaxTotal(3000);
    		// 单路由的并发数
    		pollingConnectionManager.setDefaultMaxPerRoute(100);
    		HttpClientBuilder httpClientBuilder = HttpClients.custom();
    		httpClientBuilder.setConnectionManager(pollingConnectionManager);
    		// 重试次数2次，并开启
    		httpClientBuilder.setRetryHandler(new DefaultHttpRequestRetryHandler(2,
    				true));
    		// 保持长连接配置，需要在头添加Keep-Alive
    		httpClientBuilder
    				.setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy());
    		HttpClient httpClient = httpClientBuilder.build();
    		// httpClient连接底层配置clientHttpRequestFactory
    		HttpComponentsClientHttpRequestFactory clientHttpRequestFactory =
    		new HttpComponentsClientHttpRequestFactory(httpClient);
    		clientHttpRequestFactory.setReadTimeout(5000);// ms
    		clientHttpRequestFactory.setConnectTimeout(15000);//
    		return clientHttpRequestFactory;
    	}
    }

[附：SpringCloud之系列汇总跳转地址][SpringCloud]

[SpringCloud]: https://blog.csdn.net/qq_24313635/article/details/104061217