欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

RestTemplate響應中如何獲取輸入流InputStream

 更新時間:2023年01月11日 10:45:14   作者:SmilingRon  
這篇文章主要介紹了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

RestTemplate整體UML.jpg

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)境的步驟詳解

    這篇文章主要介紹了IntelliJ IDEA基于SpringBoot如何搭建SSM開發(fā)環(huán)境,本文分步驟通過圖文并茂的形式給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2020-10-10
  • SpringBoot如何整合Springsecurity實現(xiàn)數(shù)據(jù)庫登錄及權限控制

    SpringBoot如何整合Springsecurity實現(xiàn)數(shù)據(jù)庫登錄及權限控制

    這篇文章主要給大家介紹了關于SpringBoot如何整合Springsecurity實現(xiàn)數(shù)據(jù)庫登錄及權限控制的相關資料,文中通過圖文以及實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2022-01-01
  • java向數(shù)據(jù)庫插入數(shù)據(jù)顯示亂碼的幾種問題解決

    java向數(shù)據(jù)庫插入數(shù)據(jù)顯示亂碼的幾種問題解決

    這篇文章主要給大家介紹了關于java向數(shù)據(jù)庫插入數(shù)據(jù)顯示亂碼問題的解決方案,文章分別羅列了前臺亂碼的問題、前臺先后臺插入數(shù)據(jù)后臺接收到的數(shù)據(jù)是亂碼以及后臺向數(shù)據(jù)庫插入數(shù)據(jù)是亂碼等幾種情況,需要的朋友可以參考下
    2021-11-11
  • SpringBoot中的@CacheEvict 注解的實現(xiàn)

    SpringBoot中的@CacheEvict 注解的實現(xiàn)

    本文主要介紹了SpringBoot中的@CacheEvict注解的實現(xiàn),@CacheEvict 注解用于清空緩存,文中通過示例代碼介紹的非常詳細,需要的朋友們下面隨著小編來一起學習學習吧
    2024-03-03
  • Spring Boot 常用注解大全

    Spring Boot 常用注解大全

    這篇文章主要介紹了Spring Boot 常用注解大全,需要的朋友可以參考下
    2024-02-02
  • Java源碼解析之LinkedHashMap

    Java源碼解析之LinkedHashMap

    LinkedHashMap是HashMap的子類,所以也具備HashMap的諸多特性.不同的是,LinkedHashMap還維護了一個雙向鏈表,以保證通過Iterator遍歷時順序與插入順序一致.除此之外,它還支持Access Order, ,需要的朋友可以參考下
    2021-05-05
  • java面向?qū)ο?API(接口)與集合(ArrayList)

    java面向?qū)ο?API(接口)與集合(ArrayList)

    這篇文章主要介紹了Java語言面向?qū)ο蟮腁PI與集合,還是十分不錯的,這里給大家分享下,需要的朋友可以參考,希望能夠給你帶來幫助
    2021-08-08
  • java8中parallelStream性能測試及結(jié)果分析

    java8中parallelStream性能測試及結(jié)果分析

    本篇文章給大家用代碼實例做了segmentfaultjava8中parallelStream性能測試,并對測試結(jié)果做了說明,需要的朋友學習下吧。
    2018-01-01
  • 如何通過RabbitMq實現(xiàn)動態(tài)定時任務詳解

    如何通過RabbitMq實現(xiàn)動態(tài)定時任務詳解

    工作中經(jīng)常會有定時任務的需求,常見的做法可以使用Timer、Quartz、Hangfire等組件,這次想嘗試下新的思路,使用RabbitMQ死信隊列的機制來實現(xiàn)定時任務,下面這篇文章主要給大家介紹了關于如何通過RabbitMq實現(xiàn)動態(tài)定時任務的相關資料,需要的朋友可以參考下
    2022-01-01
  • 關于Hibernate的一些學習心得總結(jié)

    關于Hibernate的一些學習心得總結(jié)

    Hibernate是一個優(yōu)秀的Java 持久化層解決方案,是當今主流的對象—關系映射(ORM)工具
    2013-07-07

最新評論