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

Question

我正在使用Spring Webflux和Spring Boot2，我的场景如下：

@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;
}

在返回之前，我如何将来自流量和正常产品列表的结果连接起来？没有反应控制器是可能的吗？

附言。我不想对从调用1获得的结果调用。block（）和CompleteableFuture

Answer 1

如果要从该方法返回list ，则没有.block()方法就无法完成此操作。

您应该合并结果并从该方法返回flux ，以保持反应性方法。您可以使用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，那么这个调用将阻塞线程池。

在这种情况下，请看一下：在Spring Webflux中执行阻塞JDBC调用