最新公告
  • 欢迎您光临码巴巴,本站秉承服务宗旨 履行“站长”责任,销售只是起点 服务永无止境!立即加入我们
  • java springboot 监听程序是否运行,并重启

    1.就在刚刚,接到一个需要长轮训一直监听项目,但在项目运行期间,因为硬件设备会出现程序跑着跑着不在运行的情况。

    2,提出以下解决方案。新建守护线程,去监听主线程的代码有没有在运行,如果没有运行,则通过重启释放资源。

    3.代码如下:

    package com.ruoyi.web.core.damtest;
    
    import lombok.Data;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.core.annotation.Order;
    import org.springframework.stereotype.Component;
    
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    /**
     * 打印机控制
     */
    
    /**
     * DAM-0020TA控制
     */
    @Component
    @Data
    @Order(2)
    public  class PrinterControl2 implements CommandLineRunner {
    
        private static final Logger LOGGER = LoggerFactory.getLogger(PrinterControl2.class);
    
        public static long LISTENNER_SLEEP_TIME = 300;
    
        public static String IP = "127.0.0.1";
    
    
        // 上次检查的时间
        private volatile long lastCheckTimestamp = System.currentTimeMillis();
    
    
        // 设置应用假死的阈值,例如1分钟
        private static final long APP_UNHEALTHY_THRESHOLD = 1 * 60 * 1000;
    
    
    
    
    
    
        /**
         * 计时器核心驱动代码
         */
        public void core(){
            try{
                /**
                 * 设置定时器
                 */
                ScheduledExecutorService scheduledThreadPoolExecutor= Executors.newScheduledThreadPool(1);
                scheduledThreadPoolExecutor.scheduleAtFixedRate(new Runnable() {
                    @Override
                    public void run() {
    
                        listenerPLC();
                    }
                }, 0,LISTENNER_SLEEP_TIME , TimeUnit.MILLISECONDS);
            }catch (Exception e){
                e.printStackTrace();
                    LOGGER.error("PLC初始化异常");
            }
    
        }
    
    
    
        /**
         * 守护线程
         */
        public void deamonThread(){
            try{
                ScheduledExecutorService scheduledThreadPoolExecutor= Executors.newScheduledThreadPool(1);
                scheduledThreadPoolExecutor.scheduleAtFixedRate(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            long currentTimestamp = System.currentTimeMillis();
                            boolean isRestart = currentTimestamp - lastCheckTimestamp > APP_UNHEALTHY_THRESHOLD;
                            LOGGER.info("守护线程出判断线程是否掉线:{}",isRestart);
                            if (isRestart) {
                                restartApplication();
                            }
                        }catch (Exception e){
                            LOGGER.error("守护线程出现异常,异常信息为:{}",e.getMessage());
                        }
                    }
                }, 0,LISTENNER_SLEEP_TIME , TimeUnit.MILLISECONDS);
            }catch (Exception e){
                    LOGGER.error("守护线程定时器出现异常,异常信息为:{}",e.getMessage());
                    e.printStackTrace();
            }
    
        }
    
    
    
    
        /**
         * 主线程执行逻辑
         * @throws Exception
         * @auther liukx
         */
        public void listenerPLC() {
    
    
    
        }
    
    
        /**
         * 通过执行shell 脚本重启服务,shell 可查看另一篇文章
         */
        private void restartApplication() {
            // 这里可以调用Spring Boot的重启接口或者使用命令行重启
            LOGGER.info("系统正在重启。。。");
            //SpringApplication.exit(SpringApplication.run(RuoYiApplication.class, new String[0]));
            try{
                 Process process = Runtime.getRuntime().exec("sh /home/lenovo/bg/bg_startup.sh");
                int exitCode = process.waitFor();
                LOGGER.info("Shell脚本执行完毕,退出码为:" + exitCode);
            }catch (Exception e){
                 LOGGER.info("程序在重启是发生异常,异常信息为:{}",e.getMessage());
                 e.printStackTrace();
            }
    
        }
    
    
    
        /**
         * 通过springboot CommandLineRunner让程序在初始化时,执行下面两个线程
         * @param args
         * @throws Exception
         */
        @Override
        public void run(String... args) throws Exception {
            deamonThread();
            core();
    
        }
    }
    
    

    4.重启java进程 shell 脚本传送门:http://www.mababa.xin/2024/05/05/938.html

     

    1. 本站所有资源来源于用户上传和网络,如有侵权请及时联系站长!

    2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!

    3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!

    4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!

    5. 如有链接无法下载、失效或广告,请联系管理员处理!

    6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需!

    7. 如遇到加密压缩包,默认解压密码为"mababa.xin",如遇到无法解压的请联系管理员!


    码巴巴-优质代码创造者 » java springboot 监听程序是否运行,并重启

    常见问题FAQ

    免费下载或者VIP会员专享资源能否直接商用?
    本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用者承担。更多说明请参考 VIP介绍。
    提示下载完但解压或打开不了?
    最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度网盘软件或迅雷下载。若排除这种情况,可在对应资源底部留言,或 联络我们.。
    找不到素材资源介绍文章里的示例图片?
    对于PPT,KEY,Mockups,APP,网页模版等类型的素材,文章内用于介绍的图片通常并不包含在对应可供下载素材包内。这些相关商业图片需另外购买,且本站不负责(也没有办法)找到出处。 同样地一些字体文件也是这种情况,但部分素材会在素材包内有一份字体下载链接清单。
    一个高级程序员模板开发平台
    问问管理员?

    发表评论

    • 44会员总数(位)
    • 95资源总数(个)
    • 0本周发布(个)
    • 0 今日发布(个)
    • 1511稳定运行(天)

    提供最优质的资源集合

    立即查看 了解详情
    升级SVIP尊享更多特权立即升级