消息执行器

Author: Peng Hu

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

@@ -46,8 +46,7 @@
 /**
  * 
  * 从grizzly的 FutureImpl精简而来. </br>
- * 
- * 详情查看 {@link org.glassfish.grizzly.impl.SafeFutureImpl} .
+ *
  * <p/>
  * (Based on the JDK {@link java.util.concurrent.FutureTask})
  *

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

@@ -1,17 +1,17 @@
 package info.xiaomo.gengine.network.handler;
 
+import com.google.protobuf.AbstractMessage;
 import info.xiaomo.gengine.network.INetworkConsumer;
 import info.xiaomo.gengine.network.INetworkEventListener;
-import io.netty.channel.ChannelHandlerAdapter;
 import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
 
 /**
  * @author xiaomo
- * :todo
  */
-public class MessageExecutor extends ChannelHandlerAdapter {
+public class MessageExecutor extends SimpleChannelInboundHandler<Object> {
 
-    private INetworkConsumer consumer;
+    private final INetworkConsumer consumer;
 
     private final INetworkEventListener listener;
 
@@ -22,23 +22,23 @@ public MessageExecutor(INetworkConsumer consumer, INetworkEventListener listener
     }
 
 
-
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
         listener.onExceptionOccur(ctx, cause);
     }
 
-//    @Override
-//    public void channelRead(ChannelHandlerContext ctx, Object msg) {
-//        consumer.consume((AbstractMessage) msg, ctx.channel());
-//    }
-//    @Override
-//    public void channelActive(ChannelHandlerContext ctx) {
-//        this.listener.onConnected(ctx);
-//    }
-//
-//    @Override
-//    public void channelInactive(ChannelHandlerContext ctx) {
-//        this.listener.onDisconnected(ctx);
-//    }
+    @Override
+    public void channelRead0(ChannelHandlerContext ctx, Object msg) {
+        consumer.consume((AbstractMessage) msg, ctx.channel());
+    }
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) {
+        this.listener.onConnected(ctx);
+    }
+
+    @Override
+    public void channelInactive(ChannelHandlerContext ctx) {
+        this.listener.onDisconnected(ctx);
+    }
 }