RestTemplate響應中如何獲取輸入流InputStream
RestTemplate調(diào)用接口如何獲取輸入流
由于項目需求,需要獲取RestTemplate請求響應的輸入流。如下:
首先需要獲取一個RestTemplate實例:
RestTemplate rest = new RestTemplate();
一般的使用方式如下:
String message = rest.getForObject(url, String.class); // or String message = rest.postForObject(url, paramObject, String.class);
若要獲取InputStream,需要使用到spring提供Resource接口和ResponseEntity類,方式如下:
ResponseEntity<Resource> entity = rest.postForEntity(url, paramObject, Resource.class); InputStream in = entity.getBody().getInputStream();
當然,我們也可以先使用entity對響應做出判斷,比如檢查響應狀態(tài):
if (entity.getStatusCode().equals(HttpStatus.OK)) { ? ? // ... }
SpringRestTemplate解析
RESTful
簡單來說,RESTful是基于Http協(xié)議,面向資源和語義的設計風格。它可以看做是Http協(xié)議的一種嚴格實現(xiàn),基于Http資源(URI)和語義(Get/Post/Put/Delete等)
作為對比,PRC則是面向過程(資源+語義),而對協(xié)議沒有固定要求的設計風格。它的目的是將遠程方法當做本地方法一樣調(diào)用,相比于RESTful的面向資源和語義,它將兩者結(jié)合起來,作為我們平時開發(fā)過程中的方法。
? 比如一個訂單查詢系統(tǒng),用RESTful風格的寫法是這樣的
// 這里查詢用的是Http語義GET,對應的新增為POST,刪除為DELETE,修改為PUT GET /order/123
用PRC風格的寫法是這樣的
/order/queryOrder/123
RPC對比
總結(jié)來看,RESTful和PRC有以下不同。
? 1、RESTful基于Http協(xié)議,而RPC對協(xié)議沒有固定要求,一般會采用效率較高的協(xié)議。
? 2、RESTful面向資源和語義,而RPC面向過程。即RESTful提供的資源表達十分明確,提供了多種語義作為資源的操作方法,例如上面的訂單查詢。RPC則會為同一個資源提供多個操作方法,對外并沒有十分明確的資源概念。
RestTemplate
HttpMessageConverter及序列化
?序列化就是將對象轉(zhuǎn)化為可以傳輸?shù)亩M制,反序列化就是將二進制轉(zhuǎn)化為程序內(nèi)部的對象。序列化/反序列化主要體現(xiàn)在程序I/O這個過程中,包括網(wǎng)絡I/O和磁盤I/O。在網(wǎng)絡中Http報文是以二進制字符串的形式傳遞的,這種是反序列化前的存在形式,我們要在Java中處理,則還需要進行反序列化操作。
我們可以通過HttpServletRequest的getInputStream()方法獲取請求報文的原始內(nèi)容,HttpServletResponse的getOutputStream()方法寫入響應報文,這些方式都是通過流的形式來處理數(shù)據(jù),如果要轉(zhuǎn)化為對象,還需要我們進一步處理。在面向?qū)ο蟮哪J街?,每次都需要讀取流中的原始數(shù)據(jù)并轉(zhuǎn)化為對象,這樣顯然是很麻煩的,如果能將請求和響應都自動封裝為我們想要的對象,那不是很好嘛。HttpMessageConverter提供的就是這樣的功能,將原始的請求報文和響應報文封裝為對象。
public interface HttpMessageConverter<T> { boolean canRead(Class<?> clazz, @Nullable MediaType mediaType); boolean canWrite(Class<?> clazz, @Nullable MediaType mediaType); List<MediaType> getSupportedMediaTypes(); T read(Class<? extends T> clazz, HttpInputMessage inputMessage) throws IOException, HttpMessageNotReadableException; void write(T t, @Nullable MediaType contentType, HttpOutputMessage outputMessage) throws IOException, HttpMessageNotWritableException; }
?HttpMessageConverter中出現(xiàn)了成對的read和write方法。每種Converter負責處理其各自支持的MimeType,can**()方法通過判斷當前Converter和需要處理的MimeType是否一致,如果一致則能處理,否則不能處理。如果能處理,則再通過read/write()方法進行操作,其本質(zhì)上也是通過輸入輸出流處理數(shù)據(jù),我們來看下StringHttpMessageConverter是如何將請求報文轉(zhuǎn)化為String對象的:
// 判斷當前Converter是否支持此類型的轉(zhuǎn)換,只有是String時才會支持 @Override public boolean supports(Class<?> clazz) { return String.class == clazz; } // 從HttpInputMessage讀取輸入流,并轉(zhuǎn)化為String對象 @Override protected String readInternal(Class<? extends String> clazz, HttpInputMessage inputMessage) throws IOException { Charset charset = getContentTypeCharset(inputMessage.getHeaders().getContentType()); return StreamUtils.copyToString(inputMessage.getBody(), charset); } // 從InputStream中讀取原始的報文數(shù)據(jù) public static String copyToString(@Nullable InputStream in, Charset charset) throws IOException { if (in == null) { return ""; } else { StringBuilder out = new StringBuilder(); InputStreamReader reader = new InputStreamReader(in, charset); char[] buffer = new char[4096]; int charsRead; while((charsRead = reader.read(buffer)) != -1) { out.append(buffer, 0, charsRead); } return out.toString(); } }
組件替換
從上面的UML可以看出,RestTemplate中定義了一組Http語義的模板方法,并通過HttpAccessor創(chuàng)建了HttpRequest對象再執(zhí)行請求。也就是說,RestTemplate中并沒有創(chuàng)建請求,請求是委托給HttpAccessor創(chuàng)建的,HttpAccessor可以切換請求工廠,這樣就給我們提供了切換請求,即Http組件的操作。
通過HttpAccessor的ClientHttpRequestFactory屬性來切換不同的HTTP組件:HttpAccessor默認使用SimpleClientHttpRequestFactory來創(chuàng)建一個ClientHttpRequest,如果通過HttpAccessor提供的setRequestFactory()方法替換掉其默認的工廠,就可以實現(xiàn)HTTP組件切換。RestTemplate提供了以ClientHttpRequestFactory為參數(shù)的構造方法,其內(nèi)部調(diào)用了setRequestFactory()。
通過看ClientHttpRequestFactory的實現(xiàn)類,可以發(fā)現(xiàn)常見的Http組件有HttpComponents、OkHttp、Netty4Client等,在這里不做深入探究。
?總結(jié)
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
IntelliJ IDEA基于SpringBoot如何搭建SSM開發(fā)環(huán)境的步驟詳解
這篇文章主要介紹了IntelliJ IDEA基于SpringBoot如何搭建SSM開發(fā)環(huán)境,本文分步驟通過圖文并茂的形式給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-10-10SpringBoot如何整合Springsecurity實現(xiàn)數(shù)據(jù)庫登錄及權限控制
這篇文章主要給大家介紹了關于SpringBoot如何整合Springsecurity實現(xiàn)數(shù)據(jù)庫登錄及權限控制的相關資料,文中通過圖文以及實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2022-01-01java向數(shù)據(jù)庫插入數(shù)據(jù)顯示亂碼的幾種問題解決
這篇文章主要給大家介紹了關于java向數(shù)據(jù)庫插入數(shù)據(jù)顯示亂碼問題的解決方案,文章分別羅列了前臺亂碼的問題、前臺先后臺插入數(shù)據(jù)后臺接收到的數(shù)據(jù)是亂碼以及后臺向數(shù)據(jù)庫插入數(shù)據(jù)是亂碼等幾種情況,需要的朋友可以參考下2021-11-11SpringBoot中的@CacheEvict 注解的實現(xiàn)
本文主要介紹了SpringBoot中的@CacheEvict注解的實現(xiàn),@CacheEvict 注解用于清空緩存,文中通過示例代碼介紹的非常詳細,需要的朋友們下面隨著小編來一起學習學習吧2024-03-03java面向?qū)ο?API(接口)與集合(ArrayList)
這篇文章主要介紹了Java語言面向?qū)ο蟮腁PI與集合,還是十分不錯的,這里給大家分享下,需要的朋友可以參考,希望能夠給你帶來幫助2021-08-08java8中parallelStream性能測試及結(jié)果分析
本篇文章給大家用代碼實例做了segmentfaultjava8中parallelStream性能測試,并對測試結(jié)果做了說明,需要的朋友學習下吧。2018-01-01如何通過RabbitMq實現(xiàn)動態(tài)定時任務詳解
工作中經(jīng)常會有定時任務的需求,常見的做法可以使用Timer、Quartz、Hangfire等組件,這次想嘗試下新的思路,使用RabbitMQ死信隊列的機制來實現(xiàn)定時任務,下面這篇文章主要給大家介紹了關于如何通過RabbitMq實現(xiàn)動態(tài)定時任務的相關資料,需要的朋友可以參考下2022-01-01