From c32ab53c7e343447ada078b443315e349c1590a8 Mon Sep 17 00:00:00 2001
From: lyf666 <lyf666@gmail.com>
Date: Sun, 26 Mar 2017 22:10:12 +0800
Subject: [PATCH] .

---
 pom.xml                                       |  2 +-
 .../cloudowr/sdk/log/BaseAbsAioHandler.java   |  7 ++++++
 .../cloudowr/sdk/log/server/LoggerServer.java | 22 ++++++++++++++++++-
 3 files changed, 29 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 7c8006f..a78daa6 100644
--- a/pom.xml
+++ b/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>
diff --git a/src/main/java/cn/cloudowr/sdk/log/BaseAbsAioHandler.java b/src/main/java/cn/cloudowr/sdk/log/BaseAbsAioHandler.java
index 93c31d6..1b0b4e6 100644
--- a/src/main/java/cn/cloudowr/sdk/log/BaseAbsAioHandler.java
+++ b/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;
         }
diff --git a/src/main/java/cn/cloudowr/sdk/log/server/LoggerServer.java b/src/main/java/cn/cloudowr/sdk/log/server/LoggerServer.java
index cfc5d16..07ab17e 100644
--- a/src/main/java/cn/cloudowr/sdk/log/server/LoggerServer.java
+++ b/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() {