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

WebClient拋UnsupportedMediaTypeException異常解決

 更新時(shí)間：2022年02月24日 14:49:34   作者：kl  
這篇文章主要為大家介紹了WebClient拋UnsupportedMediaTypeException異常的解決方案，文中給大家介紹了六中方案，有需要的朋友可以借鑒參考下，希望能夠有所幫助

前言

前面分享了Spring5中的WebClient使用方法詳解 后，就有朋友在segmentfault上給博主提了一個(gè)付費(fèi)的問題，這個(gè)是博主在segmentfault平臺(tái)上面收到的首個(gè)付費(fèi)問答，雖然酬勞不多，只有十元，用群友的話說(shuō)性價(jià)比太低了。但在解決問題過(guò)程中對(duì)WebClient有了更深入的了解卻是另一種收獲。解決這個(gè)問題博主做了非常詳細(xì)的排查和解決，現(xiàn)將過(guò)程記錄在此，供有需要的朋友參考。

問題背景

使用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。

問題分析

如上異常，拋異常的代碼在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端沒有返回contentType ，默認(rèn)就使用APPLICATION_OCTET_STREAM來(lái)接收數(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端請(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里沒有指定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()了，博主以為這種方式最簡(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è)方案解決問題了

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)文章

  • 常用數(shù)字簽名算法RSA與DSA的Java程序內(nèi)實(shí)現(xiàn)示例

    常用數(shù)字簽名算法RSA與DSA的Java程序內(nèi)實(shí)現(xiàn)示例

    這篇文章主要介紹了常用數(shù)字簽名算法RSA與DSA的Java程序內(nèi)實(shí)現(xiàn)示例,一般來(lái)說(shuō)DSA算法用于簽名的效率會(huì)比RSA要快,需要的朋友可以參考下
    2016-04-04
  • 一文帶你弄懂Maven拉包(拉取依賴包)原理

    一文帶你弄懂Maven拉包(拉取依賴包)原理

    業(yè)務(wù)需求開發(fā)的時(shí)候，我們總是會(huì)遇到拉不到依賴包的情況，此時(shí)如果不清楚 Maven 拉取依賴包的原理，那么很可能找不到問題所在，今天小編就帶大家了解下 Maven 拉包的原理，讓你在遇到問題的時(shí)候能快速解決,需要的朋友可以參考下
    2023-07-07
  • Mac上配置JDK?1.8的超詳細(xì)流程

    Mac上配置JDK?1.8的超詳細(xì)流程

    相信每個(gè)拿到MAC的小伙伴都是很欣喜的,但是由于MAC系統(tǒng)與WIN系統(tǒng)有著極大的不同,所以使用起來(lái)會(huì)有一些小困擾,這篇文章主要給大家介紹了關(guān)于Mac上配置JDK?1.8的超詳細(xì)流程,需要的朋友可以參考下
    2023-11-11
  • 使用@Autowired注解有錯(cuò)誤提示的解決

    使用@Autowired注解有錯(cuò)誤提示的解決

    這篇文章主要介紹了使用@Autowired注解有錯(cuò)誤提示的解決，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2021-11-11
  • 利用mysql實(shí)現(xiàn)的雪花算法案例

    利用mysql實(shí)現(xiàn)的雪花算法案例

    這篇文章主要介紹了利用mysql實(shí)現(xiàn)的雪花算法案例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-08-08
  • 詳解RestTemplate?用法

    詳解RestTemplate?用法

    RestTemplate?是從?Spring3.0?開始支持的一個(gè)?HTTP?請(qǐng)求工具，也有的稱之為網(wǎng)絡(luò)框架，說(shuō)白了就是Java版本的一個(gè)postman，這篇文章主要介紹了詳解RestTemplate?用法,需要的朋友可以參考下
    2022-07-07
  • Java類和成員變量聲明類詳解

    Java類和成員變量聲明類詳解

    這篇文章主要介紹了Java類和成員變量聲明類詳解，類中的成員變量——這些被稱為字段，文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的朋友可以參考一下
    2022-08-08
  • 如何在Netty中注解使用Service或者M(jìn)apper

    如何在Netty中注解使用Service或者M(jìn)apper

    這篇文章主要介紹了如何在Netty中注解使用Service或者M(jìn)apper，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2022-02-02
  • Spring實(shí)戰(zhàn)之使用@POSTConstruct和@PreDestroy定制生命周期行為操作示例

    Spring實(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
  • Mybatis-Plus 通用CRUD的詳細(xì)操作

    Mybatis-Plus 通用CRUD的詳細(xì)操作

    這篇文章主要介紹了Mybatis-Plus 通用CRUD的詳細(xì)操作,包括插入操作，更新操作及刪除操作等，針對(duì)每種操作通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友可以參考下
    2021-09-09

最新評(píng)論