修改bug

liurunyu

2025-08-06 c6ef837cf5882b050d2e38a77d7a1531a882328b

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/ServerShutDownHook.java

New file
@@ -0,0 +1,42 @@
package com.dy.rtuMw;

import com.dy.common.mw.protocol.Command;
import com.dy.common.mw.protocol.CommandType;
import com.dy.rtuMw.server.local.CommandInnerDeaLer;
import com.dy.rtuMw.server.local.localProtocol.CodeLocal;
import lombok.extern.slf4j.Slf4j;

/**
 * @Author: liurunyu
 * @Date: 2024/8/6 9:51
 * @Description 程序（控制台）关闭处理钩子类
 */
@Slf4j
public class ServerShutDownHook {
    public static void OnShutDown(){
        Runtime.getRuntime().addShutdownHook(new Thread(){
            @Override
            public void run(){
            try{
                // 确保这段代码尽可能快速执行，避免影响JVM的关闭
                log.info("程序（控制台）关闭钩子类执行");
                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("关闭程序前，关闭了TCP服务");
                Command com2 = new Command() ;
                com2.id = Command.defaultId ;
                com2.code = CodeLocal.stopMqttSv ;
                com2.type = CommandType.innerCommand ;
                new CommandInnerDeaLer().deal(com2) ;
                log.info("关闭程序前，关闭了MQTT服务");
            }catch (Exception e){
                log.error("程序（控制台）关闭钩子发生异常", e);
            }
            }
        });
    }
}