增量开发MQTT协议、功能模块，上下行命令（消息）等

liurunyu

2 天以前 f8b2e59a82702a790c383a8ecd90c708c76e2488

 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("关闭程序前，关闭了TCP服务");
                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);
            }