WebClient exchangeToMono正在检索空正文

Question

使用WebClient的exchangeToMono（）时，正文检索部分总是返回一个空的Mono：

例如，返回非空Mono的公开服务

@PostMapping("/test")
public Mono<Pojo> getCalled(@RequestBody Pojo pojo) {
    System.out.println(pojo); // always prints a non-null object
    return Mono.just(pojo);
}

带有的WebClient。retrieve（）

WebClient.create().post().uri(theUrl).bodyValue(p).retrieve().toEntity(Pojo.class).map(response -> {
    if (response.getStatusCode().isError()) {
        // do something;
    }
    return response.getBody();
}).single(); // always get a single element and does not fail

带有. exchange eToMono（）的WebClient

WebClient.create().post().uri(theUrl).bodyValue(p).exchangeToMono(Mono::just).flatMap(response -> {
    if (response.statusCode().isError()) {
        // do something;
    }

    return response.bodyToMono(Pojo.class).single(); // fails with java.util.NoSuchElementException: Source was empty
});

我做错什么了吗？

Answer 1

响应Mono为空，因为它已经被. exchange eToMono使用，因此单（）运算符在NoSuchElementException中失败。

Answer 2

我不知道你为什么要做exchange eToMono（Mono::只是）。

不，您不需要使用Mono两次，您需要的是阅读有关如何正确使用exchange功能WebClient的文档

以下是摘自文档的示例

Mono<Person> entityMono = client.get()
        .uri("/persons/1")
        .accept(MediaType.APPLICATION_JSON)
        .exchangeToMono(response -> {
            if (response.statusCode().equals(HttpStatus.OK)) {
                return response.bodyToMono(Person.class);
            }
            else {
                // Turn to error
                return response.createException().flatMap(Mono::error);
            }
        });

这是您的代码，但要在exchangeToMono中执行操作

WebClient.create().post().uri(theUrl).bodyValue(p).exchangeToMono(response -> {
    if (response.statusCode().isError()) {
        // do something;
    }

    return response.bodyToMono(Pojo.class).single();
});

exchangeToMono有一个目的，它不是把东西放进Mono中