發送http請求(2):RestTemplate發送http請求

關聯閱讀：

發送http請求(1):發送http請求的幾種方式

相關組件

RestTemplate 是Spring提供的用於訪問Rest服務的客戶端工具，它提供了多種便捷訪問遠程Http服務的方法，可以大大提升客戶端的編寫效率。 RestTemplate 相比於他們應該算是一個整合框架，一個能夠統一各類請求發送方式的框架。

先分析下其相關組件

繼承體系

RestTemplate 繼承了InterceptingHttpAccessor 實現了RestOperations

public class RestTemplate extends InterceptingHttpAccessor implements RestOperations {
}
複製代碼

RestOperations

定義rest的各類操做, 使用了大量的重載方法。例如，咱們經常使用的

getForObject
postForObject
複製代碼

HttpAccessor

HttpAccessor 提供了ClientHttpRequestFactory屬性，用於建立ClientHttpRequest。默認初始化SimpleClientHttpRequestFactory工廠類，

public abstract class HttpAccessor {
private ClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
...
}
複製代碼

在發送請求的幾種方式上節中咱們說過SimpleClientHttpRequestFactory 是針對JDK原生HttpURLConnection工廠類。也就是說RestTemplate 默認是使用HttpURLConnection來發送http請求。

不過咱們能夠經過set方法設置其餘工廠類。換用其餘發送http請求的方式。

public void setRequestFactory(ClientHttpRequestFactory requestFactory) {
        super.setRequestFactory(requestFactory);
        this.interceptingRequestFactory = null;
}
複製代碼

InterceptingHttpAccessor

InterceptingHttpAccessor 繼承了HttpAccessor。 從其名稱，咱們也能夠看出這是一個具備攔截器功能的HttpAccessor

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 ，仍是建立默認的SimpleClientHttpRequestFactory

InterceptingClientHttpRequestFactory 建立的ClientHttpRequest 是InterceptingClientHttpRequest

小結：

• HttpAccessor： 提供對普通Http客戶端 ClientHttpRequest的支持
• InterceptingHttpAccessor： 提供對具備攔截功能的ClientHttpRequest的支持

屬性體系

RestTemplate 屬性也有幾個關鍵組件，咱們應該瞭解。

RequestCallback

Callback interface for code that operates on a ClientHttpRequest. Allows to manipulate the request headers, and write to the request body. 用於操做請求頭和body，在請求發出前執行。

ResponseExtractor

解析HTTP響應的數據，從Response中提取數據，經過它來從ClientHttpResponse提取出指定內容（好比請求頭、請求Body體等）

UriTemplateHandler

用來處理：Path Param 與 Query Param

ResponseErrorHandler

錯誤響應處理器

關聯組件

InterceptingRequestExecution

當咱們給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

咱們看看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();
			}
		}
	}
複製代碼

1. 首先獲取到RequestCallback ,ResponseExtractor 工具。並調用UriTemplateHandler處理url中的參數問題
2. 從HttpAccessor獲取一個ClientHttpRequest，若是配置了ClientHttpRequestInterceptor，則經過InterceptingClientHttpRequestFactory建立具備攔截器功能的InterceptingClientHttpRequest客戶端。若是沒有使用普通的ClientHttpRequestFactory建立一個普通客戶端，默認使用的是SimpleClientHttpRequestFactory 建立HttpURLConnection 的客戶端
3. 獲得ClientHttpRequest後，若是RequestCallback不爲null。則執行RequestCallback
4. 執行ClientHttpRequest.execute(). 若是此時有ClientHttpRequestInterceptor，則先執行ClientHttpRequestInterceptor，再發送請求。
5. ResponseErrorHandler 處理可能的錯誤響應
6. 若是存在responseExtractor響應提取器， 則調用responseExtractor 提取response數據。
7. 數據返回

總結

Resttemplate 應該說是對發送請求的方式的一種抽象，他不生產請求，只作請求的整合工。這種高級整合帶來的是更加便捷的，更加豐富的發送請求方式。

推薦閱讀：

SpringCloud源碼閱讀0-SpringCloud必備知識

SpringCloud源碼閱讀1-EurekaServer源碼的祕密

SpringCloud源碼閱讀2-Eureka客戶端的祕密

SpringCloud源碼閱讀3-Ribbon負載均衡(上)

Springcloud源碼閱讀4-Ribbon負載均衡(下)

歡迎你們關注個人公衆號【源碼行動】，最新我的理解及時奉送。