WebClient拋UnsupportedMediaTypeException異常解決
前言
前面分享了Spring5中的WebClient使用方法詳解 后，就有朋友在segmentfault上給博主提了一個(gè)付費(fèi)的問(wèn)題，這個(gè)是博主在segmentfault平臺(tái)上面收到的首個(gè)付費(fèi)問(wèn)答，雖然酬勞不多，只有十元，用群友的話說(shuō)性價(jià)比太低了。但在解決問(wèn)題過(guò)程中對(duì)WebClient有了更深入的了解卻是另一種收獲。解決這個(gè)問(wèn)題博主做了非常詳細(xì)的排查和解決，現(xiàn)將過(guò)程記錄在此，供有需要的朋友參考。
問(wèn)題背景
使用WebClient請(qǐng)求一個(gè)接口，使用bodyToMono方法用一個(gè)Entity接收響應(yīng)的內(nèi)容，偽代碼如下：
IdExocrResp resp = WebClient.create()
.post()
.uri("https://id.exocr.com:8080/bankcard")
.body(BodyInserters.fromFormData(formData))
.retrieve()
.bodyToMono(IdExocrResp.class)
.block();上面的代碼在運(yùn)行時(shí)會(huì)拋一個(gè)異常，異常如下：
Exception in thread "main" org.springframework.web.reactive.function.UnsupportedMediaTypeException: Content type 'application/octet-stream' not supported for bodyType=IdExocrResp at org.springframework.web.reactive.function.BodyExtractors.lambda$readWithMessageReaders$12(BodyExtractors.java:201) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s):
直譯過(guò)來(lái)大概的意思就是，不支持application/octet-stream類型的Content Type。
問(wèn)題分析
如上異常，拋異常的代碼在BodyExtractors的201行，根據(jù)異常堆棧信息找到對(duì)應(yīng)的代碼分析：
private static S readWithMessageReaders(
ReactiveHttpInputMessage message, BodyExtractor.Context context, ResolvableType elementType,
Function readerFunction,
Function errorFunction,
Supplier emptySupplier) {
if (VOID_TYPE.equals(elementType)) {
return emptySupplier.get();
}
MediaType contentType = Optional.ofNullable(message.getHeaders().getContentType())
.orElse(MediaType.APPLICATION_OCTET_STREAM);
return context.messageReaders().stream()
.filter(reader -> reader.canRead(elementType, contentType))
.findFirst()
.map(BodyExtractors::cast)
.map(readerFunction)
.orElseGet(() -> {
ListmediaTypes = context.messageReaders().stream()
.flatMap(reader -> reader.getReadableMediaTypes().stream())
.collect(Collectors.toList());
return errorFunction.apply(
new UnsupportedMediaTypeException(contentType, mediaTypes, elementType));
});
}可以看到，在這個(gè)body提取器類中，有一個(gè)默認(rèn)的contentType 策略，如果server端沒(méi)有返回contentType ，默認(rèn)就使用APPLICATION_OCTET_STREAM來(lái)接收數(shù)據(jù)。問(wèn)題正是這里導(dǎo)致的。因?yàn)樵谶@個(gè)接口的響應(yīng)header里，contentType 為null，其實(shí)正確的應(yīng)該是application/json，只是服務(wù)器沒(méi)指定，然后被默認(rèn)策略設(shè)置為application/octet-stream后，在默認(rèn)的JSON解碼器里是不支持，導(dǎo)致拋出了不支持的MediaType異常。定位到真實(shí)原因后，博主給出了如下方案
解決方案
方案一
如果服務(wù)端是自己的服務(wù)，可以修改服務(wù)端的程序指定ContentType為application/json類型返回即可。如果是第三方的服務(wù)，沒(méi)法改動(dòng)server端請(qǐng)參考下面的方案
方案二
使用String接收后，然后在flatMap里在過(guò)濾自己解碼一遍，String類型可以接收application/octet-stream類型的Content Type的，代碼如：
IdExocrResp resp = WebClient.create()
.post()
.uri("xxx")
.body(BodyInserters.fromFormData(formData))
.retrieve()
.bodyToMono(String.class)
.flatMap(str -> Mono.just(JSON.parseObject(str, IdExocrResp.class)))
.block();方案三
因?yàn)轫憫?yīng)的值確實(shí)是json，只是在響應(yīng)的header里沒(méi)有指定Content Type為application/json。而最終異常也是因?yàn)閖son解碼器不支持導(dǎo)致的，所以我們可以定制json解碼器，重寫(xiě)支持的MediaType校驗(yàn)規(guī)則
自定義解碼器
/**
* @author: kl @kailing.pub
* @date: 2019/12/3
*/
public class CustomJacksonDecoder extends AbstractJackson2Decoder {
public CustomJacksonDecoder() {
super(Jackson2ObjectMapperBuilder.json().build());
}
/**
* 添加 MediaType.APPLICATION_OCTET_STREAM 類型的支持
* @param mimeType
* @return
*/
@Override
protected boolean supportsMimeType(MimeType mimeType) {
return (mimeType == null
|| mimeType.equals(MediaType.APPLICATION_OCTET_STREAM)
|| super.getDecodableMimeTypes().stream().anyMatch(m -> m.isCompatibleWith(mimeType)));
}
}設(shè)置解碼器
ExchangeStrategies strategies = ExchangeStrategies.builder()
.codecs(configurer -> configurer.customCodecs().decoder(new CustomJacksonDecoder()))
.build();
MultiValueMap formData = new LinkedMultiValueMap<>();
IdExocrResp resp = WebClient.builder()
.exchangeStrategies(strategies)
.build()
.post()
.uri("https://id.exocr.com:8080/bankcard")
.body(BodyInserters.fromFormData(formData))
.retrieve()
.bodyToMono(IdExocrResp.class)
.block();方案四
因?yàn)轫憫?yīng)的DefaultClientResponse里沒(méi)有Content-Type，所以可以使用exchange()拿到clientResponse后重新build一個(gè)ClientResponse，然后設(shè)置Content-Type為application/json即可解決問(wèn)題，代碼如：
MultiValueMap formData = new LinkedMultiValueMap<>();
IdExocrResp resp = WebClient.create()
.post()
.uri("https://id.exocr.com:8080/bankcard")
.body(BodyInserters.fromFormData(formData))
.exchange()
.flatMap(res -> ClientResponse.from(res)
.header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.body(res.body(BodyExtractors.toDataBuffers()))
.build()
.bodyToMono(IdExocrResp.class))
.block();方案五
同方案四的思路，重新構(gòu)造一個(gè)帶Content-Type為application/json的clientResponse，但是處理邏輯是在filter里，就不需要使用exchange()了，博主以為這種方式最簡(jiǎn)潔優(yōu)雅，代碼如：
MultiValueMap formData = new LinkedMultiValueMap<>();
IdExocrResp resp = WebClient.builder()
.filter((request, next) ->
next.exchange(request).map(response -> {
Fluxbody = response.body(BodyExtractors.toDataBuffers());
return ClientResponse.from(response)
.header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.body(body)
.build();
}))
.build()
.post()
.uri("https://id.exocr.com:8080/bankcard")
.body(BodyInserters.fromFormData(formData))
.retrieve()
.bodyToMono(IdExocrResp.class)
.block();方案六
前面原因分析的時(shí)候已經(jīng)說(shuō)了，MediaType為空時(shí)spring默認(rèn)設(shè)置為application/octet-stream了。這里的設(shè)計(jì)其實(shí)可以更靈活點(diǎn)的，比如除了默認(rèn)的策略外，還可以讓用戶自由的設(shè)置默認(rèn)的Content Type類型。這個(gè)就涉及到改動(dòng)Spring的框架代碼了，博主已經(jīng)把這個(gè)改動(dòng)提交到Spring的官方倉(cāng)庫(kù)了，如果合并了的話，就可以在下個(gè)版本使用這個(gè)方案解決問(wèn)題了
pr地址：https://github.com/spring-projects/spring-framework/pull/24120
以上就是WebClient拋UnsupportedMediaTypeException異常解決的詳細(xì)內(nèi)容，更多關(guān)于WebClient拋UnsupportedMediaTypeException的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
SpringBoot中的多RabbitMQ數(shù)據(jù)源配置實(shí)現(xiàn)
本篇博客將介紹如何在 Spring Boot 中配置和管理多個(gè) RabbitMQ 數(shù)據(jù)源,以滿足不同的應(yīng)用需求,具有一定的參考價(jià)值,感興趣的可以了解一下2023-09-09
SpringBoot使用Redisson實(shí)現(xiàn)延遲執(zhí)行的完整示例
這篇文章主要介紹了SpringBoot使用Redisson實(shí)現(xiàn)延遲執(zhí)行的完整示例,文中通過(guò)代碼示例講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2024-06-06
Java實(shí)現(xiàn)PNG圖片格式轉(zhuǎn)BMP圖片格式
在實(shí)際開(kāi)發(fā)中,有時(shí)需要在不同平臺(tái)、不同應(yīng)用場(chǎng)景中對(duì)圖片格式進(jìn)行轉(zhuǎn)換,本文主要介紹了如何使用 Java 語(yǔ)言實(shí)現(xiàn)將 PNG 格式的圖片轉(zhuǎn)換為 BMP 格式的圖片,需要的可以了解下2025-03-03
Mybatis的collection三層嵌套查詢方式(驗(yàn)證通過(guò))
這篇文章主要介紹了Mybatis的collection三層嵌套查詢方式(驗(yàn)證通過(guò))，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-03-03
這篇文章主要介紹了Spring ProtocolResolver策略接口示例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-04-04
下面小編就為大家分享一篇基于JVM 中常見(jiàn)垃圾收集算法介紹，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-01-01
SpringBoot如何配置獲取request中body的json格式參數(shù)
這篇文章主要介紹了SpringBoot如何配置獲取request中body的json格式參數(shù)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要介紹了Java中的WeakHashMap源碼分析,WeakHashMap可能平時(shí)使用的頻率并不高,但是你可能聽(tīng)過(guò)WeakHashMap會(huì)進(jìn)行自動(dòng)回收吧,下面就對(duì)其原理進(jìn)行分析,需要的朋友可以參考下2023-09-09
這篇文章主要介紹了springmvc處理異步請(qǐng)求的示例，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-01-01
一鍵清除maven倉(cāng)庫(kù)中下載失敗的jar包的實(shí)現(xiàn)方法
這篇文章主要介紹了一鍵清除maven倉(cāng)庫(kù)中下載失敗的jar包的實(shí)現(xiàn)方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07