Project Reactor Netty Hello World

package help.lixin.examples;

import java.util.concurrent.CountDownLatch;

import org.junit.Test;

import reactor.core.publisher.Mono;
import reactor.ipc.netty.http.server.HttpServer;
import reactor.ipc.netty.tcp.BlockingNettyContext;

public class ReactorNettyTest {

	@Test
	public void tetsHello() {
		BlockingNettyContext facade = // 创建HttpServer并配置路由
                HttpServer.create(8080).startRouter(routes -> {
                    routes.get("/hello", (req, resp) -> resp.sendString(Mono.just("hello!")));
                    routes.get("/world", (req, resp) -> resp.sendString(Mono.just("world!")));
                });
              
		CountDownLatch latch = new CountDownLatch(1);
		try {
			latch.await();
		} catch (InterruptedException ignore) {
		}
	}
}