.

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>cn.cloudowr</groupId>
     <artifactId>sdk</artifactId>
-    <version>1.4.12</version>
+    <version>1.4.13</version>
     <build>
         <plugins>
             <plugin>

src/main/java/cn/cloudowr/sdk/log/BaseAbsAioHandler.java

@@ -9,6 +9,7 @@ import com.talent.aio.common.exception.AioDecodeException;
 import com.talent.aio.common.intf.AioHandler;
 
 import java.nio.ByteBuffer;
+import java.util.Arrays;
 
 /**
  * Created by lyf66 on 2017/3/24.
@@ -62,6 +63,12 @@ public abstract class BaseAbsAioHandler implements AioHandler<Object, Message, O
             packet = switchMessage(byteBuffer, type, bodyLen, packet);
             if (packet == null) {
                 System.out.println("packet is not recognized, remote:" + channelContext.getClientNode());
+                byte[] dst = new byte[bodyLen];
+                byteBuffer.get(dst);
+                if (dst.length > 0) {
+                    System.out.println(new String(dst));
+                    System.out.println();
+                }
             }
             return packet;
         }

src/main/java/cn/cloudowr/sdk/log/server/LoggerServer.java

@@ -18,7 +18,27 @@ public class LoggerServer {
     private ServerGroupContext<Object, Message, Object> serverGroupContext = null;
     private AioServer<Object, Message, Object> aioServer = null; //可以为空
     private ServerAioHandler<Object, Message, Object> aioHandler = null;
-    private ServerAioListener<Object, Message, Object> aioListener = null;
+    private ServerAioListener<Object, Message, Object> aioListener = new ServerAioListener<Object, Message, Object>() {
+        @Override
+        public void onAfterConnected(ChannelContext<Object, Message, Object> channelContext, boolean isConnected, boolean isReconnect) throws Exception {
+            System.out.println("client connected");
+        }
+
+        @Override
+        public void onAfterSent(ChannelContext<Object, Message, Object> channelContext, Message packet, boolean isSentSuccess) throws Exception {
+            System.out.println("sent msg to client");
+        }
+
+        @Override
+        public void onAfterReceived(ChannelContext<Object, Message, Object> channelContext, Message packet, int packetSize) throws Exception {
+            System.out.println("received msg from client");
+        }
+
+        @Override
+        public void onAfterClose(ChannelContext<Object, Message, Object> channelContext, Throwable throwable, String remark, boolean isRemove) throws Exception {
+            System.out.println("client connection closed");
+        }
+    };
     private static HandlerChain chain;
 
     public static HandlerChain getChain() {