添加motan支持

Author: zfvipgit

tx-client/src/main/java/com/codingapi/tx/netty/handler/TransactionHandler.java

@@ -43,15 +43,14 @@ public TransactionHandler(NettyControlService nettyControlService, int delay) {
     }
 
 
-
     @Override
     public void channelRead(final ChannelHandlerContext ctx, final Object msg) throws Exception {
 
         final String json = SocketUtils.getJson(msg);
         logger.info("接受->" + json);
 
 
-        nettyControlService.executeService(ctx,json);
+        nettyControlService.executeService(ctx, json);
     }
 
     @Override
@@ -76,9 +75,18 @@ public void channelActive(ChannelHandlerContext ctx) throws Exception {
         logger.info("建立链接-->" + ctx);
 
         nettyControlService.uploadModelInfo();
+        //通道激活后进行心跳检查
+        SocketUtils.sendMsg(ctx, heartJson);
     }
 
 
+    /**
+     * 当客户端的所有ChannelHandler中4s内没有write事件，则会触发userEventTriggered方法
+     *
+     * @param ctx
+     * @param evt
+     * @throws Exception
+     */
     @Override
     public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
         //心跳配置