使用spring webflux和hystrix的并发调用

Question

对于后台，我有一个前面的函数，它将生成一个用户列表，然后将使用该列表为列表中的每个用户调用此getUser详细信息函数，并返回用户详细信息的映射或列表。

@HystrixCommand(commandKey = "getUserDetails")
  public getUserResponse getUserDetails(userRequest request) {
    getUserResponse response = webClient.post()
        .uri(uri)
        .body(BodyInserters.fromObject(request))
        .retrieve()
        .onStatus(HttpStatus::isError, resp -> resp.bodyToMono(getUserError.class).map(errorHandler::mapRequestErrors))
        .bodyToMono(getUserResponse.class).block();

    return response;
  }

理想情况下，我还会替换/删除错误映射，因为仅涉及记录返回的错误响应并继续。到目前为止，我已经想到了一些类似的东西，但我不确定 webflux/hystrix 会玩得很好吗？

@HystrixCommand(commandKey = "getUserDetails", fallbackMethod = "getUserFallback")
  public Mono<getUserResponse> getUserDetails(userRequest request) {
    return = webClient.post()
        .uri(uri)
        .body(BodyInserters.fromObject(request))
        .retrieve()
        .bodyToMono(getUserResponse.class);
  }

  @HystrixCommand
  public Mono<getUserResponse> getUserFallback(userRequest request, Throwable throwable) {
    log.error(//contents of error message returned)
    return mono.empty();
  }

public Flux<UserMap> fetchUserDetails(List<Integer> userIds) {
    return Flux.fromIterable(userIds)
        .parallel()
        .runOn(Schedulers.elastic())
    .flatMap(userDetailsRepository::getUserDetails);
}

Answer 1

Hystrix已被弃用。如果有机会，请转到支持Webflux/Reactor的resilience4j。

Spring还专门支持弹性4j。

关于错误处理，您可以利用Mono/Flux API中丰富的运算符集，如< code>onErrorReturn或< code>onErrorResume。