详解如何使用详解如何使用Jersey客户端请求客户端请求Spring Boot(RESTFul)服务服务
本篇文章主要介绍了详解如何使用Jersey客户端请求Spring Boot(RESTFul)服务,小编觉得挺不错的,现在分享给大家,也给大
家做个参考。一起跟随小编过来看看吧
本文介绍了使用Jersey客户端请求Spring Boot(RESTFul)服务,分享给大家,具体如下:
Jersey客户端获取Client对象实例封装:
@Service("jerseyPoolingClient")
public class JerseyPoolingClientFactoryBean implements FactoryBean<Client>, InitializingBean, DisposableBean{
/**
* Client接口是REST客户端的基本接口,用于和REST服务器通信。Client被定义为一个重量级的对象,其内部管理着
* 客户端通信底层的各种对象,比如连接器,解析器等。因此,不推荐在应用中产生大量的的Client实例,这一点在开发中
* 需要特别小心,另外该接口要求其实例要有关闭连接的保障,否则会造成内存泄露
*/
private Client client;
/**
* 一个Client最大的连接数,默认为2000
*/
private int maxTotal = 2000;
/**
* 每路由的默认最大连接数
*/
private int defaultMaxPerRoute = 1000;
private ClientConfig clientConfig;
public JerseyPoolingClientFactoryBean() {
}
/**
* 带配置的构造函数
* @param clientConfig
*/
public JerseyPoolingClientFactoryBean(ClientConfig clientConfig) {
this.clientConfig = clientConfig;
}
public JerseyPoolingClientFactoryBean(int maxTotal, int defaultMaxPerRoute) {
this.maxTotal = maxTotal;
this.defaultMaxPerRoute = defaultMaxPerRoute;
}
/**
* attention:
* Details:容器销毁时,释放Client资源
* @author chhliu
*/
@Override
public void destroy() throws Exception {
this.client.close();
}
/**
*
* attention:
* Details:以连接池的形式,来初始化Client对象
* @author chhliu
*/
@Override
public void afterPropertiesSet() throws Exception {
// 如果没有使用带ClientConfig的构造函数,则该类的实例为null,则使用默认的配置初始化
if(this.clientConfig == null){
final ClientConfig clientConfig = new ClientConfig();
// 连接池管理实例,该类是线程安全的,支持多并发操作
PoolingHttpClientConnectionManager pcm = new PoolingHttpClientConnectionManager();
pcm.setMaxTotal(this.maxTotal);
pcm.setDefaultMaxPerRoute(this.defaultMaxPerRoute);
clientConfig.property(ApacheClientProperties.CONNECTION_MANAGER, pcm);
/*
* 在使用Jersey来请求Spring Boot服务时,Spring Boot默认使用Jackson来解析JSON
* 而Jersey默认使用MOXy解析JSON,当Jersey Client想Spring Boot服务请求资源时,
* 这个差异会导致服务端和客户端对POJO的转换不同,造成反序列化的错误
* 因此,此处需要在Client的Config实例中注册Jackson特性
*/
clientConfig.register(JacksonFeature.class);
// 使用配置Apache连接器,默认连接器为HttpUrlConnector
clientConfig.connectorProvider(new ApacheConnectorProvider());
client = ClientBuilder.newClient(clientConfig);
}else{
// 使用构造函数中的ClientConfig来初始化Client对象
client = ClientBuilder.newClient(this.clientConfig);
}
}