WebClient拋UnsupportedMediaTypeException異常解決
前言
前面分享了Spring5中的WebClient使用方法詳解 后,就有朋友在segmentfault上給博主提了一個(gè)付費(fèi)的問題,這個(gè)是博主在segmentfault平臺(tái)上面收到的首個(gè)付費(fèi)問答,雖然酬勞不多,只有十元,用群友的話說性價(jià)比太低了。但在解決問題過程中對WebClient有了更深入的了解卻是另一種收獲。解決這個(gè)問題博主做了非常詳細(xì)的排查和解決,現(xiàn)將過程記錄在此,供有需要的朋友參考。
問題背景
使用WebClient請求一個(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):
直譯過來大概的意思就是,不支持application/octet-stream類型的Content Type。
問題分析
如上異常,拋異常的代碼在BodyExtractors的201行,根據(jù)異常堆棧信息找到對應(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端沒有返回contentType ,默認(rèn)就使用APPLICATION_OCTET_STREAM來接收數(shù)據(jù)。問題正是這里導(dǎo)致的。因?yàn)樵谶@個(gè)接口的響應(yīng)header里,contentType 為null,其實(shí)正確的應(yīng)該是application/json,只是服務(wù)器沒指定,然后被默認(rèn)策略設(shè)置為application/octet-stream后,在默認(rèn)的JSON解碼器里是不支持,導(dǎo)致拋出了不支持的MediaType異常。定位到真實(shí)原因后,博主給出了如下方案
解決方案
方案一
如果服務(wù)端是自己的服務(wù),可以修改服務(wù)端的程序指定ContentType為application/json類型返回即可。如果是第三方的服務(wù),沒法改動(dòng)server端請參考下面的方案
方案二
使用String接收后,然后在flatMap里在過濾自己解碼一遍,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里沒有指定Content Type為application/json。而最終異常也是因?yàn)閖son解碼器不支持導(dǎo)致的,所以我們可以定制json解碼器,重寫支持的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里沒有Content-Type,所以可以使用exchange()拿到clientResponse后重新build一個(gè)ClientResponse,然后設(shè)置Content-Type為application/json即可解決問題,代碼如:
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()了,博主以為這種方式最簡潔優(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)說了,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的官方倉庫了,如果合并了的話,就可以在下個(gè)版本使用這個(gè)方案解決問題了
pr地址:https://github.com/spring-projects/spring-framework/pull/24120
以上就是WebClient拋UnsupportedMediaTypeException異常解決的詳細(xì)內(nèi)容,更多關(guān)于WebClient拋UnsupportedMediaTypeException的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
常用數(shù)字簽名算法RSA與DSA的Java程序內(nèi)實(shí)現(xiàn)示例
這篇文章主要介紹了常用數(shù)字簽名算法RSA與DSA的Java程序內(nèi)實(shí)現(xiàn)示例,一般來說DSA算法用于簽名的效率會(huì)比RSA要快,需要的朋友可以參考下2016-04-04如何在Netty中注解使用Service或者M(jìn)apper
這篇文章主要介紹了如何在Netty中注解使用Service或者M(jìn)apper,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-02-02Spring實(shí)戰(zhàn)之使用@POSTConstruct和@PreDestroy定制生命周期行為操作示例
這篇文章主要介紹了Spring實(shí)戰(zhàn)之使用@POSTConstruct和@PreDestroy定制生命周期行為操作,結(jié)合實(shí)例形式詳細(xì)分析了Spring使用@POSTConstruct和@PreDestroy定制生命周期相關(guān)接口定義、配置與功能實(shí)現(xiàn)技巧,需要的朋友可以參考下2019-12-12