为什么不能在reactor netty中订阅请求？

Question

我只想访问reactor netty项目中的Http内容。但结果为空。

代码如下。

DisposableServer server =
            HttpServer.create()
                    .host("localhost")
                    .port(8000)
                    .route(routes ->
                                    .post("/echo",
                                            (request, response) -> 
                                                {   request.receive()
                                                        .retain()
                                                        .aggregate()
                                                        .asString()
                                                        .subscribe(System.out::println);
                                                    return response.sendString(Mono.just("hello"));})          
                    .bindNow();

我无法在控制台中获得结果。

我可以像在代码中一样访问请求吗？有人能帮忙吗？谢谢。

Answer 1

您在接收到请求数据之前返回响应，因此反应器Netty将在发送响应后删除收到的任何传入数据。

我不知道您的用例，但将示例更改为以下内容，您将能够看到传入的数据：

DisposableServer server =
        HttpServer.create()
                .host("localhost")
                .port(8000)
                .route(routes ->
                        routes.post("/echo",
                                (request, response) ->
                                        response.sendString(request.receive()
                                                .retain()
                                                .aggregate()
                                                .asString()
                                                .flatMap(s -> {
                                                    System.out.println(s);
                                                    return Mono.just("hello");
                                                })))
                )
                .bindNow();