如何在使用Reactor Netty HTTP客户端时同时获得HTTP响应体和状态

Question

我在这里使用Reactor Netty HTTP客户端作为独立的依赖项，即不是通过spring-webflux，因为我不想拖入与spring相关的依赖项

从文档中可以看出，可以发出返回HttpClientResponse的请求

import reactor.netty.http.client.HttpClient;
import reactor.netty.http.client.HttpClientResponse;

public class Application {

    public static void main(String[] args) {
        HttpClientResponse response =
                HttpClient.create()                   
                          .get()                      
                          .uri("http://example.com/") 
                          .response()                 
                          .block();
    }
}

问题是httpclientresponse只包含头和staus。从这里的Java文件可以看出

从示例中也可以使用您可以做的数据

import reactor.netty.http.client.HttpClient;

public class Application {

    public static void main(String[] args) {
        String response =
                HttpClient.create()
                          .get()
                          .uri("http://example.com/")
                          .responseContent() 
                          .aggregate()       
                          .asString()        
                          .block();
    }
}

但这仅将http实体数据作为字符串返回。没有有关标头或状态代码的信息。

我现在遇到的问题是，我需要发出一个请求，并得到一个响应，该响应既给我报头、状态等，又给我http响应体。

我好像找不到办法。有什么想法吗？QW

Answer 1

看看下面的方法：

• 通量 响应（双功能 >接收器）
• 单 响应（双功能 >接收器）

它们允许您同时访问响应正文、状态和http头。

例如，使用responseSingle方法，可以执行以下操作：

private Mono<Foo> getFoo() {
    return httpClient.get()
            .uri("foos/1")
            .responseSingle(
                    (response, bytes) ->
                            bytes.asString()
                                    .map(it -> new Foo(response.status().code(), it))
            );
}

上面的代码将响应转换为某些域对象foo,定义如下：

public static class Foo {
    int status;
    String response;

    public Foo(int status, String response) {
        this.status = status;
        this.response = response;
    }
}