在Spring Webflux中组合多个单声道

Question

    mainService.getAllBranch()
            .flatMapMany(branchesList -> {
                List<Branch> branchesList2 = (List<Branch>) branchesList.getData();
                List<Mono<Transaction>> trxMonoList= new ArrayList<>();

                branchesList2.stream().forEach(branch -> {
                    trxMonoList.add(mainService.getAllTrxByBranchId(branch.branchId));
                });
                return Flux.concat(trxMonoList); // <--- is there any other way than using concat?
            })
            .collectList()
            .flatMap(resultList -> combineAllList());

    interface MainService{
            Mono<RespBody> getAllBranch();
            Mono<RespBody> getAllTrxByBranchId(String branchId); //will return executed url ex: http://trx.com/{branchId}
    }

1. 获取所有分支
2. 遍历所有brancheslist2并将其添加到trxmonolist
3. 返回flux.concat，这是我不确定这样做是否正确的地方。但它起作用了
4. 合并所有列表

我只是困惑，这是在我的上下文中使用flux的正确方式吗？或者有没有什么更好的方法来实现我正在努力做的事情？

Answer 1

您需要稍微将代码重构为反应式代码。

 mainService.getAllBranch()
        .flatMapMany(branchesList -> Flux.fromIterable(branchesList.getData())) (1)
        .flatMap(branch -> mainService.getAllTrxByBranchId(branch.branchId))    (2)
        .collectList()
        .flatMap(resultList -> combineAllList());

1）从列表中创建分支通量；

2）遍历每个元素并调用一个服务。

您不应该在Reactor中使用Stream API，因为它有相同的方法，但对多线程进行了适配和优化。