RestTemplate是什么?
傳統情況下在java代碼里訪問restful服務,一般使用Apache的HttpClient。不過此種方法使用起來太過繁瑣。spring提供了一種簡單便捷的模板類來進行操作,這就是RestTemplate。
它簡化了與http服務的通信方式,統一了restful的標准,封裝了http鏈接, 我們只需要傳入url及返回值類型即可。
RestTemplate默認依賴JDK提供http連接的能力(HttpURLConnection),如果有需要的話也可以通過setRequestFactory方法替換為例如 Apache HttpComponents、Netty或OkHttp等其它HTTP library。
考慮到RestTemplate類是為調用REST服務而設計的,因此它的主要方法與REST的基礎緊密相連就不足為奇了,后者是HTTP協議的方法:HEAD、GET、POST、PUT、DELETE和OPTIONS。例如,RestTemplate類具有headForHeaders()、getForObject()、postForObject()、put()和delete()等方法。
RestTemplate用來干什么?
RestTemplate能大幅簡化了提交表單數據的難度,並且附帶了自動轉換JSON數據的功能,但只有理解了HttpEntity的組成結構(header與body),且理解了與uriVariables之間的差異,才能真正掌握其用法。
該類的入口主要是根據HTTP的六個方法制定:
exchange和excute可以通用上述方法
1.幾個簡單的例子
1.1postForObject請求restful接口(查看該博客 RESTful接口詳解 可詳細了解什么是restful接口)
1 @RestController 2 public class TestController 3 { 4 @RequestMapping(value = "testPost", method = RequestMethod.POST) 5 public ResponseBean testPost(@RequestBody RequestBean requestBean) 6 { 7 ResponseBean responseBean = new ResponseBean(); 8 responseBean.setRetCode("0000"); 9 responseBean.setRetMsg("succ"); 10 11 return responseBean; 12 } 13 }
使用RestTemplate訪問該服務
1 //請求地址 2 String url = "http://localhost:8080/testPost"; 3 //入參 4 RequestBean requestBean = new RequestBean(); 5 requestBean.setTest1("1"); 6 requestBean.setTest2("2"); 7 requestBean.setTest3("3"); 8 9 RestTemplate restTemplate = new RestTemplate(); 10 ResponseBean responseBean = restTemplate.postForObject(url, requestBean, ResponseBean.class);
從這個例子可以看出,使用restTemplate訪問restful接口非常的簡單粗暴無腦。(url, requestMap, ResponseBean.class)這三個參數分別代表 請求地址、請求參數、HTTP響應轉換被轉換成的對象類型。
RestTemplate方法的名稱遵循命名約定,第一部分指出正在調用什么HTTP方法,第二部分指示返回的內容。本例中調用了restTemplate.postForObject方法,post指調用了HTTP的post方法,Object指將HTTP響應轉換為您選擇的對象類型。還有其他很多類似的方法,有興趣的同學可以參考官方api。
1.2exchange指定調用方式
exchange()方法跟上面的getForObject()、getForEntity()、postForObject()、postForEntity()等方法不同之處在於它可以指定請求的HTTP類型。
1 public void rtExchangeTest() throws JSONException { 2 RestTemplate restTemplate = new RestTemplate(); 3 String url = "http://xxx.top/notice/list"; 4 HttpHeaders headers = new HttpHeaders(); 5 headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED); 6 JSONObject jsonObj = new JSONObject(); 7 jsonObj.put("start",1); 8 jsonObj.put("page",5); 9 10 HttpEntity<String> entity = new HttpEntity<>(jsonObj.toString(), headers); 11 ResponseEntity<JSONObject> exchange = restTemplate.exchange(url,HttpMethod.GET, entity, JSONObject.class); 12 System.out.println(exchange.getBody()); 13 }
1.3excute()指定調用方式
excute()的用法與exchange()大同小異了,它同樣可以指定不同的HttpMethod,不同的是它返回的對象是響應體所映射成的對象,而不是ResponseEntity。此處就不做代碼展示了。
需要強調的是,execute()方法是以上所有方法的底層調用。比如postForObject:
1 @Override 2 @Nullable 3 public <T> T postForObject(String url, @Nullable Object request, Class<T> responseType, Map<String, ?> uriVariables) 4 throws RestClientException { 5 6 RequestCallback requestCallback = httpEntityCallback(request, responseType); 7 HttpMessageConverterExtractor<T> responseExtractor = 8 new HttpMessageConverterExtractor<>(responseType, getMessageConverters(), logger); 9 return execute(url, HttpMethod.POST, requestCallback, responseExtractor, uriVariables); 10 }
2.手動指定轉換器(HttpMessageConverter)
我們知道,調用reseful接口傳遞的數據內容是json格式的字符串,返回的響應也是json格式的字符串。然而restTemplate.postForObject方法的請求參數RequestBean和返回參數ResponseBean卻都是java類。是RestTemplate通過HttpMessageConverter自動幫我們做了轉換的操作。
默認情況下RestTemplate自動幫我們注冊了一組HttpMessageConverter用來處理一些不同的contentType的請求。
如StringHttpMessageConverter來處理text/plain;MappingJackson2HttpMessageConverter來處理application/json;MappingJackson2XmlHttpMessageConverter來處理application/xml。
你可以在org.springframework.http.converter包下找到所有spring幫我們實現好的轉換器。
如果現有的轉換器不能滿足你的需求,你還可以實現org.springframework.http.converter.HttpMessageConverter接口自己寫一個。詳情參考官方api。
選好了HttpMessageConverter后怎么把它注冊到我們的RestTemplate中呢。以下這個例子展示了如何使用GsonHttpMessageConverter替換掉默認用來處理application/json的MappingJackson2HttpMessageConverter。
1 RestTemplate restTemplate = new RestTemplate(); 2 //獲取RestTemplate默認配置好的所有轉換器 3 List<HttpMessageConverter<?>> messageConverters = restTemplate.getMessageConverters(); 4 //默認的MappingJackson2HttpMessageConverter在第7個 先把它移除掉 5 messageConverters.remove(6); 6 //添加上GSON的轉換器 7 messageConverters.add(6, new GsonHttpMessageConverter());
3.設置底層連接方式
要創建一個RestTemplate的實例,您可以像上述例子中簡單地調用默認的無參數構造函數。這將使用java.net包中的標准Java類作為底層實現來創建HTTP請求。
但很多時候我們需要像傳統的HttpClient那樣設置HTTP請求的一些屬性。RestTemplate使用了一種很偷懶的方式實現了這個需求,那就是直接使用一個HttpClient作為底層實現......
1 //生成一個設置了連接超時時間、請求超時時間、異常最大重試次數的httpClient 2 RequestConfig config = RequestConfig.custom().setConnectionRequestTimeout(10000).setConnectTimeout(10000).setSocketTimeout(30000).build(); 3 HttpClientBuilder builder = HttpClientBuilder.create().setDefaultRequestConfig(config).setRetryHandler(new DefaultHttpRequestRetryHandler(5, false)); 4 HttpClient httpClient = builder.build(); 5 //使用httpClient創建一個ClientHttpRequestFactory的實現 6 ClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory(httpClient); 7 //ClientHttpRequestFactory作為參數構造一個使用作為底層的RestTemplate 8 RestTemplate restTemplate = new RestTemplate(requestFactory);
4.設置攔截器
需要對請求做一些通用的攔截設置,這就可以使用攔截器進行處理。攔截器需要我們實現org.springframework.http.client.ClientHttpRequestInterceptor接口自己寫。
舉個簡單的例子,寫一個在header中根據請求內容和地址添加令牌的攔截器。
public class TokenInterceptor implements ClientHttpRequestInterceptor { @Override public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException { //請求地址 String checkTokenUrl = request.getURI().getPath(); //token有效時間 int ttTime = (int) (System.currentTimeMillis() / 1000 + 1800); //請求方法名 POST、GET等 String methodName = request.getMethod().name(); //請求內容 String requestBody = new String(body); //生成令牌 此處調用一個自己寫的方法,有興趣的朋友可以自行google如何使用ak/sk生成token,此方法跟本教程無關,就不貼出來了 String token = TokenHelper.generateToken(checkTokenUrl, ttTime, methodName, requestBody); //將令牌放入請求header中 request.getHeaders().add("X-Auth-Token",token); return execution.execute(request, body); } }
創建RestTemplate實例的時候可以這樣向其中添加攔截器
1 RestTemplate restTemplate = new RestTemplate(); 2 //向restTemplate中添加自定義的 攔截器 3 restTemplate.getInterceptors().add(new TokenInterceptor());