为Spring的RestTemplate配置HttpClient连接池和异步任务

ゝ一纸荒年。 2022-03-12 02:05 427阅读 0赞

<bean id="pollingConnectionManager" class="org.apache.http.impl.conn.PoolingHttpClientConnectionManager">
            
            <property name="maxTotal" value="1000"/>
            
            <property name="defaultMaxPerRoute" value="1000"/>
        </bean>
    
        <bean id="httpClientBuilder" class="org.apache.http.impl.client.HttpClientBuilder" factory-method="create">
            <property name="connectionManager" ref="pollingConnectionManager"/>
            
            <property name="retryHandler">
                <bean class="org.apache.http.impl.client.DefaultHttpRequestRetryHandler">
                    <constructor-arg value="0"/>
                    <constructor-arg value="false"/>
                </bean>
            </property>
            <property name="defaultHeaders">
                <list>
                    <bean class="org.apache.http.message.BasicHeader">
                        <constructor-arg value="User-Agent"/>
                        <constructor-arg value="Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/31.0.1650.16 Safari/537.36"/>
                    </bean>
                    <bean class="org.apache.http.message.BasicHeader">
                        <constructor-arg value="Accept-Encoding"/>
                        <constructor-arg value="gzip,deflate"/>
                    </bean>
                    <bean class="org.apache.http.message.BasicHeader">
                        <constructor-arg value="Accept-Language"/>
                        <constructor-arg value="zh-CN"/>
                    </bean>
                </list>
            </property>
    
        </bean>
    
        <bean id="httpClient" factory-bean="httpClientBuilder" factory-method="build"/>
    
        
        <bean id="clientHttpRequestFactory"
              class="org.springframework.http.client.HttpComponentsClientHttpRequestFactory">
            <constructor-arg ref="httpClient"/>
    
            
            <property name="connectTimeout" value="60000"/>
    
            
            <property name="readTimeout" value="60000"/>
    
            
            <property name="connectionRequestTimeout" value="200"/>
    
            
            <property name="bufferRequestBody" value="true"/>
        </bean>
    
        
        <alias name="defaultRestTemplate" alias="restTemplate"/>
        <bean id="defaultRestTemplate" class="org.springframework.web.client.RestTemplate">
            <constructor-arg ref="clientHttpRequestFactory"/>
            <property name="errorHandler">
                <bean class="org.springframework.web.client.DefaultResponseErrorHandler"/>
            </property>
    
            
            <property name="messageConverters">
                <list>
                    <bean class="org.springframework.http.converter.xml.SourceHttpMessageConverter" />
                    <bean class="org.springframework.http.converter.xml.MarshallingHttpMessageConverter" />
                    <bean class="org.springframework.http.converter.ByteArrayHttpMessageConverter"/>
                    <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter">
                        <property name="supportedMediaTypes">
                            <list>
                                <value>application/json;charset=UTF-8</value>
                                
                            </list>
                        </property>
                    </bean>
                    <bean class="org.springframework.http.converter.StringHttpMessageConverter">
                        <property name="supportedMediaTypes">
                            <list>
                                <value>text/plain;charset=UTF-8</value>
                                <value>application/json;charset=UTF-8</value>
                                <value>application/xml;charset=UTF-8</value>
                            </list>
                        </property>
                    </bean>
                    <bean class="org.springframework.http.converter.FormHttpMessageConverter">
                        <property name="supportedMediaTypes">
                            <list>
                                <value>application/x-www-form-urlencoded</value>
                            </list>
                        </property>
                    </bean>
                </list>
            </property>
        </bean>
        
        <task:executor id="executor" pool-size="10-100" queue-capacity="10" keep-alive="10" rejection-policy="CALLER_RUNS"/>
        <task:annotation-driven executor="executor"/>

// 通过代码配置RestTemplate的Http连接池
    PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();
                connectionManager.setDefaultMaxPerRoute(1000);
                connectionManager.setMaxTotal(1000);
                this.restTemplate = new RestTemplate(new HttpComponentsClientHttpRequestFactory(
                        HttpClientBuilder.create().setConnectionManager(connectionManager).build()
                ));

// 使用Reactor+SpringMVC可以实现异步，WebFlux中直接使用WebClient实例来异步请求
    // 相当于RestTemplate、AsyncRestTemplate是SpringMVC中的【RestTemplate + Reactor可以变成和WebClient一样的效果，AsyncRestTemplate是一个轻量的异步实现】，WebClient是WebFlux中的，但是WebClient性能更好
    Mono.fromCallable(() -> restTemplate.getForObject(TARGET_HOST + "/hello/" + latency, String.class))
                    .subscribeOn(Schedulers.elastic());

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* 不积跬步无以至千里，不积小流无以成江海 \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*