获取http响应代码和所有可用正文

Question

我想要ot实现WebFlux示例客户端，它可以用http params发出请求，并获得响应体和http响应代码。我试过这个：

public ClientResponse execute(NotificationMessage nm)
Mono<String> transactionMono = Mono.just(convertedString);
        return client.post().uri(builder -> builder.build())
                .header(HttpHeaders.USER_AGENT, "agent")
                .body(transactionMono, String.class).exchange().block();
    }

    private static String convert(Map<String, String> map) throws UnsupportedEncodingException {
        String result = map.entrySet().stream().map(e -> encode(e.getKey()) + "=" + encode(e.getValue()))
                .collect(Collectors.joining("&"));
        return result;
    }

    private static String encode(String s) {
        try {
            return URLEncoder.encode(s, "UTF-8");
        } catch (UnsupportedEncodingException e) {
            throw new IllegalStateException(e);
        }
    }

您能在.exchange()之后给我一些建议吗？我如何获得http状态代码和所有可用的主体。

Answer 1

从exchange返回的ClientResponse对象中，您可以使用response.statuscode（）获取状态，并使用response.bodytoMono（）或bodyToFlux（）获取实际的主体。您应该避免在反应式编程中使用。block()，而使用。subscribe（）或。flatmap（）或其他运算符来从Mono或Flux对象获取数据。在这里阅读更多关于反应性编程和项目反应器（由spring webflux使用）的信息。

例如：

public Mono<Data> execute(NotificationMessage nm)
    return client.post().uri(builder -> builder.build())
                .header(HttpHeaders.USER_AGENT, "agent")
                .body(transactionMono, String.class).exchange()
                .flatMap(response -> {
                        HttpStatus code = response.statusCode();
                        Data data = response.bodyToMono(Data.class);
                        return data;
                });
}