格式并加些打印

license/src/main/java/iot/sixiang/license/forward/ForwardClientHandler.java

@@ -28,14 +28,12 @@ public class ForwardClientHandler extends SimpleChannelInboundHandler<Object> {
     }
 
     @Override
-    protected void channelRead0(ChannelHandlerContext ctx, Object msg){
-
-        // TODO Auto-generated method stub
-        // TODO 中转客户端收到消息后，将消息原封不动的发送给设备客户端
+    protected void channelRead0(ChannelHandlerContext ctx, Object msg) {
+        // 中转客户端收到消息后，将消息原封不动的发送给设备客户端
         SocketChannel channel = (SocketChannel) ctx.channel();
         InetSocketAddress socketAddr = (InetSocketAddress) ctx.channel().remoteAddress();
-        String serverIp = socketAddr.getHostString();
-        int serverPort = socketAddr.getPort();
+        //String serverIp = socketAddr.getHostString();
+        //int serverPort = socketAddr.getPort();
         DeviceProtocol protocol = (DeviceProtocol) msg;
         String channelId = channel.id().asLongText();
         log.debug("桥接客户端，channelRead0:{},{}", channelId, HexUtil.bytes2hex(protocol.getContent()));
@@ -45,27 +43,23 @@ public class ForwardClientHandler extends SimpleChannelInboundHandler<Object> {
         forwardMessageResponseEvent.setChannel(channel);
         forwardMessageResponseEvent.setProtocol(protocol);
         eventPublisher.publishEvent(forwardMessageResponseEvent);
-
     }
 
 
     @Override
     public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
-        // TODO Auto-generated method stub
         super.channelRegistered(ctx);
         log.debug("桥接客户端，channelRegistered:{}", ctx.channel().id().asLongText());
     }
 
     @Override
     public synchronized void channelActive(ChannelHandlerContext ctx) throws Exception {
-        // TODO Auto-generated method stub
         super.channelActive(ctx);
         log.debug("桥接客户端，channelActive:{}", ctx.channel().id().asLongText());
     }
 
     @Override
     public void channelInactive(ChannelHandlerContext ctx) throws Exception {
-        // TODO Auto-generated method stub
         super.channelInactive(ctx);
         SocketChannel channel = (SocketChannel) ctx.channel();
         String channelId = channel.id().asLongText();
@@ -79,14 +73,12 @@ public class ForwardClientHandler extends SimpleChannelInboundHandler<Object> {
 
     @Override
     public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
-        // TODO Auto-generated method stub
         super.channelReadComplete(ctx);
         log.debug("桥接客户端，channelReadComplete:{}", ctx.channel().id().asLongText());
     }
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
-        // TODO Auto-generated method stub
         super.exceptionCaught(ctx, cause);
         log.debug("桥接客户端，exceptionCaught:{}", ctx.channel().id().asLongText());
         ctx.close();
@@ -97,5 +89,4 @@ public class ForwardClientHandler extends SimpleChannelInboundHandler<Object> {
     public synchronized void userEventTriggered(ChannelHandlerContext ctx, Object obj) {
         log.debug("桥接客户端，userEventTriggered:{}", ctx.channel().id().asLongText());
     }
-
 }