更新定时发送

src/main/java/com/persagy/job/SpringSchedule.java

@@ -38,6 +38,15 @@ public class SpringSchedule {
         nettyClient.sendMessage(message);
     }
 
+    @Scheduled(initialDelay = 2000, fixedDelay = 60000)
+    public void connectCron() {
+        if (Objects.isNull(NettyClient.channel)) {
+            log.warn("NettyClient is not init");
+            return;
+        }
+        NettyMessage message = new NettyMessage(3);
+        nettyClient.sendMessageNotCheck(message);
+    }
 
     @Scheduled(initialDelay = 1000, fixedDelay = 600000)
     public void connectAnalizeCron() {
@@ -45,12 +54,6 @@ public class SpringSchedule {
             log.warn("NettyClient is not init");
             return;
         }
-        try {
-            NettyMessage message = new NettyMessage(3);
-            nettyClient.sendMessage(message);
-        } catch (Exception e) {
-            log.error(e.getMessage(),e);
-        }
         log.info("NettyClient State:isActive[{}],isOpen[{}],isRegistered[{}],isWritable[{}]", NettyClient.channel.isActive(), NettyClient.channel.isOpen(), NettyClient.channel.isRegistered(), NettyClient.channel.isWritable());
         sengAlarmMessage();
     }

src/main/java/com/persagy/netty/client/NettyClient.java

@@ -74,4 +74,12 @@ public class NettyClient {
         }
     }
 
+    public void sendMessageNotCheck(NettyMessage msg){
+        try {
+            channel.writeAndFlush(JSONObject.parseObject(msg.toString(), NettyMessage.class));
+        } catch (Exception e) {
+            log.error(e.getMessage(),e);
+        }
+    }
+
 }