Springboot-RestTemplate调用服务实战记录

Posted Merrizee

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Springboot-RestTemplate调用服务实战记录相关的知识,希望对你有一定的参考价值。

springboot内自带的resttemplate可以帮助我们实现远程调用其他服务接口的作用,实际封装了httpclient,将httpclient繁琐的

配置用springboot特有的配置类来配置,并交给sprinng管理.

避免在一个项目中频繁创建httpclient对象,造成的堆内存浪费,确保连接对象的单例性.

优点:配置简单,请求参数灵活.

缺点:报错需要try-catch手动捕获,不看日志不容易发现问题.没有熔断器,可以根据熔断器状态返回指定错误码,及时发现.

配置类RestTemplateConfig:

@Configuration
public class RestTemplateConfig {

@Bean
public RestTemplate httpRestTemplate() {
ClientHttpRequestFactory factory = httpRequestFactory();
RestTemplate restTemplate = new RestTemplate(factory);
// 可以添加消息转换
//restTemplate.setMessageConverters(...);
// 可以增加拦截器
//restTemplate.setInterceptors(...);
return restTemplate;
}

public ClientHttpRequestFactory httpRequestFactory() {
return new HttpComponentsClientHttpRequestFactory(restTemplateConfigHttpClient());
}

public HttpClient restTemplateConfigHttpClient() {
Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
.register("http", PlainConnectionSocketFactory.getSocketFactory())
.register("https", SSLConnectionSocketFactory.getSocketFactory())
.build();
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);
// 设置整个连接池最大连接数 根据自己的场景决定
connectionManager.setMaxTotal(200);
// 路由是对maxTotal的细分
connectionManager.setDefaultMaxPerRoute(100);
RequestConfig requestConfig = RequestConfig.custom()
// 服务器返回数据(response)的时间,超过该时间抛出read timeout
.setSocketTimeout(10000)
// 连接上服务器(握手成功)的时间,超出该时间抛出connect timeout
.setConnectTimeout(5000)
// 从连接池中获取连接的超时时间,超过该时间未拿到可用连接,
// 会抛出org.apache.http.conn.ConnectionPoolTimeoutException:
// Timeout waiting for connection from pool
.setConnectionRequestTimeout(5000)
.build();
return HttpClientBuilder.create()
.setDefaultRequestConfig(requestConfig)
.setConnectionManager(connectionManager)
.build();
}
}
注入:
@Autowired
RestTemplateConfig restTemplateConfig;

发请求:

 

RestTemplate httpRestTemplate = restTemplateConfig.httpRestTemplate();
try {
List<Integer> requestBean = new ArrayList<>();
result.stream().map(a -> {
requestBean.add(a.getId());
return a;
}).collect(Collectors.toList());
Map map = httpRestTemplate.postForObject(服务url, requestBean, Map.class);
result = result.stream().map(a -> {
Iterator iterator = map.keySet().iterator();
while (iterator.hasNext()) {
String key = (String) iterator.next();
Object obj = map.get(key);
if (String.valueOf(a.getId()).equals(key)) {
Integer i = (Integer) obj;
a.setCourseCount(i);
return a;
}
}
return a;
}).collect(Collectors.toList());
} catch (Exception e) {
System.err.println("调用服务:" + metel2ApiUrl + "查询课程数量异常");
e.printStackTrace();
}
return result;

 

以上是关于Springboot-RestTemplate调用服务实战记录的主要内容,如果未能解决你的问题,请参考以下文章

Java中方法调用总结

系统调用与函数调用

java三种调用方式(同步调用/回调/异步调用)

LINUX系统调用

引用调用 vs 复制调用调用

RPC 调用和 HTTP 调用的区别