如何在WebFlux控制器中订阅

Question

在REST控制器中，我需要调用REST以获取一个值，用作第二次REST调用的URI变量。

@PostMapping
public void abbina(@RequestBody DocumentsUploadRequest documentsUploadRequest) {

  Mono<GetResult> result = WebClient
      .create(url)
      .get()
       .....
      .retrieve()
      .bodyToMono(GetResult.class)
      ;

  WebClient.post()
      .uri(...)
      .path("/{partita}")
      .build(result.block().getValue()))
      .....
      .bodyToMono(PostResult.class)
   ....
}

问题是在WebFlux REST中不可能调用mono/flux上的块。

代码抛出

Java . lang . illegalstateexception block()/block first()/block last()正在阻塞，这在线程反应器中是不支持的-http

我试图改变

. build（result.block（）. getValue（）））

与

。build(result.share()。阻止()。getValue()))

但现在的问题是< code>result.share()。block()无限期挂起。

Answer 1

首先，切勿阻塞反应式管道。您应该改为订阅。在这种特殊情况下，只要您提供发布者，Spring Webflux框架就会为您订阅。为此，控制器方法必须像这样返回 Mono 发布者：

@PostMapping
public Mono<Void> abbina(@RequestBody Attribute documentsUploadRequest) {

}

在这里，Mono

然后，您必须构建一个没有阻塞的反应式管道。

第一个HTTP调用的结果是GetResult的Mono：

private Mono<GetResult> getResult() {
    return WebClient
            .get()
            //...
            .retrieve()
            .bodyToMono(GetResult.class);
}

同样，第二个 HTTP 调用返回一个单声道的后结果：

private Mono<PostResult> postResult(String firstResult) {
    return WebClient
            .post()
            //...
            .retrieve()
            .bodyToMono(PostResult.class);
}

最后，将这两个发布者结合起来，以便使用平面地图运算符构建您的管道：

@PostMapping
public Mono<Void> abbina(@RequestBody Attribute documentsUploadRequest) {
    return getResult()
            .flatMap(result -> postResult(result.getValue()))
            .then();
}

我建议查看以下指南：构建反应式RESTful Web服务