如何使用Spring Flux并行对同一服务的平行呼叫

Question

我正在使用弹簧反应式工作，需要使用WebClient将多个呼叫依次致电其他REST API。 问题是我能够致电其他REST API的多个呼叫，但是在没有订阅或阻止的情况下，响应无法阅读。 由于非反应性编程，我无法使用订阅或阻止。有什么办法，我可以在阅读响应时合并并将其作为通量发送。 以下是我被卡住的代码。

public Mono<DownloadDataLog> getDownload(Token dto, Mono<DataLogRequest> request) {
    Mono<GraphQlCustomerResponse> profileResponse = customerProfileHandler.getMyUsageHomeMethods(dto, null);
    DownloadDataLog responseObj = new DownloadDataLog();
    ArrayList<Mono<List<dataUsageLogs>>> al = new ArrayList<>();
    return Mono.zip(profileResponse, request).flatMap(tuple2 -> {
        Flux<List<Mono<DataLogGqlRequest>>> userequest = prepareUserRequest(getListOfMdns(tuple2.getT1()),
                tuple2.getT2());              
        Flux.from(userequest).flatMap(req -> {
            for (Mono<DataLogGqlRequest> logReq : req) {
                al.add(service.execute(logReq, dto));
            }
            responseObj.setAl(al);
            return Mono.empty();
        }).subscribe();
          return Mono.just(responseObj);

    });

}

private Mono<DataLogGqlRequest> prepareInnerRequest(Mono<DataLogGqlRequest> itemRequest, int v1,int v2){
    return itemRequest.flatMap(req -> {
        DataLogGqlRequest userRequest = new DataLogGqlRequest();
        userRequest.setBillDate(req.getBillDate()); 
        userRequest.setMdnNumber(req.getMdnNumber());
        userRequest.setCposition(v1+"");    
        userRequest.setPposition(v2+"");
        return Mono.just(userRequest);
    });
    
    
}