restTemplate踩过的坑-spring clound--cloud内部服务调用重试次数

骑猪看日落 2022-04-22 01:12 223阅读 0赞

转载自 [https://www.cnblogs.com/jimw/p/9037542.html][https_www.cnblogs.com_jimw_p_9037542.html]

现在公司项目基本都从臃肿的项目转换成微服务的方向转换，因此也从中使用了spring clound的一些组件，在此过程中就遇到了restTemplate的坑。

起初，是直接注入RestTemplate，后来则不断的遇到错误日志无法请求，出现异常。

异常信息：

org.springframework.web.util.NestedServletException: Request processing failed; nested exception is java.lang.IllegalStateException: No instances available for IP

意思是说url必须是服务的名称，猜测应该是涉及到eureka，直接用ip跟url调用是直接报错的。

因此不适用默认的，直接重新自定义，则引用了原有的注入修改一下。

当配置了这个之后，服务正常了。观察了一段时间，发现在并发的高峰期，开多几个服务器负载，也会存在服务出现请求非常慢，导致接口出现阻塞的情况出现，经过分析

1、出现阻塞的原因是因为高峰并发的时候，出现请求的链接数很大

因此找了源码，发现是因为restTemplate的默认配置值小于请求的链接数，而且路由并发也是默认为5的,因为微服务之间的逻辑处理中也有一定的时间。出现大规模阻塞的坑就这么踩到了。

![732794-20180514182635806-596459239.png][]

![732794-20180514182256720-1593303995.png][]

对代码改造一下，配置最大链接数，路由并发数，这个restTemplate的坑就这么解决了。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 </td> 
 <td> <code>package</code>&nbsp;<code>com.jingbei.guess.config.web;</code> &nbsp; <code>import</code>&nbsp;<code>java.security.KeyManagementException;</code> <code>import</code>&nbsp;<code>java.security.KeyStoreException;</code> <code>import</code>&nbsp;<code>java.security.NoSuchAlgorithmException;</code> <code>import</code>&nbsp;<code>java.security.cert.CertificateException;</code> <code>import</code>&nbsp;<code>java.security.cert.X509Certificate;</code> &nbsp; <code>import</code>&nbsp;<code>javax.net.ssl.HostnameVerifier;</code> <code>import</code>&nbsp;<code>javax.net.ssl.SSLContext;</code> &nbsp; <code>import</code>&nbsp;<code>org.apache.http.client.HttpClient;</code> <code>import</code>&nbsp;<code>org.apache.http.config.Registry;</code> <code>import</code>&nbsp;<code>org.apache.http.config.RegistryBuilder;</code> <code>import</code>&nbsp;<code>org.apache.http.conn.socket.ConnectionSocketFactory;</code> <code>import</code>&nbsp;<code>org.apache.http.conn.socket.PlainConnectionSocketFactory;</code> <code>import</code>&nbsp;<code>org.apache.http.conn.ssl.NoopHostnameVerifier;</code> <code>import</code>&nbsp;<code>org.apache.http.conn.ssl.SSLConnectionSocketFactory;</code> <code>import</code>&nbsp;<code>org.apache.http.conn.ssl.SSLContextBuilder;</code> <code>import</code>&nbsp;<code>org.apache.http.conn.ssl.TrustStrategy;</code> <code>import</code>&nbsp;<code>org.apache.http.impl.client.DefaultHttpRequestRetryHandler;</code> <code>import</code>&nbsp;<code>org.apache.http.impl.client.HttpClientBuilder;</code> <code>import</code>&nbsp;<code>org.apache.http.impl.conn.PoolingHttpClientConnectionManager;</code> <code>import</code>&nbsp;<code>org.springframework.context.annotation.Bean;</code> <code>import</code>&nbsp;<code>org.springframework.context.annotation.Configuration;</code> <code>import</code>&nbsp;<code>org.springframework.http.client.HttpComponentsClientHttpRequestFactory;</code> <code>import</code>&nbsp;<code>org.springframework.web.client.DefaultResponseErrorHandler;</code> <code>import</code>&nbsp;<code>org.springframework.web.client.RestTemplate;</code> &nbsp; <code>import</code>&nbsp;<code>lombok.extern.slf4j.Slf4j;</code> &nbsp; <code>/**</code> <code>&nbsp;</code><code>*</code> <code>&nbsp;</code><code>* 功能描述：</code> <code>&nbsp;</code><code>*</code> <code>&nbsp;</code><code>* @作者 jimw 创建时间： 2018-04</code> <code>&nbsp;</code><code>*</code> <code>&nbsp;</code><code>*/</code> <code>@Slf4j</code> <code>@Configuration</code> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>RestTemplateConfig { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Bean</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>RestTemplate restTemplate() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>RestTemplate restTemplate =&nbsp;</code><code>new</code>&nbsp;<code>RestTemplate();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>restTemplate.setRequestFactory(clientHttpRequestFactory());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>restTemplate.setErrorHandler(</code><code>new</code>&nbsp;<code>DefaultResponseErrorHandler());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>restTemplate;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Bean</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>HttpComponentsClientHttpRequestFactory clientHttpRequestFactory() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SSLContext sslContext =&nbsp;</code><code>new</code>&nbsp;<code>SSLContextBuilder().loadTrustMaterial(</code><code>null</code><code>,&nbsp;</code><code>new</code>&nbsp;<code>TrustStrategy() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>boolean</code>&nbsp;<code>isTrusted(X509Certificate[] arg0, String arg1)&nbsp;</code><code>throws</code>&nbsp;<code>CertificateException { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>true</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}).build();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>httpClientBuilder.setSSLContext(sslContext);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HostnameVerifier hostnameVerifier = NoopHostnameVerifier.INSTANCE;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SSLConnectionSocketFactory sslConnectionSocketFactory =&nbsp;</code><code>new</code>&nbsp;<code>SSLConnectionSocketFactory(sslContext,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>hostnameVerifier);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Registry&lt;ConnectionSocketFactory&gt; socketFactoryRegistry = RegistryBuilder.&lt;ConnectionSocketFactory&gt;create()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.register(</code><code>"http"</code><code>, PlainConnectionSocketFactory.getSocketFactory())</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>.register(</code><code>"https"</code><code>, sslConnectionSocketFactory).build();</code><code>// 注册http和https请求</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 开始设置连接池</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>PoolingHttpClientConnectionManager poolingHttpClientConnectionManager =&nbsp;</code><code>new</code>&nbsp;<code>PoolingHttpClientConnectionManager(</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>socketFactoryRegistry);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>poolingHttpClientConnectionManager.setMaxTotal(</code><code>2700</code><code>);&nbsp;</code><code>// 最大连接数2700</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>poolingHttpClientConnectionManager.setDefaultMaxPerRoute(</code><code>100</code><code>);&nbsp;</code><code>// 同路由并发数100</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>httpClientBuilder.setConnectionManager(poolingHttpClientConnectionManager);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>httpClientBuilder.setRetryHandler(</code><code>new</code>&nbsp;<code>DefaultHttpRequestRetryHandler(</code><code>3</code><code>,&nbsp;</code><code>true</code><code>));&nbsp;</code><code>// 重试次数</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HttpClient httpClient = httpClientBuilder.build();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HttpComponentsClientHttpRequestFactory clientHttpRequestFactory =&nbsp;</code><code>new</code>&nbsp;<code>HttpComponentsClientHttpRequestFactory(</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>httpClient);&nbsp;</code><code>// httpClient连接配置</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>clientHttpRequestFactory.setConnectTimeout(</code><code>20000</code><code>);&nbsp;</code><code>// 连接超时</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>clientHttpRequestFactory.setReadTimeout(</code><code>30000</code><code>);&nbsp;</code><code>// 数据读取超时时间</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>clientHttpRequestFactory.setConnectionRequestTimeout(</code><code>20000</code><code>);&nbsp;</code><code>// 连接不够用的等待时间</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>clientHttpRequestFactory;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(KeyManagementException | NoSuchAlgorithmException | KeyStoreException e) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log.error(</code><code>"初始化HTTP连接池出错"</code><code>, e);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>null</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

在对应的插件中配置即可

依赖包：

<groupId>org.apache.httpcomponents</groupId>

<artifactId>httpclient</artifactId>

</dependency>

<groupId>org.apache.httpcomponents</groupId>

<artifactId>httpcore</artifactId>

</dependency>

[https_www.cnblogs.com_jimw_p_9037542.html]: https://www.cnblogs.com/jimw/p/9037542.html
[732794-20180514182635806-596459239.png]: /images/20220422/4edc084f2a624e72b10e45082d7862e2.png
[732794-20180514182256720-1593303995.png]: /images/20220422/954ff4486abb49c1950762ce49577518.png