成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

常見Java應用如何優雅關閉

開發 前端
在我們進行系統升級的時候,往往需要關閉我們的應用,然后重啟。在關閉應用前,我們希望做一些前置操作,比如關閉數據庫、redis連接,清理zookeeper的臨時節點,釋放分布式鎖,持久化緩存數據等等。

一、前言

在我們進行系統升級的時候,往往需要關閉我們的應用,然后重啟。在關閉應用前,我們希望做一些前置操作,比如關閉數據庫、redis連接,清理zookeeper的臨時節點,釋放分布式鎖,持久化緩存數據等等。

二、Linux的信號機制

在linux上,我們關閉進程主要是使用 kill 的方式。

當執行該命令以后,linux會向進程發送一個信號,進程收到以后之后,可以做一些清理工作。

kill 命令默認的信號值為 15 ,即 SIGTERM 信號。

通過 kill -l 查看linux支持哪些信號:

常見Java應用如何優雅關閉

linux提供了 signal() api,可以將信號處理函數注冊上去:

 

  1. #include <signal.h> 
  2. #include <stdio.h> 
  3. #include <unistd.h> 
  4. #include <stdlib.h> 
  5. #include <stdbool.h> 
  6.  
  7. static void gracefulClose(int sig)   
  8.     printf("執行清理工作\n"); 
  9.     printf("JVM 已關閉\n"); 
  10.     exit(0);    //正常關閉 
  11.  
  12. int main(int argc,char *argv[])   
  13.     if(signal(SIGTERM,gracefulClose) == SIG_ERR) 
  14.         exit(-1); 
  15.  
  16.     printf("JVM 已啟動\n"); 
  17.  
  18.     while(true
  19.     { 
  20.         // 執行工作 
  21.         sleep(1); 
  22.     } 

三、Java提供的Shutdown Hook

Java并不支持類似于linux的信號機制,但是提供了 Runtime.addShutdownHook(Thread hook) 的api。

在JVM關閉前,會并發執行各個Hook線程。

 

  1. public class ShutdownHook { 
  2.  
  3.     public static void main(String[] args) throws InterruptedException { 
  4.         Runtime.getRuntime().addShutdownHook(new DbShutdownWork()); 
  5.         System.out.println("JVM 已啟動"); 
  6.  
  7.         while(true){ 
  8.             Thread.sleep(10L); 
  9.         } 
  10.     } 
  11.  
  12.     static class DbShutdownWork extends Thread{ 
  13.         public void run(){ 
  14.             System.out.println("關閉數據庫連接"); 
  15.         } 
  16.     } 

四、Spring Boot提供的優雅關閉功能

我們一般采用如下的方式,啟動一個Spring boot應用:

 

  1. public static void main(String[] args) throws Exception {   
  2.     SpringApplication.run(SampleController.class, args); 

SpringApplication.run()代碼如下,會調用到refreshContext(context)方法:

 

  1. public ConfigurableApplicationContext run(String... args) {   
  2.     StopWatch stopWatch = new StopWatch(); 
  3.     stopWatch.start(); 
  4.     ConfigurableApplicationContext context = null
  5.     FailureAnalyzers analyzers = null
  6.     configureHeadlessProperty(); 
  7.     SpringApplicationRunListeners listeners = getRunListeners(args); 
  8.     listeners.started(); 
  9.     try { 
  10.         ApplicationArguments applicationArguments = new DefaultApplicationArguments( 
  11.                 args); 
  12.         ConfigurableEnvironment environment = prepareEnvironment(listeners, 
  13.                 applicationArguments); 
  14.         Banner printedBanner = printBanner(environment); 
  15.         context = createApplicationContext(); 
  16.         analyzers = new FailureAnalyzers(context); 
  17.         prepareContext(context, environment, listeners, applicationArguments, 
  18.                 printedBanner); 
  19.         refreshContext(context); 
  20.         afterRefresh(context, applicationArguments); 
  21.         listeners.finished(context, null); 
  22.         stopWatch.stop(); 
  23.         if (this.logStartupInfo) { 
  24.             new StartupInfoLogger(this.mainApplicationClass) 
  25.                     .logStarted(getApplicationLog(), stopWatch); 
  26.         } 
  27.         return context; 
  28.     } 
  29.     catch (Throwable ex) { 
  30.         handleRunFailure(context, listeners, analyzers, ex); 
  31.         throw new IllegalStateException(ex); 
  32.     } 

refreshContext()方法比較簡單:

 

  1. private void refreshContext(ConfigurableApplicationContext context) {   
  2.     refresh(context);   //調用ApplicationContext.refresh() 
  3.     if (this.registerShutdownHook) {        //registerShutdownHook默認值為true 
  4.         try { 
  5.             context.registerShutdownHook(); 
  6.         } 
  7.         catch (AccessControlException ex) { 
  8.             // Not allowed in some environments. 
  9.         } 
  10.     } 

AbstractApplicationContext.registerShutdownHook()代碼:

 

  1. public void registerShutdownHook() {   
  2.     if (this.shutdownHook == null) { 
  3.         this.shutdownHook = new Thread() { 
  4.             @Override 
  5.             public void run() { 
  6.                 synchronized (startupShutdownMonitor) { 
  7.                     doClose(); 
  8.                 } 
  9.             } 
  10.         }; 
  11.         Runtime.getRuntime().addShutdownHook(this.shutdownHook); 
  12.     } 

很明顯,Spring boot通過在啟動時,向JVM注冊一個ShutdownHook,從而實現JVM關閉前,正常關閉Spring容器。而Spring在銷毀時,會依次調用bean的destroy動作來銷毀。

五、Dubbo的優雅關閉策略

Dubbo同樣是基于ShutdownHook實現的。

AbstractConfig的static代碼:

 

  1. static {   
  2.     Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() { 
  3.         public void run() { 
  4.             if (logger.isInfoEnabled()) { 
  5.                 logger.info("Run shutdown hook now."); 
  6.             } 
  7.             ProtocolConfig.destroyAll(); 
  8.         } 
  9.     }, "DubboShutdownHook")); 

六、總結

只要我們的應用運行在linux平臺上,所有的優雅關閉方案都是基于linux提供的信號機制提供的,JVM也是如此。

Java并沒有為我們提供與之一一對應的api,而是給出了個ShutdownHook機制,也能達到類似的效果,缺點是我們無法得知JVM關閉的原因。

像dubbo、spring boot等成熟的開源框架,都實現了自動注冊ShutdownHook的功能,從而避免使用者忘記調用優雅關閉api引發問題,降低框架的使用難度。

責任編輯:未麗燕 來源: 點我達技術
相關推薦

2021-01-19 10:35:49

JVM場景函數

2022-04-11 08:17:07

JVMJava進程

2024-11-13 16:37:00

Java線程池

2021-03-28 09:17:18

JVM場景鉤子函數

2021-04-20 08:00:31

Redisson關閉訂單支付系統

2025-01-13 06:00:00

Go語言gRPC

2021-12-06 09:57:25

容器Linux信號

2021-01-28 14:53:19

PHP編碼開發

2021-01-18 13:17:04

鴻蒙HarmonyOSAPP

2025-02-12 00:21:44

Java并發編程

2022-06-02 10:02:47

Kubectl更新應用Linux

2023-12-20 10:04:45

線程池Java

2022-09-08 07:32:56

JDK7程序管理

2023-10-10 13:23:18

空指針異常Java

2025-06-24 08:25:00

Java并發編程線程

2021-07-15 09:47:20

Docker容器命令

2019-11-18 15:50:11

AjaxJavascript前端

2022-01-10 09:35:50

日志語言解析器

2022-03-07 07:33:24

Spring自定義機制線程池

2025-01-20 07:10:00

LambdaJavanull
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 国产高清视频 | 成人精品一区二区 | 黄色大片观看 | 香蕉大人久久国产成人av | 2019天天干天天操 | 欧美高清hd | 精品一区二区久久久久久久网精 | 日韩中文字幕一区二区三区 | 黄色在线观看国产 | 久久精品日产第一区二区三区 | 日韩视频在线免费观看 | 国产亚洲欧美日韩精品一区二区三区 | 日韩欧美一级精品久久 | 成人一区二区在线 | 国产精品自拍视频 | 中文字幕成人av | 国产精品午夜电影 | 91av亚洲| 欧美精品久久一区 | 国产一区二区视频在线观看 | 做a视频 | 91精品久久久久久久久 | 天天操天天干天天透 | 婷婷久久网 | 久久国产视频网 | 亚洲国产精品第一区二区 | chinese中国真实乱对白 | 在线观看av网站永久 | 亚洲精品视频网站在线观看 | 日本中文字幕一区 | 国产精品久久久久无码av | 欧美日韩电影一区二区 | 成人免费视频在线观看 | 国产精品美女久久久久久久久久久 | 国产精品完整版 | 成人福利视频网站 | 亚洲高清久久 | 91精品国产91久久综合桃花 | 亚洲欧洲色视频 | 视频精品一区二区三区 | 久久高潮 |