RestTemplate 是Spring提供的用于访问Rest服务的客户端工具,它提供了多种便捷访问远程Http服务的方法,可以大大提升客户端的编写效率。 RestTemplate 相比于他们应该算是一个整合框架,一个能够统一各类请求发送方式的框架。负载均衡
先分析下其相关组件框架
RestTemplate 继承了InterceptingHttpAccessor 实现了RestOperationside
public class RestTemplate extends InterceptingHttpAccessor implements RestOperations {
}
复制代码
定义rest的各类操做, 使用了大量的重载方法。例如,咱们经常使用的工具
getForObject
postForObject
复制代码
HttpAccessor 提供了ClientHttpRequestFactory属性,用于建立ClientHttpRequest。默认初始化SimpleClientHttpRequestFactory工厂类,post
public abstract class HttpAccessor {
private ClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
...
}
复制代码
在发送请求的几种方式上节中咱们说过SimpleClientHttpRequestFactory 是针对JDK原生HttpURLConnection工厂类。也就是说RestTemplate 默认是使用HttpURLConnection来发送http请求。this
不过咱们能够经过set方法设置其余工厂类。换用其余发送http请求的方式。url
public void setRequestFactory(ClientHttpRequestFactory requestFactory) {
super.setRequestFactory(requestFactory);
this.interceptingRequestFactory = null;
}
复制代码
InterceptingHttpAccessor 继承了HttpAccessor。 从其名称,咱们也能够看出这是一个具备拦截器功能的HttpAccessorspa
public abstract class InterceptingHttpAccessor extends HttpAccessor {
private List<ClientHttpRequestInterceptor> interceptors = new ArrayList<ClientHttpRequestInterceptor>();
public void setInterceptors(List<ClientHttpRequestInterceptor> interceptors) {
this.interceptors = interceptors;
}
public List<ClientHttpRequestInterceptor> getInterceptors() {
return interceptors;
}
@Override
public ClientHttpRequestFactory getRequestFactory() {
ClientHttpRequestFactory delegate = super.getRequestFactory();
if (!CollectionUtils.isEmpty(getInterceptors())) {
return new InterceptingClientHttpRequestFactory(delegate, getInterceptors());
}
else {
return delegate;
}
}
}
复制代码
getRequestFactory()方法,经过判断是否具备拦截器,决定是建立具备拦截功能的InterceptingClientHttpRequestFactory ,仍是建立默认的SimpleClientHttpRequestFactoryrest
InterceptingClientHttpRequestFactory 建立的ClientHttpRequest 是InterceptingClientHttpRequest
小结:
RestTemplate 属性也有几个关键组件,咱们应该了解。
Callback interface for code that operates on a ClientHttpRequest. Allows to manipulate the request headers, and write to the request body. 用于操做请求头和body,在请求发出前执行。
解析HTTP响应的数据,从Response中提取数据,经过它来从ClientHttpResponse提取出指定内容(好比请求头、请求Body体等)
用来处理:Path Param 与 Query Param
错误响应处理器
当咱们给Resttenplate设置拦截器时,默认会建立一个InterceptingClientHttpRequest客户端。 当咱们调用InterceptingClientHttpRequest.execute()发送请求时,最终会调用InterceptingClientHttpRequest.executeInternal()方法
@Override
protected final ClientHttpResponse executeInternal(HttpHeaders headers, byte[] bufferedOutput) throws IOException {
//根据拦截器建立一个拦截器链。
InterceptingRequestExecution requestExecution = new InterceptingRequestExecution();
return requestExecution.execute(this, bufferedOutput);
}
复制代码
此时建立一个拦截器执行链,并把当前(this=InterceptingClientHttpRequest) 做为参数传入到执行链中。
咱们看看ClientHttpRequestInterceptor 是如何执行的。 InterceptingRequestExecution#execute() 会首先执行拦截器。
InterceptingRequestExecution类
@Override
public ClientHttpResponse execute(HttpRequest request, byte[] body) {
if (this.iterator.hasNext()) {
ClientHttpRequestInterceptor nextInterceptor = this.iterator.next();
return nextInterceptor.intercept(request, body, this);
}
....
}
复制代码
拦截器执行链中,获取一个拦截器,执行其intercept方法。在每一个intercept方法中都调用execution.execute() 从而造成链式调用。
讲完了组件,下面讲讲执行过程 以getForObject为例
@Override
public <T> T getForObject(String url, Class<T> responseType, Object... urlVariables) throws RestClientException {
RequestCallback requestCallback = acceptHeaderRequestCallback(responseType);
HttpMessageConverterExtractor<T> responseExtractor =
new HttpMessageConverterExtractor<T>(responseType, getMessageConverters(), logger);
return execute(url, HttpMethod.GET, requestCallback, responseExtractor, urlVariables);
}
public <T> T execute(String url, HttpMethod method, RequestCallback requestCallback, ResponseExtractor<T> responseExtractor, Object... urlVariables) throws RestClientException {
URI expanded = getUriTemplateHandler().expand(url, urlVariables);
return doExecute(expanded, method, requestCallback, responseExtractor);
}
复制代码
调用doExecute方法
protected <T> T doExecute(URI url, HttpMethod method, RequestCallback requestCallback, ResponseExtractor<T> responseExtractor) throws RestClientException {
ClientHttpResponse response = null;
try {
//建立一个http请求客户端,根据
ClientHttpRequest request = createRequest(url, method);
if (requestCallback != null) {
//若是requestCallback不为null。则处理request
requestCallback.doWithRequest(request);
}
//执行请求
response = request.execute();
//处理请求,包含错误响应的处理
handleResponse(url, method, response);
//提早指定数据
if (responseExtractor != null) {
return responseExtractor.extractData(response);
}
else {
return null;
}
}
...
finally {
if (response != null) {
response.close();
}
}
}
复制代码
Resttemplate 应该说是对发送请求的方式的一种抽象,他不生产请求,只作请求的整合工。这种高级整合带来的是更加便捷的,更加丰富的发送请求方式。
SpringCloud源码阅读0-SpringCloud必备知识
SpringCloud源码阅读1-EurekaServer源码的秘密
SpringCloud源码阅读3-Ribbon负载均衡(上)
Springcloud源码阅读4-Ribbon负载均衡(下)
欢迎你们关注个人公众号【源码行动】,最新我的理解及时奉送。