update

Author: kimmking

02nio/nio01/src/main/java/java0/nio01/HttpServer01.java

@@ -25,7 +25,7 @@ private static void service(Socket socket) {
             PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);
             printWriter.println("HTTP/1.1 200 OK");
             printWriter.println("Content-Type:text/html;charset=utf-8");
-            String body = "hello,nio";
+            String body = "hello,nio1";
             printWriter.println("Content-Length:" + body.getBytes().length);
             printWriter.println();
             printWriter.write(body);

02nio/nio01/src/main/java/java0/nio01/HttpServer02.java

@@ -27,7 +27,7 @@ private static void service(Socket socket) {
             PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);
             printWriter.println("HTTP/1.1 200 OK");
             printWriter.println("Content-Type:text/html;charset=utf-8");
-            String body = "hello,nio";
+            String body = "hello,nio2";
             printWriter.println("Content-Length:" + body.getBytes().length);
             printWriter.println();
             printWriter.write(body);

02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundInitializer.java

@@ -28,11 +28,7 @@ public void initChannel(SocketChannel ch) {
 		p.addLast(new HttpServerCodec());
 		//p.addLast(new HttpServerExpectContinueHandler());
 		p.addLast(new HttpObjectAggregator(1024 * 1024));
-		p.addLast(new HttpInboundHandler(this.proxyServer, new HttpRequestFilter() {
-			@Override
-			public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
-				fullRequest.headers().set("mao", "soul");
-			}
-		}));
+		p.addLast(new HttpInboundHandler(this.proxyServer,
+				(fullRequest, ctx) -> fullRequest.headers().set("mao", "soul")));
 	}
 }

02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java

@@ -17,7 +17,6 @@
 
 
 public class HttpInboundServer {
-    private static Logger logger = LoggerFactory.getLogger(HttpInboundServer.class);
 
     private int port;
 
@@ -49,7 +48,7 @@ public void run() throws Exception {
                     .handler(new LoggingHandler(LogLevel.INFO)).childHandler(new HttpInboundInitializer(this.proxyServers));
 
             Channel ch = b.bind(port).sync().channel();
-            logger.info("开启netty http服务器，监听地址和端口为 http://127.0.0.1:" + port + '/');
+            System.out.println("开启netty http服务器，监听地址和端口为 http://127.0.0.1:" + port + '/');
             ch.closeFuture().sync();
         } finally {
             bossGroup.shutdownGracefully();