JVM安全退出（如何优雅的关闭java服务）

迈不过友情╰ 2022-11-15 14:19 308阅读 0赞

# 背景 #

> 用户：货都到了，购物车里怎么还有刚买的东西，what?  
> 产品：有用户反映，提单完成了，怎么没清购物车，研发赶紧看看是不是有bug啊？  
> 研发：恩，我看看，！@\#￥%……&\*（）一顿狂查，搜嘎，当时在上线，重启应用，异步任务丢了……  
> 产品：能不能行，上线你就丢任务，丢不丢人啊！  
> 研发：…………

上线!重启!你还在为丢失任务而烦恼么？看这里看这里，从此不再丢任务，JVM可以安全退出的

在交易流程中，为了提升服务的性能，我们做了一些异步化的优化，比如更新用户最近使用的收货地址、提单完成后通过MQ去发送各种通知类消息、清理用户的购物车等等这些操作，异步化加快了应用的响应速度同时也带来一个隐患，如何保障异步操作的执行？这个场景主要发生在应用重启时，对于通过线程或线程池进行的异步化，JVM重启时，后台执行的异步操作可能尚未完成。这时，需要通过JVM安全关闭来保证异步操作进行完成后，JVM再执行关闭。  
更广泛的说，在Linux上很多应用通常会通过kill -9 pid的方式强制将进程杀掉，这种方式简单高效，因此很多应用的停止脚本经常会选择使用kill -9 pid的方式。强制进程退出,会带来一些副作用，对应用程序而言其效果等同于突然掉电，可能会导致如下一些问题：

1.  缓存中的数据尚未持久化到磁盘中，导致数据丢失；
2.  正在进行文件的write操作，没有更新完成，突然退出，导致文件损坏；
3.  线程池的任务队列中尚有接收到的任务还没来得及处理，导致任务丢失；
4.  数据库操作已经完成，例如账户余额更新，准备返回应答消息给客户端时，消息尚在通信线程的发送队列中排队等待发送，进程强制退出导致应答消息没有返回给客户端，客户端发起超时重试，会带来重复更新问题；
5.  其它问题等…

这些问题都有可能对我们的业务产生影响，造成不必要的损失，为了避免这些问题，我们需要在JVM关闭时做些扫尾的工作，为此JVM提供了关闭钩子（shutdown hooks）来做这些事情。本文探讨了利用关闭钩子的相关内容。

# JVM 关闭 #

首先，我们了解下哪些情况会导致JVM关闭，如下图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70][]

对于强制关闭的几种情况，系统关机，操作系统会通知JVM进程关闭并等待，一旦等待超时，系统会强制中止JVM进程；kill -9、Runtime.halt()、断电、系统crash这些种方式会直接无商量中止JVM进程，JVM完全没有执行扫尾工作的机会。因此对用应用程序而言，我们强烈不建议使用kill -9 这种暴力方式退出。  
而对于正常关闭、异常关闭的几种情况，JVM关闭前，都会调用已注册的shutdown hooks，基于这种机制，我们可以将扫尾的工作放在shutdown hooks中，进而使我们的应用程序安全的退出。基于平台通用性的考虑，我们更推荐应用程序使用System.exit(0)这种方式退出JVM。

JVM 与 shutdown hooks 交互流程如下图所示，可以对照源码进一步的学习shutdown hooks工作原理。  
[![image][]][image 1]

# Jvm安全退出 #

对于tomcat类Web应用，我们可以直接通过Runtime.addShutdownHook(Thread hook)注册自定义钩子，在钩子中实现资源的清理；而对于worker类应用，我们可以采用如下的方式安全的退出应用。

## 基于信号的进程通知机制 ##

信号是在软件层次上对中断机制的一种模拟，在原理上，一个进程收到一个信号与处理器收到一个中断请求可以说是一样的。通俗来讲，信号就是进程间的一种异步通信机制。信号具有平台相关性，Linux平台支持的一些终止进程信号如下所示：

<table> 
 <thead> 
  <tr> 
   <th>信号名称</th> 
   <th>用途</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>SIGKILL</td> 
   <td>终止进程，强制杀死进程</td> 
  </tr> 
  <tr> 
   <td>SIGTERM</td> 
   <td>终止进程，软件终止信号</td> 
  </tr> 
  <tr> 
   <td>SIGTSTP</td> 
   <td>停止进程，终端来的停止信号</td> 
  </tr> 
  <tr> 
   <td>SIGPROF</td> 
   <td>终止进程，统计分布图用计时器到时</td> 
  </tr> 
  <tr> 
   <td>SIGUSR1</td> 
   <td>终止进程，用户定义信号1</td> 
  </tr> 
  <tr> 
   <td>SIGUSR2</td> 
   <td>终止进程，用户定义信号2</td> 
  </tr> 
  <tr> 
   <td>SIGINT</td> 
   <td>终止进程，中断进程</td> 
  </tr> 
  <tr> 
   <td>SIGQUIT</td> 
   <td>建立CORE文件终止进程，并且生成core文件</td> 
  </tr> 
 </tbody> 
</table>

Windows平台存在一些差异，它的一些信号举例如下所示：

<table> 
 <thead> 
  <tr> 
   <th>信号名称</th> 
   <th>用途</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>SIGINT</td> 
   <td>Ctrl+C中断</td> 
  </tr> 
  <tr> 
   <td>SIGTERM</td> 
   <td>kill发出的软件终止</td> 
  </tr> 
  <tr> 
   <td>SIGBREAK</td> 
   <td>Ctrl+Break中断</td> 
  </tr> 
 </tbody> 
</table>

信号选择：为了不干扰正常信号的运作，又能模拟Java异步通知，在Linux上我们需要先选定一种特殊的信号。通过查看信号列表上的描述，发现 SIGUSR1 和 SIGUSR2 是允许用户自定义的信号,我们可以选择SIGUSR2，在Windows上我们可以选择SIGINT。

通过这种信号机制，对应用程序JVM发送特定信号,JVM可以感知并处理该信号，进而可以接受程序退出指令。

## 安全退出实现 ##

首先看下通用的JVM安全退出的流程图：

[![image][image 2]][image_image 2]

第一步，应用进程启动的时候，初始化Signal实例，它的代码示例如下：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
</pre> </td> 
   <td> <pre>Signal sig = new Signal(getOSSignalType());
</pre> </td> 
  </tr> 
 </tbody> 
</table>

其中Signal构造函数的参数为String字符串，也就上文介绍的信号量名称。

第二步，根据操作系统的名称来获取对应的信号名称，代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
</pre> </td> 
   <td> <pre>private String getOSSignalType()
   {
       return System.getProperties().getProperty("os.name").
                 toLowerCase().startsWith("win") ? "INT" : "USR2";
    }
</pre> </td> 
  </tr> 
 </tbody> 
</table>

判断是否是windows操作系统，如果是则选择SIGINT，接收Ctrl+C中断的指令；否则选择USR2信号，接收SIGUSR2（等价于kill -12 pid）指令。

第三步，将实例化之后的SignalHandler注册到JVM的Signal，一旦JVM进程接收到kill -12 或者 Ctrl+C则回调handle接口，代码示例如下：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
</pre> </td> 
   <td> <pre>Signal.handle(sig, shutdownHandler);
</pre> </td> 
  </tr> 
 </tbody> 
</table>

其中shutdownHandler实现了SignalHandler接口的handle(Signal sgin)方法，代码示例如下：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
6
7
8
9
</pre> </td> 
   <td> <pre>public class ShutdownHandler implements SignalHandler {
    /**
     * 处理信号
     *
     * @param signal 信号
     */
    public void handle(Signal signal) {
    }
}
</pre> </td> 
  </tr> 
 </tbody> 
</table>

第四步，在接收到信号回调的handle接口中，初始化JVM的ShutdownHook线程，并将其注册到Runtime中，示例代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
</pre> </td> 
   <td> <pre>private void registerShutdownHook()
 {
        Thread t = new Thread(new ShutdownHook(), "ShutdownHook-Thread");
        Runtime.getRuntime().addShutdownHook(t);
 }
</pre> </td> 
  </tr> 
 </tbody> 
</table>

第五步，接收到进程退出信号后，在回调的handle接口中执行虚拟机的退出操作，示例代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
</pre> </td> 
   <td> <pre>Runtime.getRuntime().exit(0);
</pre> </td> 
  </tr> 
 </tbody> 
</table>

JVM退出时，底层会自动检测用户是否注册了ShutdownHook任务，如果有，则会自动执行注册钩子的Run方法，应用只需要在ShutdownHook中执行扫尾工作即可，示例代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
6
7
8
9
10
11
12
13
</pre> </td> 
   <td> <pre>class ShutdownHook implements Runnable
{
        @Override
        public void run() {
                System.out.println("ShutdownHook execute start...");
                try {
                   TimeUnit.SECONDS.sleep(10);//模拟应用进程退出前的处理操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("ShutdownHook execute end...");
                }
}
</pre> </td> 
  </tr> 
 </tbody> 
</table>

通过以上的几个步骤，我们可以轻松实现JVM的安全退出，另外，通常安全退出需要有超时控制机制，例如30S，如果到达超时时间仍然没有完成退出，则由停机脚本直接调用kill -9强制退出。

# 使用关闭钩子的注意事项 #

*  关闭钩子本质上是一个线程（也称为Hook线程），对于一个JVM中注册的多个关闭钩子它们将会并发执行，所以JVM并不保证它们的执行顺序；由于是并发执行的，那么很可能因为代码不当导致出现竞态条件或死锁等问题，为了避免该问题，强烈建议在一个钩子中执行一系列操作。
 *  Hook线程会延迟JVM的关闭时间，这就要求在编写钩子过程中必须要尽可能的减少Hook线程的执行时间，避免hook线程中出现耗时的计算、等待用户I/O等等操作。
 *  关闭钩子执行过程中可能被强制打断,比如在操作系统关机时，操作系统会等待进程停止，等待超时，进程仍未停止，操作系统会强制的杀死该进程，在这类情况下，关闭钩子在执行过程中被强制中止。
 *  在关闭钩子中，不能执行注册、移除钩子的操作，JVM将关闭钩子序列初始化完毕后，不允许再次添加或者移除已经存在的钩子，否则JVM抛出 IllegalStateException。
 *  不能在钩子调用System.exit()，否则卡住JVM的关闭过程，但是可以调用Runtime.halt()。
 *  Hook线程中同样会抛出异常，对于未捕捉的异常，线程的默认异常处理器处理该异常，不会影响其他hook线程以及JVM正常退出。

# 总结 #

为了保障应用重启过程中异步操作的执行，避免强制退出JVM可能产生的各种问题，我们可以采用关闭钩子、自定义信号的方式，主动的通知JVM退出，并在JVM关闭前，执行应用程序的一些扫尾工作，进一步保证应用程序可以安全的退出。

文章来源：[https://www.cnblogs.com/panchanggui/p/9806266.html][https_www.cnblogs.com_panchanggui_p_9806266.html]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70]: /images/20221022/d2cc38f2536448c1a2a8f6012533e695.png
[image]: /images/20221022/19ff85a1f6c0492086b9f4e61e021db8.png
[image 1]: http://img10.360buyimg.com/n7/s1306x1261_jfs/t6205/257/91070679/64131/65b88829/5939100fNaf1f9cbe.png
[image 2]: https://img-blog.csdnimg.cn/img_convert/36379790dccc5c9389730978aaec1fa2.png
[image_image 2]: /images/20221022/b4bd86322f824375a6ef878a6c8a35f4.png
[https_www.cnblogs.com_panchanggui_p_9806266.html]: https://www.cnblogs.com/panchanggui/p/9806266.html