调整下格式

hiram · hiram · commit 2f9748ff3ac8 · 2020-11-02T15:40:44.000+08:00
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java
@@ -20,11 +20,11 @@ public class HttpInboundServer {
     private static Logger logger = LoggerFactory.getLogger(HttpInboundServer.class);
 
     private int port;
-    
+
     private List<String> proxyServerList;
 
     public HttpInboundServer(int port, List<String> proxyServerList) {
-        this.port=port;
+        this.port = port;
         this.proxyServerList = proxyServerList;
     }
 
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
@@ -30,7 +30,7 @@ public void connect(FullHttpRequest fullHttpRequest, ChannelHandlerContext ctx)
             b.group(workerGroup);
             b.channel(NioSocketChannel.class);
             b.option(ChannelOption.SO_KEEPALIVE, true)
-            .option(ChannelOption.SO_RCVBUF, 32 * 1024);
+                    .option(ChannelOption.SO_RCVBUF, 32 * 1024);
             b.handler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpOutboundHandler.java
@@ -20,11 +20,13 @@ public class NettyHttpOutboundHandler extends ChannelInboundHandlerAdapter {
     private int contentLength = 0;
     private FullHttpRequest fullHttpRequest = null;
     private String backendUrl;
+
     public NettyHttpOutboundHandler(ChannelHandlerContext ctx, FullHttpRequest fullHttpRequest, String backendUrl) {
         this.parentCtx = ctx;
         this.fullHttpRequest = fullHttpRequest;
         this.backendUrl = backendUrl;
     }
+
     @Override
     public void channelActive(ChannelHandlerContext ctx)
             throws Exception {
@@ -40,15 +42,15 @@ public void channelActive(ChannelHandlerContext ctx)
        /*DefaultFullHttpRequest request = new DefaultFullHttpRequest(
                 HttpVersion.HTTP_1_1, HttpMethod.GET, new URI("/").toASCIIString());*/
 
-       // &#26500;&#24314;http&#35831;&#27714;
-            request.headers().set(HttpHeaderNames.HOST, host);
-            request.headers().set(HttpHeaderNames.CONNECTION,
-                    HttpHeaderNames.CONNECTION);
-            request.headers().set(HttpHeaderNames.CONTENT_LENGTH,
-                    request.content().readableBytes());
+        // &#26500;&#24314;http&#35831;&#27714;
+        request.headers().set(HttpHeaderNames.HOST, host);
+        request.headers().set(HttpHeaderNames.CONNECTION,
+                HttpHeaderNames.CONNECTION);
+        request.headers().set(HttpHeaderNames.CONTENT_LENGTH,
+                request.content().readableBytes());
         ctx.writeAndFlush(request);
     }
-    
+
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg)
             throws Exception {
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/router/MyFirstHttpEndpointRouter.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/router/MyFirstHttpEndpointRouter.java
@@ -7,7 +7,7 @@
 import java.util.List;
 import java.util.Random;
 
-public class MyFirstHttpEndpointRouter implements HttpEndpointRouter{
+public class MyFirstHttpEndpointRouter implements HttpEndpointRouter {
 
     @Override
     public String route(List<String> endpoints) {
