来自发布服务器的反应器netty http状态

Question

我不确定如何处理这个问题，http响应状态取决于我需要阅读的主体。我有这样的想法：

private NettyOutbound handleRequest(HttpServerRequest req, HttpServerResponse res) {
    Mono<String> body = req.receive().aggregate().asString(UTF_8);
    ...
    return res.status(status)
                .sendString(body, UTF_8);
}

private int status(String body) {
    ...
}

但为了获得阅读正文所需的状态，我看不到任何使用发布者提供的值的选项。我如何使其能够调用上面的方法，并在创建NetYoutBound时使用该状态

Answer 1

如果我理解正确，您正在尝试实现路由处理程序

我想下面的应该行得通

package hello;

import reactor.core.publisher.Mono;
import reactor.netty.DisposableServer;
import reactor.netty.http.server.HttpServer;
import reactor.netty.http.server.HttpServerRequest;
import reactor.netty.http.server.HttpServerResponse;

public class Application {
    
    private Mono<Void> handleRequest(HttpServerRequest req, HttpServerResponse res) {
        return req.receive().aggregate().asString().flatMap(body ->
                {
                    int status = status(body);
                    return res.status(status).sendString(Mono.just(body)).then();
                }
        );
    }

    private int status(String body) {
        return body.toLowerCase().equals("hello") ? 200 : 400;
    }

    public void startServer() {
        DisposableServer server =
                HttpServer.create()
                        .host("localhost")
                        .port(8080)
                        .route(routes -> routes.get("/hello", this::handleRequest))
                        .bindNow();
        
        server.onDispose().block();
    }

    public static void main(String[] args) {
        new Application().startServer();
    }
}