Undertow + CompletableFuture/RxJava

Question

public class HelloWorldServer { 

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

这是hello世界应用程序使用的下游。 有人可以提供Undertow + CompletableFuture或RxJava的例子吗？我搜索了但没有成功。

Answer 1

下面是暗流你好世界RxJava 2：

public static void main(final String[] args) { 
    Observable<HttpServerExchange> exchangeObservable = Observable.create(observableEmitter -> { 
     Undertow server = Undertow.builder() 
       .addHttpListener(8080, "localhost") 
       .setHandler(new HttpHandler() { 
        @Override 
        public void handleRequest(final HttpServerExchange exchange) throws Exception { 
         observableEmitter.onNext(exchange); 
        } 
       }).build(); 
     server.start(); 
     observableEmitter.setCancellable(() -> server.stop()); 
    }); 

    exchangeObservable.subscribe(exchange -> { 
     exchange.getResponseHeaders().put(Headers.CONTENT_TYPE, "text/plain"); 
     exchange.getResponseSender().send("Hello World"); 
    }); 
} 

这只是一个简单的例子，在世界你好暗潮+ RxJava，这还没有考虑到在其他的东西帐户线程管理。我使用Observable.create()来包装HttpHandler，它的回调为Observable。此Observable表示您将消耗的传入请求（exchangeObservable.subscribe()部分）处理请求的流程。

RxJava只会更改从回调的语法来观察的模式，再加上提供了良好的运算符来对付他们：http://reactivex.io/documentation/operators.html