From 6b828ba1310db528aa8172bd14a0253ebca5a844 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期二, 10 六月 2025 18:34:29 +0800
Subject: [PATCH] 基于mqtt的水肥机、气象站、墒情站协议、功能模块继续开发
---
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/ServerShutDownHook.java | 16 +++++++++++-----
1 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/ServerShutDownHook.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/ServerShutDownHook.java
index 9f945ae..5171b77 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/ServerShutDownHook.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/ServerShutDownHook.java
@@ -20,13 +20,19 @@
try{
// 纭繚杩欐浠ｇ爜灏藉彲鑳藉揩閫熸墽琛岋紝閬垮厤褰卞搷JVM鐨勫叧闂�
log.info("绋嬪簭锛堟帶鍒跺彴锛夊叧闂挬瀛愮被鎵ц");
- Command com = new Command() ;
- com.id = Command.defaultId ;
- com.code = CodeLocal.stopTcpSv ;
- com.type = CommandType.innerCommand ;
- new CommandInnerDeaLer().deal(com) ;
+ Command com1 = new Command() ;
+ com1.id = Command.defaultId ;
+ com1.code = CodeLocal.stopTcpSv ;
+ com1.type = CommandType.innerCommand ;
+ new CommandInnerDeaLer().deal(com1) ;
//Thread.sleep(100L);//瀹炴祴涓嶆墽琛�
log.info("鍏抽棴绋嬪簭鍓嶏紝鍏抽棴浜員CP鏈嶅姟");
+ Command com2 = new Command() ;
+ com2.id = Command.defaultId ;
+ com2.code = CodeLocal.stopMqttSv ;
+ com2.type = CommandType.innerCommand ;
+ new CommandInnerDeaLer().deal(com2) ;
+
}catch (Exception e){
log.error("绋嬪簭锛堟帶鍒跺彴锛夊叧闂挬瀛愬彂鐢熷紓甯�", e);
}
--
Gitblit v1.8.0