spring-boot - 结合非阻塞和阻塞调用并在 Spring Webflux 中返回结果

Question

我正在使用 Spring Webflux 和 Spring boot 2，我的场景是这样的:

Controller

@GetMapping(path="/products")
public List<Products> getProducts(){
 return serviceObj.getProducts();
}

服务类

public List<Products> getProducts(){
List<Products> products = null;
  //Call 1 -> to repository class method returning Flux<Products>
repositoryObj.getProductsFlux();
  //Call 2 -> To repository class method returning List<Products>
repositoryObj.getProductsNormal();
  //Concat results from Call 1 & Call 2 and return List<Products>
return products;
}

如何在返回之前连接来自 Flux 和 normal 产品列表的结果？没有 Reactive Controller 是否可行？

附言我不想对调用 1 获得的结果调用 .block() 和 CompleteableFuture

Answer 1

没有 .block() 就没有办法做到这一点如果你想返回 List<Products>从那个方法。

您应该合并结果并返回 Flux<Products>从这个方法到保持被动的方法。您可以使用 mergeWith 或 concatWith

示例:

public Flux<Products> getProducts(){
    List<Products> productsNonFlux = repositoryObj.getProductsNormal();
    Flux<Products> productsFlux = repositoryObj.getProductsFlux();
    return productsFlux.mergeWith(Flux.fromIterable(productsNonFlux));
}

重要!

请记住，如果您的 repositoryObj.getProductsNormal()正在使用 JDBC，那么此调用将阻塞线程池。

在这种情况下，请查看: Execute blocking JDBC call in Spring Webflux