SpringWebClient,对同一服务的并行调用,收集成功和错误进行响应

tvz2xvvm  于 2021-07-16  发布在  Java
关注(0)|答案(0)|浏览(211)

编辑:这个问题的核心是处理mono的错误,并转换成一个新的对象类型,以便以后可以根据需要进行Map。现在任何未处理的错误都将停止流。如果使用onerrorreturn,则必须返回原始响应类型(updateresponse),但我希望返回一个包含错误详细信息的新类型。我可以使用onerrorresume并返回mono.empty(),但我还是想捕获错误的详细信息。
我希望利用spring的React式webclient对外部服务进行并行调用,该服务将更新给定id列表的用户,然后将任何错误/成功收集到单个响应中,然后返回给调用者。到目前为止,我看到的所有错误处理都不允许我将数据Map到新的响应,因此不确定如何处理这个问题。

// This is the class where I want to collect and map successes/errors to a new response object
public class UpdateUserService {
  private final UpdateUserClient updateUserClient;

  public Mono<UpdateUserResponse> updateUser(List<Long> userIds, UpdateUserRequest request) {

    // Parallel calls to updateUserClient
    Mono<UpdateUserResponse> resp = Flux.fromIterable(userIds)
      .flatMap(userId -> updateUserClient.updatUser(userId, request))
      // How to maps successes and handle errors here to UpdateUserResponse?
      ...

      return resp;

  }
}

// Supporting classes
public class UpdateUserResponse {
    List<UpdateUserResult> results;
}

public class UpdateUserResult {
    Long id;
    Boolean success;
    String message;
}

public class UpdateUserClient {
    private final WebClient webClient;
    private final String path;

    public Mono<UpdateResponse> updatUser(Long userId, UpdateUserRequest request) {
        return webClient.put()
            .uri(uriBuilder -> uriBuilder
                .path(path)
                .queryParam("userId", userID)
                .build())
            .body(request, UpdateUserRequest.class)
            .accept(MediaType.APPLICATION_JSON)
            .retrieve()
            .bodyToMono(UpdateResponse.class);  // UpdateResponse just contains a success boolean
    }
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题