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

@@ -80,6 +80,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);
             }
             if (message.contains("&&")) {
                 String[] split = message.split("&&");

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

@@ -14,11 +14,11 @@ import java.util.concurrent.TimeUnit;
 public class BootNettyChannelInitializer<SocketChannel>extends ChannelInitializer<Channel> {
 
     //注意超时时间，这里配置，最好设置长点，要不代码 会自动关连接。这里是60秒
-    public static long READ_TIME_OUT = 60;
+    public static long READ_TIME_OUT = 60*30;
 
-    public static long WRITE_TIME_OUT = 60;
+    public static long WRITE_TIME_OUT = 60*30;
 
-    public static long ALL_TIME_OUT = 60;
+    public static long ALL_TIME_OUT = 60*30;
 
     @Override
     protected void initChannel(Channel ch) throws Exception {

src/main/java/com/cn/esermis/server/Consumer.java

@@ -38,7 +38,10 @@ public class Consumer {
             Object message = redisQueueService.receiveMessage(Constant.SERVER);
             if (message==null || message.equals("")){
 //                System.out.println("消息队列为空");
-                Thread.sleep(1000*5);
+                try {
+                    Thread.sleep(1000*5);
+                } catch (InterruptedException e) {
+                }
             }else{
                 tolot++;
                 int finalTolot = tolot;