如何使用响应式框架组合Mono与Flux，为批量Product设置统一Category

在响应式编程中，不能像处理普通集合那样直接阻塞获取Mono的值，需要通过响应式操作符来组合Mono和Flux的数据流。针对你的场景，核心思路是先获取到Category实例，再将其与每个Product关联，具体实现如下：

Flux<Product> products = productRepository.findAllById(productCodes);
Mono<Category> category = categoryRepository.findById(productCodes.get(0));

// 响应式方式为每个Product设置Category
Flux<Product> productsWithCategory = category.flatMapMany(targetCategory -> 
    products.map(product -> {
        product.setCategory(targetCategory);
        return product;
    })
);

代码说明： #

1. flatMapMany操作符：等待Mono<Category>发射出分类数据后，将该数据传递给后续的处理逻辑，同时将Mono转换为Flux类型输出，匹配products的数据流类型。
2. map操作符：遍历Flux<Product>中的每个产品，为其设置目标分类，最后返回处理后的产品对象。

额外注意事项： #

• 如果你的Product是不可变对象（没有setCategory方法），可以通过创建新的Product实例来完成关联：

  products.map(product -> new Product(
      product.getId(), 
      product.getName(), 
      targetCategory // 传入分类参数
  ))
  

• 原代码中productCodes.get(0)存在空指针风险，如果productCodes可能为空，建议先处理空值情况：

  Mono<Category> category = Mono.justOrEmpty(productCodes.stream().findFirst())
      .flatMap(code -> categoryRepository.findById(code));
  

内容的提问来源于stack exchange，提问作者BreenDeen