小编No_*_*One的帖子

有没有办法向 spring webflux 控制器端点添加响应头？例如，对于以下方法，我必须添加一个自定义标题，例如“x-my-header”

@GetMapping(value = "/search/{text}")
@ResponseStatus(value = HttpStatus.OK)
public Flux<SearchResult> search(@PathVariable(
        value = "text") String text){

        return searchService().find(text);
}

有没有办法将 Mono 对象转换为 java Pojo？我有一个 Web 客户端连接到 3rd 方 REST 服务，Mono我必须提取该对象并询问它，而不是返回。

我找到的所有示例都返回了，Mono<Pojo>但我必须获得 Pojo 本身。目前，我通过调用block()Pojo 来做到这一点，但有没有更好的方法来避免阻塞？

该块的问题在于，在几次运行后，它开始抛出一些错误，例如块因错误而终止。

 public MyPojo getPojo(){
     return myWebClient.get()
                .uri(generateUrl())
                .headers(createHttpHeaders(headersMap))
                .exchange()
                .flatMap(evaluateResponseStatus())
                .block();
}


private Function<ClientResponse, Mono<? extends MyPojo>> evaluateResponseStatus() {
      return response -> {
            if (response.statusCode() == HttpStatus.OK) {
                return response.bodyToMono(MyPojo.class);
            }
            if (webClientUtils.isError(response.statusCode())) {
                throw myHttpException(response);
                // This invokes my exceptionAdvice
                // but after few runs its ignored and 500 error is returned.
            }
            return Mono.empty();
        };
    }