From 26aabc7ccf44c5692a3947db33d4cd8ddc60eff5 Mon Sep 17 00:00:00 2001
From: qi <qi_liang_gz@163.com>
Date: Mon, 16 Mar 2020 17:00:27 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=97=A5=E5=BF=97=E5=8F=98?=
 =?UTF-8?q?=E9=87=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../client/handlers/ClientChannelHandler.java | 24 ++++++++++++-------
 .../handlers/RealServerChannelHandler.java    |  8 +++----
 2 files changed, 19 insertions(+), 13 deletions(-)

diff --git a/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/ClientChannelHandler.java b/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/ClientChannelHandler.java
index f56ed86..c9e9607 100644
--- a/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/ClientChannelHandler.java
+++ b/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/ClientChannelHandler.java
@@ -26,12 +26,18 @@ import io.netty.channel.SimpleChannelInboundHandler;
  */
 public class ClientChannelHandler extends SimpleChannelInboundHandler<ProxyMessage> {
 
-    private static Logger logger = LoggerFactory.getLogger(ClientChannelHandler.class);
-
+    private static Logger LOGGER = LoggerFactory.getLogger(ClientChannelHandler.class);
+    /**
+     * 引导器
+     */
     private Bootstrap bootstrap;
-
+    /**
+     * 代理引导器
+     */
     private Bootstrap proxyBootstrap;
-
+    /**
+     * 管道状态监听
+     */
     private ChannelStatusListener channelStatusListener;
 
     public ClientChannelHandler(Bootstrap bootstrap, Bootstrap proxyBootstrap, ChannelStatusListener channelStatusListener) {
@@ -42,7 +48,7 @@ public class ClientChannelHandler extends SimpleChannelInboundHandler<ProxyMessa
 
     @Override
     protected void channelRead0(ChannelHandlerContext ctx, ProxyMessage proxyMessage) throws Exception {
-        logger.debug("recieved proxy message, type is {}", proxyMessage.getType());
+        LOGGER.debug("recieved proxy message, type is {}", proxyMessage.getType());
         switch (proxyMessage.getType()) {
             case ProxyMessage.TYPE_CONNECT:
                 handleConnectMessage(ctx, proxyMessage);
@@ -63,14 +69,14 @@ public class ClientChannelHandler extends SimpleChannelInboundHandler<ProxyMessa
         if (realServerChannel != null) {
             ByteBuf buf = ctx.alloc().buffer(proxyMessage.getData().length);
             buf.writeBytes(proxyMessage.getData());
-            logger.debug("write data to real server, {}", realServerChannel);
+            LOGGER.debug("write data to real server, {}", realServerChannel);
             realServerChannel.writeAndFlush(buf);
         }
     }
 
     private void handleDisconnectMessage(ChannelHandlerContext ctx, ProxyMessage proxyMessage) {
         Channel realServerChannel = ctx.channel().attr(Constants.NEXT_CHANNEL).get();
-        logger.debug("handleDisconnectMessage, {}", realServerChannel);
+        LOGGER.debug("handleDisconnectMessage, {}", realServerChannel);
         if (realServerChannel != null) {
             ctx.channel().attr(Constants.NEXT_CHANNEL).set(null);
             ClientChannelMannager.returnProxyChanel(ctx.channel());
@@ -92,7 +98,7 @@ public class ClientChannelHandler extends SimpleChannelInboundHandler<ProxyMessa
                 // 连接后端服务器成功
                 if (future.isSuccess()) {
                     final Channel realServerChannel = future.channel();
-                    logger.debug("connect realserver success, {}", realServerChannel);
+                    LOGGER.debug("connect realserver success, {}", realServerChannel);
 
                     realServerChannel.config().setOption(ChannelOption.AUTO_READ, false);
 
@@ -167,7 +173,7 @@ public class ClientChannelHandler extends SimpleChannelInboundHandler<ProxyMessa
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
-        logger.error("exception caught", cause);
+        LOGGER.error("exception caught", cause);
         super.exceptionCaught(ctx, cause);
     }
 
diff --git a/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/RealServerChannelHandler.java b/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/RealServerChannelHandler.java
index cb93166..47d5d8f 100755
--- a/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/RealServerChannelHandler.java
+++ b/proxy-client/src/main/java/org/fengfei/lanproxy/client/handlers/RealServerChannelHandler.java
@@ -17,7 +17,7 @@ import io.netty.channel.SimpleChannelInboundHandler;
  */
 public class RealServerChannelHandler extends SimpleChannelInboundHandler<ByteBuf> {
 
-    private static Logger logger = LoggerFactory.getLogger(RealServerChannelHandler.class);
+    private static Logger LOGGER = LoggerFactory.getLogger(RealServerChannelHandler.class);
 
     @Override
     protected void channelRead0(ChannelHandlerContext ctx, ByteBuf buf) throws Exception {
@@ -35,7 +35,7 @@ public class RealServerChannelHandler extends SimpleChannelInboundHandler<ByteBu
             proxyMessage.setUri(userId);
             proxyMessage.setData(bytes);
             channel.writeAndFlush(proxyMessage);
-            logger.debug("write data to proxy server, {}, {}", realServerChannel, channel);
+            LOGGER.debug("write data to proxy server, {}, {}", realServerChannel, channel);
         }
     }
 
@@ -51,7 +51,7 @@ public class RealServerChannelHandler extends SimpleChannelInboundHandler<ByteBu
         ClientChannelMannager.removeRealServerChannel(userId);
         Channel channel = realServerChannel.attr(Constants.NEXT_CHANNEL).get();
         if (channel != null) {
-            logger.debug("channelInactive, {}", realServerChannel);
+            LOGGER.debug("channelInactive, {}", realServerChannel);
             ProxyMessage proxyMessage = new ProxyMessage();
             proxyMessage.setType(ProxyMessage.TYPE_DISCONNECT);
             proxyMessage.setUri(userId);
@@ -74,7 +74,7 @@ public class RealServerChannelHandler extends SimpleChannelInboundHandler<ByteBu
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
-        logger.error("exception caught", cause);
+        LOGGER.error("exception caught", cause);
         super.exceptionCaught(ctx, cause);
     }
 }
\ No newline at end of file