对input的接收模块进行了处理。

huimv-eartag2-platform/huimv-eartag2-input/src/main/java/com/huimv/eartag2/server/EartagServerHandler2.java

@@ -65,21 +65,27 @@ public class EartagServerHandler2 extends ChannelInboundHandlerAdapter {
         ByteBuf data = (ByteBuf) msg;
         String clientAskText = data.toString(CharsetUtil.UTF_8);
 //        System.out.println((++num)+"次, 客户端消息clientAskText>>"+clientAskText);
+        System.out.println("############################### 客户端消-接收消息 clientAskText>>"+clientAskText);
         //保存实例内的客户端请求
-        appendClientAsk(clientAskText);
+//        appendClientAsk(clientAskText);
+
+        // 处理客户端消息
+        handleClientEartagMessage(clientAskText, ctx);
+
         //临时写入耳标数据到文件
 //        writeTxt(clientAskText,"all");
     }
 
     @Override
     public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
-        if (askTextSb.toString().indexOf("end") != -1) {
-            // 处理客户端消息
-            handleClientEartagMessage(askTextSb.toString(), ctx);
-            //清空重置;
-            askTextSb.delete(0, askTextSb.length());
-            num = 0;
-        }
+//        if (askTextSb.toString().indexOf("end") != -1) {
+//            // 处理客户端消息
+//            handleClientEartagMessage(askTextSb.toString(), ctx);
+//            //清空重置;
+////            askTextSb.delete(0, askTextSb.length());
+//            askTextSb = new StringBuilder();
+//            num = 0;
+//        }
     }
 
     @Override