将单声道转换为无块的波约

Question

有没有办法将Mono对象转换为javaPojo？我有一个web客户端连接到第三方REST服务，而不是返回＜code＞Mono＜/code＞，我必须提取该对象并询问它。

我找到的所有示例都返回Mono

块的问题是，运行几次后，它开始抛出一些错误，例如块终止错误。

 public MyPojo getPojo(){
     return myWebClient.get()
                .uri(generateUrl())
                .headers(createHttpHeaders(headersMap))
                .exchange()
                .flatMap(evaluateResponseStatus())
                .block();
}


private Function<ClientResponse, Mono<? extends MyPojo>> evaluateResponseStatus() {
      return response -> {
            if (response.statusCode() == HttpStatus.OK) {
                return response.bodyToMono(MyPojo.class);
            }
            if (webClientUtils.isError(response.statusCode())) {
                throw myHttpException(response);
                // This invokes my exceptionAdvice
                // but after few runs its ignored and 500 error is returned.
            }
            return Mono.empty();
        };
    }




Answer 1

自Webclient以来。不建议使用block（），从传入的httpresponse中检索值的另一种方法是在调用应用程序中创建一个具有必需字段的POJO。然后，一旦收到Mono，就使用Mono。subscribe（），在subscrube中添加一个lambda函数，输入为x，以使用x.getters（）检索各个字段。这些值可以打印在控制台上，也可以分配给本地变量进行进一步处理。这有两个方面的帮助：-

1. 避免可怕的.block（）
2. 拉取大量数据时保持调用异步。这是实现预期结果的许多其他方法之一

Answer 2

阻止在反应式流中对价值进行操作不是一个好主意。项目反应器为您提供了一系列运算符，供您处理流中的对象。

就您的情况而言，您可以编写getPojo（）方法，如下所示：

public Mono<MyPojo> getPojo() {
     return myWebClient.get()
            .uri(generateUrl())
            .headers(createHttpHeaders(headersMap))
            .retrieve()
            .onStatus(status -> webClientUtils.isError(status), 
                      response -> Mono.error(myHttpException(response))
            .bodyToMono(MyPojo.class)
}

请注意，使用 onStatus 方法，我们在您的示例中替换了整个评估响应状态方法。

您可以按如下方式使用此方法：

// some method
...
getPojo()
    .map(pojo -> /* do something with the pojo instance */)
...

我强烈建议你在Project Reactor文档中考虑转换一个现有的序列。