删除简单日志

Author: Peng Hu

pom.xml

@@ -126,11 +126,6 @@
             <artifactId>slf4j-api</artifactId>
             <version>1.7.30</version>
         </dependency>
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-simple</artifactId>
-            <version>1.7.30</version>
-        </dependency>
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>

src/main/java/info/xiaomo/gengine/network/INetworkEventListener.java

@@ -29,4 +29,6 @@ public interface INetworkEventListener {
      */
     void onExceptionOccur(ChannelHandlerContext ctx, Throwable cause);
 
+    void idle(ChannelHandlerContext ctx, Object evt);
+
 }

src/main/java/info/xiaomo/gengine/network/client/ClientMessageExecutor.java

@@ -25,32 +25,32 @@ public ClientMessageExecutor(INetworkConsumer consumer, INetworkEventListener li
         this.futureMap = futureMap;
     }
 
-//    @Override
-//    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-//
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+
 //        AbstractMessage m = (AbstractMessage) msg;
 //        ClientFuture<AbstractMessage> f = futureMap.get(m.getSequence());
 //        if (f != null) {
 //            if (!f.isCancelled()) {
 //                f.result(m);
 //            }
 //        } else {
-//            super.channelRead(ctx, msg);
-//        }
-//
-//    }
-//
-//    @Override
-//    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
-//
-//        if(this.isIdleCheck() && evt instanceof IdleStateEvent) {
-//            IdleStateEvent idleStateEvent = (IdleStateEvent) evt;
-//            IdleState state = idleStateEvent.state();
-//            if(state == IdleState.READER_IDLE) {
-//                this.listener.idle(ctx, state);
-//            }
-//        } else {
-//            super.userEventTriggered(ctx, evt);
+            super.channelRead(ctx, msg);
 //        }
-//    }
+
+    }
+
+    @Override
+    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
+
+        if ( evt instanceof IdleStateEvent) {
+            IdleStateEvent idleStateEvent = (IdleStateEvent) evt;
+            IdleState state = idleStateEvent.state();
+            if (state == IdleState.READER_IDLE) {
+                this.listener.idle(ctx, state);
+            }
+        } else {
+            super.userEventTriggered(ctx, evt);
+        }
+    }
 }

src/main/java/info/xiaomo/gengine/network/client/NetworkEventListenerAdapter.java

@@ -26,4 +26,9 @@ public void onDisconnected(ChannelHandlerContext ctx) {
     public void onExceptionOccur(ChannelHandlerContext ctx, Throwable cause) {
 
     }
+
+    @Override
+    public void idle(ChannelHandlerContext ctx, Object evt) {
+
+    }
 }

src/main/java/info/xiaomo/gengine/network/handler/MessageExecutor.java

@@ -13,7 +13,7 @@ public class MessageExecutor extends SimpleChannelInboundHandler<Object> {
 
     private final INetworkConsumer consumer;
 
-    private final INetworkEventListener listener;
+    protected final INetworkEventListener listener;
 
 
     public MessageExecutor(INetworkConsumer consumer, INetworkEventListener listener) {