防止重复数据 入队列

src/main/java/com/cn/esermis/EsermisApplication.java

@@ -26,8 +26,8 @@ public class EsermisApplication  implements CommandLineRunner {
         /**
          * 使用异步注解方式启动netty服务端服务
          */
-        new BootNettyServer().bind(19900);
-//        new BootNettyServer().bind(8088);
+//        new BootNettyServer().bind(19900);
+        new BootNettyServer().bind(8088);
     }
 
 }

src/main/java/com/cn/esermis/netty/BootNettyChannelInboundHandlerAdapter.java

@@ -81,8 +81,8 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
 //            if (message.contains(Constant.MINUTE_STR) || message.contains(Constant.HOUR_STR)) {
                 log.info("=============" + (new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date()) + "=============");
                 log.info("收到数据：" + message);
-                String reply = HJ212MsgUtils.reply(message);
-                ctx.writeAndFlush(reply);
+//                String reply = HJ212MsgUtils.reply(message);
+//                ctx.writeAndFlush(reply);
 //            }
             if (message.contains("&&")) {
                 String[] split = message.split("&&");