如何并行地进行多个Spring Webclient调用并等待结果？

Question

@GetMapping("/{id}/offers")
fun viewTaskOffers(
        @PathVariable("id") id: String,
        @AuthenticationPrincipal user: UserPrincipal
) : Flux<ViewOfferDTO> {
    data class TaskOfferPair(
        val task: TaskDTO,
        val offer: ViewOfferDTO
    )

    return client.getTaskOffers(id).map {
            it.toViewOfferDTO()
        }.zipWith(client.getTask(id), BiFunction {
            offer: ViewOfferDTO, task: TaskDTO -> TaskOfferPair(task, offer)
        }).filter {
            it.offer.workerUser.id == user.id || it.task.creatorUser == user.id
        }.map {
            it.offer
        }
}

• gettaskoffers返回offerdto
的流量
• GetTask返回一个TaskDto

如果您不能回答我的问题，请至少告诉我如何并行地执行多个API调用，并在WebClient中等待结果

Answer 1

下面是一个并行调用的用例。

public Mono<UserInfo> fetchCarrierUserInfo(User user) {
        Mono<UserInfo> userInfoMono = fetchUserInfo(user.getGuid());
        Mono<CarrierInfo> carrierInfoMono = fetchCarrierInfo(user.getCarrierGuid());

        return Mono.zip(userInfoMono, carrierInfoMono).map(tuple -> {
            UserInfo userInfo = tuple.getT1();
            userInfo.setCarrier(tuple.getT2());
            return userInfo;
        });
    }

这里：

• FetchUserInfo进行http调用以从另一个服务获取用户信息，并返回mono
• FetchCarrierInfo方法进行HTTP调用以从另一个服务获取carrierInfo，并返回mono
• Mono.zip()将给定的Mono合并到一个新的Mono中，当所有给定的Mono都生成了一个项时，该Mono将实现，并将它们的值聚合到一个tuple2中。