Java 如何组合Mono和Flux

发布于09月21日

我正在创建一个流动的产品和一个Mono Category对象，需要应用到产品，因为所有它们都要归入同一类别.我正在try 将类别添加到每个产品中，如下所示.


     Flux<Product> products = productRepository.findAllById(productCodes);
     Mono<Category> category = categoryRepository.findById(productCodes.get(0));
     
     The category for all these products should be set as:

     //If these were a list of products i.e List<Product> productList and Category was 
     //not a Mono I would set them like this:
 
     productList.forEach( product -> product.setCategory(category));

由于各自的存储库分别返回Mono和Flux，我不确定如何使用react 式框架来做到这一点，因为我对它非常陌生.有没有人可以教我如何使用react 式来实现这一点？

推荐答案

事实上，有很多方法可以实现这一点.

下面是一个例子，在这个例子中，你将flatMap()的函数应用到你的产品流量的每个元素上.此功能使用您的类别Mono来设置产品的类别.

productsFlux.flatMap(product -> categoryMono.map(category -> {
    product.setCategory(category);
    return product;
}));

或者反之亦然，在你的类别Mono上使用flatMapMany():

categoryMono.flatMapMany(category -> productsFlux.map(product -> {
    product.setCategory(category);
    return product;
}));

或者你可以用缓存把你的类别Mono变成永远不会结束的流量，然后对你的产品流量和类别流量做Flux.zip()，就像这样:(我更喜欢这个选项，因为它更好地确保数据库只调用一次类别)

Flux<String> categoryHotFlux = categoryMono.cache().repeat();

Flux.zip(productsFlux, categoryHotFlux)
        .map(tuple -> {
            Product product = tuple.getT1();
            Category category = tuple.getT2();
            product.setCategory(category);
            return product;
        });