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(); 
    } 
} 

언더우드를 사용한 안녕 세계 응용 프로그램입니다. 누군가 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. HttpHandler을 감싸기 위해 Observable.create()을 사용했으며 Observable으로 콜백했습니다. 이 Observable은 요청을 처리하기 위해 수신 할 수신 요청 (exchangeObservable.subscribe() 부분)의 흐름을 나타냅니다.

RxJava는 그들과 거래를하는 사업자의 좋은 세트를 관찰 패턴에 콜백에서 문법을 변경, 플러스 제공됩니다