编辑:这个问题的核心是处理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
}
}
暂无答案!
目前还没有任何答案,快来回答吧!