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介绍。
- 提示下载完但解压或打开不了?
- 找不到素材资源介绍文章里的示例图片?
- 一个高级程序员模板开发平台