WebClient 在使用 share（） 后跟 block（） 调用但调用 block（） 时挂起，但调用 block（） 仅返回错误

Question

我在Spring批处理应用程序中使用Spring WebFlux WebClient，当我调用block时，我遇到了错误。代码非常简单，但是当我尝试从批处理作业中的控制器上的 Rest 终结点启动作业的应用程序时，我收到错误。

其余终结点如下所示：

@RequestMapping("/migration/products/catalog 
class ProductController{
    private final Job job; 
    ResponseEntity<Map<String,Object> loadProductCatalog(){
       // Code  to launch Product Catalog Job
    }
}

这是调用远程客户端以获取产品目录信息的方法，控制器可以使用这些信息来加载有关产品的信息

 public ProductInfo findProductInfo()  {
    try{
        String url =....;
        return webClient.get().uri(url)
                .accept(MediaType.APPLICATION_JSON).retrieve().
                bodyToMono(ProductInfo.class).share().block();
    }catch(Exception e){
        log.error("Exception during retrieval of ProductInfo Data [}", e);
        return null;
    }

}

findProductInfo方法包装在一个Service中，用于在Controller中检索ProductInfo。我使用share（），因为对Rest控制器的block（）调用刚刚挂起。

但是，如果我简单地调用block（）并首先调用share（），则对控制器的调用返回，但抛出以下错误。我对使用WebFlux非常陌生，所以我不知道发生了什么。我非常感谢您帮助我理解正在发生的事情以及解决这个问题的方法

java.lang.IllegalStateException:block（）/blockFirst（）/block last（）正在阻塞，这在线程reactor-http-nio-2中不受支持

当我使用 share（） 后跟 block（） 时，当我调用 rest 终结点时，我的应用程序挂起。但是，如果我单独使用block（），则方法返回

Answer 1

已解决:我的作业是在单线程中运行的，所以share()。block()阻塞了作业启动器的主线程。通过观察任务执行者是同步的，我发现这给了我线索，这突然变得有意义了。我配置了一个任务执行器，这样任务就可以在自己的线程和viola中运行了！