从属网络客户端呼叫-Spring被动响应

Question

我试图做两个API调用，第二个API调用依赖于第一个API响应。下面这段代码给出了第一次weblient调用的响应。在这里，我没有得到来自第二个API调用的响应。在日志中，我可以看到对第二个网络客户端调用的请求甚至不是用onSubcribe（）启动的。你能告诉我我做错了什么吗？

@Autowired
Issue issue;

List issueList = new ArrayList<>();

public Mono<Response> getResponse(Request request) {
   return webClient.post()
     .uri("myURI")
     .body(Mono.just(request),Request.class)
     .retrieve()
     .bodyToMono(Response.class)
     .flatMap(resp->{
           resp.getIssues().stream()
              .forEach(issueTemp -> {
                 issue = issueTemp;
                 webClient.get()
                    .uri("mySecondURI" + issueTemp.getId())
                    .retrieve()
                    .bodyToMono(Issue.class)
                     .flatMap(issueTemp2-> {
                        issue.setSummary(issueTemp2.getSummary());
                        return Mono.just(issue);
                     }).log();
           issueList.add(issue);
        });

        Response responseFinal = new Response();
        responseFinal.setIssues(issueList);
        return Mono.just(responseFinal);
    }).log();
}

更新2：

我已经将我的代码更改为Functions，并使用Flux而不是流迭代。我现在面临的是，所有的迭代都被过滤掉do秒dCall方法。请参考我的意见do秒dCall方法。由于其原因，第二次调用不被触发。如果我不应用过滤器，会有像“问题/空”这样的请求触发，这也会导致我的服务下降。

 public Mono<Response> getResponse(Request request) {
   return webClient.post()
     .uri("myURI")
     .body(Mono.just(request),Request.class)
     .retrieve()
     .bodyToMono(Response.class)
     .flatMap(r->
         doSecondCall(r).flatMap(issueList->{
             r.setIssues(issueList);
             return Mono.just(r);
           })
     );
}

public Mono<Issue> doSecondCall(Response r) {
          return Flux.fromIterable(r.getIssues())
                      .filter(rf->rf.getId()!=null) //everything gets filtered out
                      .flatMap(issue->getSummary(issue.getId()))
                      .collectList();
  }


public Mono<Issue> getSummary(Response r) {
          return webClient.get()
                       .uri("issue/"+id)
                       .retrieve()
                       .bodyToMono(Issue.class).log();

   }

[使用WebFlux的反应式编程如何处理依赖的外部api调用]@Thomas-另外，刚刚找到了这个线程。他基本上说，除非你阻止第一次通话，否则就无法宣布第二次通话。是这样吗？

Answer 1

你为什么不触发第二次呼叫，是因为你打破了我在这个答案中提到的链条（附示例）。

别再打破锁链了

// here...
.forEach(issueTemp -> {
    issue = issueTemp; // and this is just silly? why?
    webClient.get() // Here you are calling the webClient but ignoring the return value, so you are breaking the chain.
        .uri("mySecondURI" + issueTemp.getId())
        .retrieve()
        .bodyToMono(Issue.class)
        .flatMap(issueTemp2-> {
            issue.setSummary(issueTemp2.getSummary());
            return Mono.just(issue); // Return here but you are ignoring this return value
        }).log();
    issueList.add(issue);
});

你应该使用更多的函数来划分你的代码。通过编写函数使其成为一种习惯，并且总是从返回语句开始。你的代码很难读。

我认为你应该使用通量而不是迭代流。

// something like the following i'm writing by free hand without IDE
// i have no idea what your logic looks like but you should get the point.
Flux.fromIterable(response.getIssues())
   .flatMap(issue -> {
       return getIssue(issue.getId())
           .flatMap(response -> {
               return issue.setSummary(reponse.getSummary());
           });
   }).collectList();