终端重启，执行jenkins-update.bat脚本（需要修改不必要的命令）

collector-terminal-management/src/main/java/com/docus/server/common/netty/client/NettyClient.java

@@ -1,6 +1,5 @@
 package com.docus.server.common.netty.client;
 
-import com.docus.core.util.json.JSON;
 import com.docus.server.common.CommMsg;
 import com.docus.server.common.netty.event.StartUpEvent;
 import com.docus.server.common.netty.server.CollectorChannelCacheMap;
@@ -37,6 +36,9 @@ public class NettyClient {
     @Value("${spring.application.name}")
     private String appName;
 
+    @Value("${docus.terminal-restart-bat}")
+    private String terminalRestartBat;
+
     private SocketChannel socketChannel;
 
     @Resource
@@ -57,7 +59,7 @@ public class NettyClient {
      * @param message 消息内容
      */
     public void sendMessage(CommMsg message) {
-        boolean success = socketChannel.writeAndFlush(JSON.toJSON(message)).isSuccess();
+        boolean success = socketChannel.writeAndFlush(message).isSuccess();
         if (success) {
             log.info("发送消息成功");
         }
@@ -106,4 +108,12 @@ public class NettyClient {
     public String getSaveCollectorPackagePath() {
         return saveCollectorPackagePath;
     }
+
+    public String getAppName() {
+        return this.appName;
+    }
+
+    public String getTerminalRestartBat() {
+        return this.terminalRestartBat;
+    }
 }

collector-terminal-management/src/main/java/com/docus/server/common/netty/client/handler/ClientHandler.java

@@ -194,9 +194,17 @@ public class ClientHandler extends SimpleChannelInboundHandler<CommMsg<Serializa
         }
     }
 
-    private void terminatorRestart(String messageContent) {
+    private void terminatorRestart(String messageContent) throws Exception {
         log.info("【终端客户端-收到调度器消息】接受到终端重启命令，内容={}", messageContent);
+        String result = StartUpExeUtils.restartTerminal(nettyClient.getTerminalRestartBat());
 
+        CommMsg<Serializable> terminatorRestartMsg = CommMsg.builder()
+            .content(result)
+            .messageTime(DateUtil.formatDateTime(new Date()))
+            .messageType(TERMINATOR_RESTART)
+            .build();
+
+        nettyClient.sendMessage(terminatorRestartMsg);
     }
 
     @Override

collector-terminal-management/src/main/java/com/docus/server/common/utils/StartUpExeUtils.java

@@ -6,19 +6,29 @@ import java.io.InputStreamReader;
 
 public class StartUpExeUtils {
 
-    public static void main(String[] args) throws IOException {
+    public static void main(String[] args) throws Exception {
 //        startUpExeOnly("H:\\tools\\Navicat Premium 12免安装\\Navicat Premium 12\\navicat.exe");
 //        killExeOnly("navicat.exe");
 
 //        startUpExe("H:\\tools\\Navicat Premium 12免安装\\Navicat Premium 12\\navicat.exe", "navicat.exe");
-        restartComputer();
+        restartTerminal("");
     }
 
     private static boolean startExeStatus = true;//exe启动状态
 
     //重启终端
-    public static void restartTerminal() throws IOException {
-        Runtime.getRuntime().exec("D:\\webroot\\collector-terminal-management\\jenkins-update.bat d:\\webroot");
+    public static String restartTerminal(String bat) throws IOException, InterruptedException {
+        Process process = Runtime.getRuntime().exec(bat);
+
+        int exitCode = process.waitFor();
+
+        if (exitCode == 0) {
+            System.out.println("Command executed successfully.");
+            return "Command executed successfully.";
+        } else {
+            System.out.println("Command execution failed.");
+            return "Command executed failed.";
+        }
     }
 
     //重启虚拟机

collector-terminal-management/src/main/resources/bootstrap.yml

@@ -72,4 +72,5 @@ file:
 docus:
   vm-task-cron: 0/30 * * * * ?
   collector-package-download-url: http://192.168.16.110:9113
-  collector-package-download-savePath: H:\\packages\\
+  collector-package-download-savePath: H:\\packages\\
+  terminal-restart-bat: cmd /c start  D:\webroot\collector-scheduling-management\jenkins-update.bat d:\webroot