带调度的下拖阻塞操作不起作用

Question

我不能让非常基本的底拖示例按预期工作。下面的代码应该允许服务并发HTTP请求。实际发生的情况是，只有一个请求被处理，在第一个请求完成之前，其他请求都无法通过。

public class MainUT {

    public static void main(String[] args) {
        Undertow.builder()                                                      
            .addHttpListener(8080, "localhost")                                    
            .setHandler(new HttpHandler() {                                                   
                @Override
                public void handleRequest(final HttpServerExchange exchange) 
                                            throws Exception {
                    if(exchange.isInIoThread()){
                        exchange.dispatch(this);
                        return;
                    }
                    exchange.getResponseHeaders().put(Headers.CONTENT_TYPE, "text/plain");
                    exchange.getResponseSender().send("Hello World");               
                }
            }).build().start();
    }
}

 curl http://localhost:8080

增加XNIO线程数及其工作线程不会改变任何事情。一个随机的XNIO被分配给请求。然后在调度后分配一个随机工作者。服务器一直处于阻塞状态，直到请求得到服务。

Answer 1

您的代码看起来很好，但是查看BlockingHandler，请尝试下面的操作，或者直接使用BlockingHandler。

exchange.startBlocking();
if (exchange.isInIoThread()) {
    exchange.dispatch(handler);
} else {
    handler.handleRequest(exchange);
}

要获得链接HttpHandler的简单方法，请参见MiddleWareBuilder。我还将尝试设置访问日志处理程序，以便您可以看到正在发生什么以及哪个线程正在处理每个请求。