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