使用spring-boot webflux处理错误消息

Question

我正在编写一个java适配器，用于向WebService发布一些内容。在http服务中，我使用一个ExceptionHandler：

@org.springframework.web.bind.annotation.ExceptionHandler 
public ResponseEntity<String> handle(BadCommandException ex) {
  return ResponseEntity.badRequest().body(ex.getMessage());
}

如果我用卷曲/邮递员来称呼的话，那很管用。

private Mono<Optional<String>> post(String bearerToken, Model model, IRI outbox) {
    return WebClient.builder()
        .build()
        .post()
        .uri(outbox.stringValue())
        .contentType(new MediaType("text","turtle"))
        .body(BodyInserters.fromValue(modelToTurtleString(model)))              
        .header("Authorization", "Bearer " + bearerToken)
        .header("profile", "https://www.w3.org/ns/activitystreams")
        .accept(new MediaType("text", "turtle"))
        .retrieve()         
        .toEntity(String.class)
        .map(res->res.getHeaders().get("Location").stream().findFirst());
}

在成功的情况下，我希望从location头返回字符串。但是，例如，如果http-status为400，我如何抛出异常，并将正文中的错误消息添加到异常中呢？

谢谢

Answer 1

webclient retreive（）的spring文档提供了如何处理错误的示例。我建议你从那里开始。

Mono<Person> result = client.get()
        .uri("/persons/{id}", id).accept(MediaType.APPLICATION_JSON)
        .retrieve()
        .onStatus(HttpStatus::is4xxClientError, response -> ...)
        .onStatus(HttpStatus::is5xxServerError, response -> ...)
        .bodyToMono(Person.class);