参考

0. 原因

我调用第三方接口时，第三方接口抛出异常！restTemplate 接收到异常之后
启用了自己的异常处理！
导致了第三方抛出的错误信息被覆盖，调用方不能准确的获取错误消息提示

1. 直接new

  1.  private static RestTemplate restTemplate = new RestTemplate();
  4.   // 错误处理
  5.   restTemplate.setErrorHandler(new NoErrorResultErrorHandler());
  6.   Map<String,Object> respMap = restTemplate.exchange(url, HttpMethod.POST, requestEntity, Map.class).getBody();

2. 如果使用配置类

  1. package com.cr.code.eco.ecoapi.config;
  3. import org.apache.http.client.HttpClient;
  4. import org.apache.http.impl.client.DefaultConnectionKeepAliveStrategy;
  5. import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
  6. import org.apache.http.impl.client.HttpClientBuilder;
  7. import org.apache.http.impl.client.HttpClients;
  8. import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
  9. import org.springframework.context.annotation.Configuration;
  10. import org.springframework.http.HttpStatus;
  11. import org.springframework.http.client.ClientHttpResponse;
  12. import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
  13. import org.springframework.web.client.DefaultResponseErrorHandler;
  14. import org.springframework.web.client.RestTemplate;
  16. import java.io.IOException;
  17. import java.util.concurrent.TimeUnit;
  19. /**
  20.  *
  21.  * 解决RestTemplate 中高并发情况下Socket InteAddress 用尽
  22.  * @参考： https://blog.csdn.net/qq_27217017/article/details/98601893
  23.  *
  24.  * @author tn
  25.  * @version 1
  26.  * @ClassName RestTemplateConfig
  27.  * @description RestTemplate跟换底层
  28.  *      高频且短的大量Request请求，控制 Request的请求量，不会跑出IntAddress use out的异常
  29.  *
  30.  * @date 2020/7/26 3:01
  31.  */
  32. public class RestTemplateConfig {
  33.     private static RestTemplate restTemplate;
  35.     static {
  36.         // 长链接保持时间长度20秒
  37.         PoolingHttpClientConnectionManager poolingHttpClientConnectionManager =
  38.                 new PoolingHttpClientConnectionManager(20, TimeUnit.SECONDS);
  39.         // 设置最大链接数
  40.         poolingHttpClientConnectionManager.setMaxTotal(2*getMaxCpuCore() + 3 );
  41.         // 单路由的并发数
  42.         poolingHttpClientConnectionManager.setDefaultMaxPerRoute(2*getMaxCpuCore());
  44.         HttpClientBuilder httpClientBuilder = HttpClients.custom();
  45.         httpClientBuilder.setConnectionManager(poolingHttpClientConnectionManager);
  47.         // 重试次数3次，并开启
  48.         httpClientBuilder.setRetryHandler(new DefaultHttpRequestRetryHandler(3,true));
  49.         HttpClient httpClient = httpClientBuilder.build();
  50.         // 保持长链接配置，keep-alive
  51.         httpClientBuilder.setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy());
  53.         HttpComponentsClientHttpRequestFactory httpComponentsClientHttpRequestFactory = new HttpComponentsClientHttpRequestFactory(httpClient);
  55.         // 链接超时配置 5秒
  56.         httpComponentsClientHttpRequestFactory.setConnectTimeout(5000);
  57.         // 连接读取超时配置
  58. //        httpComponentsClientHttpRequestFactory.setReadTimeout(10000);
  59.         // 连接池不够用时候等待时间长度设置，分词那边 500毫秒 ，我们这边设置成1秒
  60.         httpComponentsClientHttpRequestFactory.setConnectionRequestTimeout(3000);
  62.         // 缓冲请求数据，POST大量数据，可以设定为true 我们这边机器比较内存较大
  63.         httpComponentsClientHttpRequestFactory.setBufferRequestBody(true);
  65.         restTemplate = new RestTemplate();
  66.         restTemplate.setRequestFactory(httpComponentsClientHttpRequestFactory);
  68.         //注意：如果不重写  handleError http抛出的异常会直接转发给前端项目中就获取不了接口返回值了
  69.         restTemplate.setErrorHandler(new DefaultResponseErrorHandler(){
  70.             @Override
  71.             public void handleError(ClientHttpResponse response) throws IOException {
  72.                 if(response.getStatusCode() == HttpStatus.OK){
  73.                     super.handleError(response);
  74.                 }
  75.             }
  76.         });
  77.     }
  79.     public static RestTemplate getRestTemplate(){
  80.         return restTemplate;
  81.     }
  83.     private static int getMaxCpuCore(){
  84.         int cpuCore = Runtime.getRuntime().availableProcessors();
  85.         return  cpuCore;
  86.     }
  87. }

使用：

  1. /**
  2. * http调用
  3. */
  4. private RestTemplate restTemplate = RestTemplateConfig.getRestTemplate();
  6.    /**
  7.      * @return
  8.      */
  9.     private List<EnvironmentDetectionResponseVo> test(){
  11.         String body = restTemplate.getForEntity("http://url",String.class).getBody();
  12.         JSONArray jsonArray = JSON.parseArray(body);
  13.         EnvironmentDetectionResponseVo[] EnvironmentDetectionResponseVo = jsonArray.toJavaObject(EnvironmentDetectionResponseVo[].class);
  14.         return Arrays.asList(EnvironmentDetectionResponseVo);
  15.     }

3. 现象

3.1 不处理他的默认异常

image.png

3.2处理之后

image.png