java-Runtime钩子回调
程序员文章站
2022-04-04 09:12:37
...
----------~开篇分享一句话:【纸上得来终觉浅,绝知此事要躬行】~---------------------------------------
在线上Java程序中经常遇到进程程挂掉,一些状态没有正确的保存下来,这时候就需要在JVM关掉的时候执行一些清理现场的代码。Java中得ShutdownHook提供了比较好的方案。
JDK在1.3之后提供了Java Runtime.addShutdownHook(Thread hook)方法,可以注册一个JVM关闭的钩子,这个钩子可以在以下几种场景被调用:
1)程序正常退出
2)使用System.exit()
3)终端使用Ctrl+C触发的中断
4)系统关闭
比如 ExecutorService的shutdown 方法,在关闭tomcat或者jvm退出时调用,能保证已经提交的任务得以执行,如果不调用,那么可能直接退出,导致已经提交的任务也无法执行。
下面这个case说明了钩子使用的场景
在线上Java程序中经常遇到进程程挂掉,一些状态没有正确的保存下来,这时候就需要在JVM关掉的时候执行一些清理现场的代码。Java中得ShutdownHook提供了比较好的方案。
JDK在1.3之后提供了Java Runtime.addShutdownHook(Thread hook)方法,可以注册一个JVM关闭的钩子,这个钩子可以在以下几种场景被调用:
1)程序正常退出
2)使用System.exit()
3)终端使用Ctrl+C触发的中断
4)系统关闭
比如 ExecutorService的shutdown 方法,在关闭tomcat或者jvm退出时调用,能保证已经提交的任务得以执行,如果不调用,那么可能直接退出,导致已经提交的任务也无法执行。
下面这个case说明了钩子使用的场景
public class TaskUtil { private static Logger logger = LoggerFactory.getLogger(TaskUtil.class.getName()); private static ScheduledExecutorService service = Executors.newScheduledThreadPool(8); private static void close() { try { service.shutdown(); } catch (Exception e) { try { service.shutdownNow(); } catch (Exception e1) { logger.error(e1.getMessage(), e1); } } } public static void registerTask(BaseTask task,long delay,TimeUnit unit){ service.schedule(task, delay, unit); logger.info("注册任务:{} 成功", new Object[] {task.getMyTaskName()}); } static { Runtime.getRuntime().addShutdownHook(new Thread() { public void run() { close(); } }); } }