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