WebClient 的 bodyToMono 关于空体预期行为

Posted

技术标签:

【中文标题】WebClient 的 bodyToMono 关于空体预期行为【英文标题】:WebClient's bodyToMono on Empty Body Expected Behavior 【发布时间】:2019-09-27 07:58:27 【问题描述】:

当 WebClient bodyToMono 遇到空主体时,预期的行为是什么?在我的具体示例中,我们正在检查从 post 调用返回的状态,如果将其转换为我们的自定义错误格式是错误的。如果转换为自定义错误格式失败,我们会在自定义格式中创建一个新错误,说明这一点。但是,当响应是一个空主体的错误时,它根本没有发回任何错误,因为 bodyToMono 没有像我预期的那样失败。请看下面的代码块:

.retrieve()
.onStatus(HttpStatus::isError)  response ->
    response.bodyToMono(ErrorResponse::class.java)
        .doOnError 
            throw APIException(
                code = UNEXPECTED_RESPONSE_CODE,
                reason = it.message ?: "Could not parse error response from Inventory Availability",
                httpStatus = response.statusCode()
            )
        
        .map 
            throw APIException(
                reason = it.errors.reason,
                code = it.errors.code,
                httpStatus = response.statusCode()
            )
        

为了解决这个问题,我们添加了 switchIfEmpty。

.retrieve()
.onStatus(HttpStatus::isError)  response ->
    response.bodyToMono(ErrorResponse::class.java)
        .switchIfEmpty  throw RuntimeException("Received Empty Response Body") 
        .doOnError 
            throw APIException(
                code = UNEXPECTED_RESPONSE_CODE,
                reason = it.message ?: "Could not parse error response from Inventory Availability",
                httpStatus = response.statusCode()
            )
        
        .map 
            throw APIException(
                reason = it.errors.reason,
                code = it.errors.code,
                httpStatus = response.statusCode()
            )
        

我的问题是:这是 bodyToMono 的预期行为吗?由于我明确要求将响应主体映射到我的 ErrorResponse 对象,我希望一个空主体出错,然后点击 doOnError 块,但它只是“成功”/返回一个空单声道......因此我们添加switchIfEmpty 块。如果我们映射到的对象具有可为空的字段,我可以看到它没有错误,但由于所有字段都是必需的,为什么 bodyToMono 在尝试将“无”映射到我的对象时不会抛出错误?

【问题讨论】:

【参考方案1】:

这是正确的。一个 Mono 可以产生 0..1 个元素,而一个空主体只产生一个完成而不发出值的单声道,就像 Mono.empty()。

如果您的用例中没有正文错误,您可以在单声道上调用 .single()。

【讨论】:

以上是关于WebClient 的 bodyToMono 关于空体预期行为的主要内容,如果未能解决你的问题,请参考以下文章

使用 Spring WebClient 解码内容编码 gzip

如何从Mono获取实体类型 ?

block()/blockFirst()/blockLast() 在 exchange() 之后调用 bodyToMono 时出现阻塞错误

关于webclient提交数据时http头的问题

反应式 WebClient 未发出响应

多线程环境下使用Spring WebClient的正确方法