自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

別再用kill -9關(guān)閉程序了......

作者：流星007
系統(tǒng) Linux
我相信很多人都用過 kill -9 pid 這個命令，徹底殺死進(jìn)程的意思，一般情況我們使用它沒有上面問題，但是在我們項目中使用它就有可能存在致命的問題。

kill 可將指定的信息送至程序。預(yù)設(shè)的信息為 SIGTERM(15)，可將指定程序終止。若仍無法終止該程序，可使用 SIGKILL(9) 信息嘗試強制刪除程序。程序或工作的編號可利用 ps 指令或 jobs 指令查看。

[[401381]]

圖片來自 Pexels

kill -9 pid ???

講的這個復(fù)雜，簡單點來說就是用來殺死 Linux 中的進(jìn)程，啥?你問我啥是進(jìn)程?請自行百度。

我相信很多人都用過 kill -9 pid 這個命令，徹底殺死進(jìn)程的意思，一般情況我們使用它沒有上面問題，但是在我們項目中使用它就有可能存在致命的問題。

kill -9 pid 帶來的問題

由于kill -9 屬于暴力刪除，所以會給程序帶來比較嚴(yán)重的后果，那究竟會帶來什么后果呢?

舉個栗子：轉(zhuǎn)賬功能，再給兩個賬戶進(jìn)行加錢扣錢的時候突然斷電了?這個時候會發(fā)生什么事情?

對于 InnoDB 存儲引擎來說，沒有什么損失，因為它支持事務(wù)，但是對于 MyISAM 引擎來說那簡直就是災(zāi)難，為什么?

假如給 A 賬戶扣了錢，現(xiàn)在需要將 B 賬戶加錢，這個時候停電了，就會造成，A 的錢被扣了，但是 B 沒有拿到這筆錢，這在生產(chǎn)環(huán)境是絕對不允許的，kill -9 相當(dāng)于突然斷電的效果。

當(dāng)然了，像轉(zhuǎn)賬這種，肯定不是使用 MyISAM 引擎，但是如今分布式火了起來，跨服務(wù)轉(zhuǎn)賬已經(jīng)是很平常的事情。

這種時候如果使用 kill -9 去停止服務(wù)，那就不是你的事務(wù)能保證數(shù)據(jù)的準(zhǔn)確性了，這個時候你可能會想到分布式事務(wù)。

這個世界上沒有絕對的安全系統(tǒng)或者架構(gòu)，分布式事務(wù)也是一樣，他也會存在問題，概率很小。

如果一旦發(fā)生，損失有可能是無法彌補的，所以一定不能使用 kill -9 去停止服務(wù)，因為你不知道他會造成什么后果。

在 MyISAM 引擎中表現(xiàn)的更明顯，比如用戶的信息由兩張表維護(hù)，管理員修改用戶信息的時候需要修改兩張表。

但由于你的 kill -9 暴力結(jié)束項目，導(dǎo)致只修改成功了一張表，這也會導(dǎo)致數(shù)據(jù)的不一致性。

這是小事，因為大不了再修改一次，但是金錢、合同這些重要的信息如果由于你的暴力刪除導(dǎo)致錯亂，我覺得可能比刪庫跑路還嚴(yán)重，至少刪庫還能恢復(fù)，你這個都不知道錯在哪里。

那我們應(yīng)該怎么結(jié)束項目呢?其實 Java 給我們提供了結(jié)束項目的功能，比如：Tomcat 可以使用 shutdown.bat/shutdown.sh 進(jìn)行優(yōu)雅結(jié)束。

什么叫優(yōu)雅結(jié)束?

  • 第一步：停止接收請求和內(nèi)部線程。
  • 第二步：判斷是否有線程正在執(zhí)行。
  • 第三步：等待正在執(zhí)行的線程執(zhí)行完畢。
  • 第四步：停止容器。

以上四步才是正常的結(jié)束流程，那 SpringBoot 怎么正常結(jié)束服務(wù)呢?下面我介紹幾種正常結(jié)束服務(wù)的方案，請拿好小本本做好筆記。

優(yōu)雅結(jié)束服務(wù)

①kill -15 pid

這種方式也會比較優(yōu)雅的結(jié)束進(jìn)程(項目)，使用他的時候需要慎重，為什么呢?

我們來看個例子，我寫了一個普通的 controller 方法做測試：

  1. @GetMapping(value = "/test") 
  2.     public String test(){ 
  3.         log.info("test --- start"); 
  4.         try { 
  5.             Thread.sleep(100000); 
  6.         } catch (InterruptedException e) { 
  7.             e.printStackTrace(); 
  8.         } 
  9.         log.info("test --- end"); 
  10.         return "test"; 
  11.     } 

代碼很簡單，打?。簍est — start 之后讓讓程序休眠 100 秒，然后再打印：test — end。

在線程休眠中我們使用 kill -15 pid 來結(jié)束這個進(jìn)程，你們猜 test — end 會被打印嗎?

application.yml：

  1. server: 
  2.   port: 9988 

啟動項目：

  1. sudo mvn spring-boot:run 

這是 maven 啟動 SpringBoot 項目的方式：

看到這個就代表項目啟動成了，找到項目的進(jìn)程 id：

  1. sudo ps -ef |grep shutdown 

 

這個就是項目的進(jìn)程號，接下來我們先測試 test 接口，讓線程進(jìn)入休眠狀態(tài)，然后再使用 kill -15 14086 停止項目：

  1. sudo curl 127.0.0.1:9988/test 

回到項目日志：

我們發(fā)現(xiàn)請求已經(jīng)到達(dá)服務(wù)，并且線程已經(jīng)成功進(jìn)入休眠，現(xiàn)在我們 kill -15 14086 結(jié)束進(jìn)程：

  1. sudo kill -15 14086 

回到日志：

  1. 2020-04-24 10:53:14.939  INFO 14086 --- [nio-9988-exec-1] com.ymy.controller.TestController        : test --- start 
  2. 2020-04-24 10:54:02.450  INFO 14086 --- [extShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor  : Shutting down ExecutorService 'applicationTaskExecutor' 
  3. java.lang.InterruptedException: sleep interrupted 
  4.  at java.lang.Thread.sleep(Native Method) 
  5.  at com.ymy.controller.TestController.test(TestController.java:26) 
  6.  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
  7.  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
  8.  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
  9.  at java.lang.reflect.Method.invoke(Method.java:498) 
  10.  at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190) 
  11.  at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138) 
  12.  at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:105) 
  13.  at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:879) 
  14.  at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:793) 
  15.  at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) 
  16.  at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1040) 
  17.  at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943) 
  18.  at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) 
  19.  at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898) 
  20.  at javax.servlet.http.HttpServlet.service(HttpServlet.java:634) 
  21.  at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) 
  22.  at javax.servlet.http.HttpServlet.service(HttpServlet.java:741) 
  23.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) 
  24.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) 
  25.  at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) 
  26.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) 
  27.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) 
  28.  at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) 
  29.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) 
  30.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) 
  31.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) 
  32.  at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) 
  33.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) 
  34.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) 
  35.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) 
  36.  at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:109) 
  37.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) 
  38.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) 
  39.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) 
  40.  at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) 
  41.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) 
  42.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) 
  43.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) 
  44.  at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202) 
  45.  at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) 
  46.  at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:541) 
  47.  at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139) 
  48.  at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) 
  49.  at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) 
  50.  at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) 
  51.  at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:373) 
  52.  at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65) 
  53.  at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) 
  54.  at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1594) 
  55.  at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) 
  56.  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
  57.  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
  58.  at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) 
  59.  at java.lang.Thread.run(Thread.java:748) 
  60. 2020-04-24 10:54:04.574  INFO 14086 --- [nio-9988-exec-1] com.ymy.controller.TestController        : test --- end 
  61. 2020-04-24 10:54:04.610 ERROR 14086 --- [nio-9988-exec-1] o.s.web.servlet.HandlerExecutionChain    : HandlerInterceptor.afterCompletion threw exception 
  62.  
  63. java.lang.NullPointerException: null 
  64.  at org.springframework.boot.actuate.metrics.web.servlet.LongTaskTimingHandlerInterceptor.stopLongTaskTimers(LongTaskTimingHandlerInterceptor.java:123) ~[spring-boot-actuator-2.2.6.RELEASE.jar:2.2.6.RELEASE] 
  65.  at org.springframework.boot.actuate.metrics.web.servlet.LongTaskTimingHandlerInterceptor.afterCompletion(LongTaskTimingHandlerInterceptor.java:79) ~[spring-boot-actuator-2.2.6.RELEASE.jar:2.2.6.RELEASE] 
  66.  at org.springframework.web.servlet.HandlerExecutionChain.triggerAfterCompletion(HandlerExecutionChain.java:179) ~[spring-webmvc-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  67.  at org.springframework.web.servlet.DispatcherServlet.triggerAfterCompletion(DispatcherServlet.java:1427) [spring-webmvc-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  68.  at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1060) [spring-webmvc-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  69.  at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943) [spring-webmvc-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  70.  at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) [spring-webmvc-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  71.  at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898) [spring-webmvc-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  72.  at javax.servlet.http.HttpServlet.service(HttpServlet.java:634) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  73.  at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) [spring-webmvc-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  74.  at javax.servlet.http.HttpServlet.service(HttpServlet.java:741) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  75.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  76.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  77.  at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) [tomcat-embed-websocket-9.0.33.jar:9.0.33] 
  78.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  79.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  80.  at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) [spring-web-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  81.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) [spring-web-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  82.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  83.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  84.  at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) [spring-web-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  85.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) [spring-web-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  86.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  87.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  88.  at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:109) [spring-boot-actuator-2.2.6.RELEASE.jar:2.2.6.RELEASE] 
  89.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) [spring-web-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  90.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  91.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  92.  at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) [spring-web-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  93.  at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) [spring-web-5.2.5.RELEASE.jar:5.2.5.RELEASE] 
  94.  at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  95.  at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  96.  at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  97.  at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  98.  at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:541) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  99.  at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  100.  at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  101.  at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  102.  at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  103.  at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:373) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  104.  at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  105.  at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  106.  at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1594) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  107.  at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  108.  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_242] 
  109.  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_242] 
  110.  at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-9.0.33.jar:9.0.33] 
  111.  at java.lang.Thread.run(Thread.java:748) [na:1.8.0_242] 

居然報錯了，但是 test — end 是打印出來了，為什么會報錯呢?

[[401383]]

這就和 sleep 這個方法有關(guān)了，在線程休眠期間，當(dāng)調(diào)用線程的 interrupt 方法的時候會導(dǎo)致 sleep 拋出異常。

這里很明顯就是 kill -15 這個命令會讓程序馬上調(diào)用線程的 interrupt 方法，目的是為了讓線程停止。

雖然讓線程停止，但線程什么時候停止還是線程自己說的算，這就是為什么我們還能看到：test — end 的原因。

②ConfigurableApplicationContext colse

我們先看怎么實現(xiàn)：

  1. package com.ymy.controller; 
  2.  
  3. import lombok.extern.slf4j.Slf4j; 
  4. import org.springframework.beans.BeansException; 
  5. import org.springframework.context.ApplicationContext; 
  6. import org.springframework.context.ApplicationContextAware; 
  7. import org.springframework.context.ConfigurableApplicationContext; 
  8. import org.springframework.web.bind.annotation.GetMapping; 
  9. import org.springframework.web.bind.annotation.PostMapping; 
  10. import org.springframework.web.bind.annotation.RestController; 
  11.  
  12. @RestController 
  13. @Slf4j 
  14. public class TestController  implements ApplicationContextAware { 
  15.  
  16.     private  ApplicationContext  context; 
  17.  
  18.     @Override 
  19.     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { 
  20.         this.context = applicationContext; 
  21.     } 
  22.  
  23.  
  24.     @GetMapping(value = "/test") 
  25.     public String test(){ 
  26.         log.info("test --- start"); 
  27.         try { 
  28.             Thread.sleep(100000); 
  29.         } catch (InterruptedException e) { 
  30.             e.printStackTrace(); 
  31.         } 
  32.         log.info("test --- end"); 
  33.         return "test"; 
  34.     } 
  35.  
  36.     /** 
  37.      * 停機(jī) 
  38.      */ 
  39.     @PostMapping(value = "shutdown") 
  40.     public void shutdown(){ 
  41.         ConfigurableApplicationContext cyx = (ConfigurableApplicationContext) context; 
  42.         cyx.close(); 
  43.     } 
  44. } 

重點在：cyx.close(); 為什么他能停止 SpringBoot 項目呢?請看源碼：

  1. public void close() { 
  2.         synchronized(this.startupShutdownMonitor) { 
  3.             this.doClose(); 
  4.             if (this.shutdownHook != null) { 
  5.                 try { 
  6.                     Runtime.getRuntime().removeShutdownHook(this.shutdownHook); 
  7.                 } catch (IllegalStateException var4) { 
  8.                 } 
  9.             } 
  10.  
  11.         } 
  12.     } 

程序在啟動的時候向 JVM 注冊了一個關(guān)閉鉤子，我們在執(zhí)行 colse 方法的時候會刪除這個關(guān)閉鉤子，JVM 就會知道這是需要停止服務(wù)。

我們看測試結(jié)果：

很明顯，他也出發(fā)了線程的 interrupt 方法導(dǎo)致線程報錯，原理和 kill -15 差不多。

③actuator

這種方式是通過引入依賴的方式停止服務(wù)，actuator 提供了很多接口，比如健康檢查，基本信息等等，我們也可以使用他來優(yōu)雅的停機(jī)。

引入依賴：

  1. <dependency> 
  2.             <groupId>org.springframework.boot</groupId> 
  3.             <artifactId>spring-boot-starter-actuator</artifactId> 
  4.         </dependency> 

application.yml：

  1. server: 
  2.   port: 9988 
  3.  
  4. management: 
  5.   endpoints: 
  6.     web: 
  7.       exposure: 
  8.         include: shutdown 
  9.   endpoint: 
  10.     shutdown: 
  11.       enabled: true 
  12.   server: 
  13.     port: 8888 

我這里對 actuator 的接口重新給定了一個接口，這樣可提高安全性，下面我們來測試一下：

  1. @RequestMapping(value = "/test",method = RequestMethod.GET) 
  2.     public String test(){ 
  3.         System.out.println("test --- start"); 
  4.         try { 
  5.             Thread.sleep(10000); 
  6.         } catch (InterruptedException e) { 
  7.             e.printStackTrace(); 
  8.         } 
  9.         System.out.println("test --- end"); 
  10.         return "hello"; 
  11.     } 

在請求 test 途中停止服務(wù)：

我們發(fā)現(xiàn)發(fā)送停止服務(wù)請求之后還給我們返回了提示信息，很人性化，我們看看控制臺：

test — end 被執(zhí)行了，不過在停止線程池的時候還是調(diào)用了線程的 interrupt 方法，導(dǎo)致 sleep 報錯，這三種方式都可以比較優(yōu)雅的停止 SpringBoot 服務(wù)。

如果我項目中存在線程休眠，我希望 10 秒以后再停止服務(wù)可以嗎?肯定是可以的，我們只需要稍微做點修改就可以了。

新增停止 SpringBoot 服務(wù)類：ElegantShutdownConfig.java。

  1. package com.ymy.config; 
  2.  
  3. import org.apache.catalina.connector.Connector; 
  4. import org.springframework.boot.web.embedded.tomcat.TomcatConnectorCustomizer; 
  5. import org.springframework.context.ApplicationListener; 
  6. import org.springframework.context.event.ContextClosedEvent; 
  7.  
  8. import java.util.concurrent.Executor; 
  9. import java.util.concurrent.ThreadPoolExecutor; 
  10. import java.util.concurrent.TimeUnit; 
  11.  
  12. public class ElegantShutdownConfig implements TomcatConnectorCustomizer, ApplicationListener<ContextClosedEvent> { 
  13.  
  14.     private volatile Connector connector; 
  15.     private final int waitTime = 10; 
  16.  
  17.     @Override 
  18.     public void customize(Connector connector) { 
  19.         this.connector = connector; 
  20.     } 
  21.  
  22.     @Override 
  23.     public void onApplicationEvent(ContextClosedEvent event) { 
  24.         connector.pause(); 
  25.         Executor executor = connector.getProtocolHandler().getExecutor(); 
  26.         if (executor instanceof ThreadPoolExecutor) { 
  27.             try { 
  28.                 ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executor; 
  29.                 threadPoolExecutor.shutdown(); 
  30.                 if (!threadPoolExecutor.awaitTermination(waitTime, TimeUnit.SECONDS)) { 
  31.                     System.out.println("請嘗試暴力關(guān)閉"); 
  32.                 } 
  33.             } catch (InterruptedException ex) { 
  34.                 System.out.println("異常了"); 
  35.                 Thread.currentThread().interrupt(); 
  36.             } 
  37.         } 
  38.  
  39.     } 
  40. } 

在啟動類中加入 bean：

  1. package com.ymy; 
  2.  
  3. import com.ymy.config.ElegantShutdownConfig; 
  4. import lombok.extern.slf4j.Slf4j; 
  5. import org.apache.catalina.connector.Connector; 
  6. import org.springframework.boot.SpringApplication; 
  7. import org.springframework.boot.autoconfigure.SpringBootApplication; 
  8. import org.springframework.boot.web.embedded.tomcat.TomcatConnectorCustomizer; 
  9. import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory; 
  10. import org.springframework.boot.web.servlet.server.ServletWebServerFactory; 
  11. import org.springframework.context.ApplicationListener; 
  12. import org.springframework.context.ConfigurableApplicationContext; 
  13. import org.springframework.context.annotation.Bean; 
  14. import org.springframework.context.event.ContextClosedEvent; 
  15.  
  16. import java.util.concurrent.Executor; 
  17. import java.util.concurrent.ThreadPoolExecutor; 
  18. import java.util.concurrent.TimeUnit; 
  19.  
  20. @SpringBootApplication 
  21. public class ShutdownServerApplication { 
  22.  
  23.     public static void main(String[] args) { 
  24.         ConfigurableApplicationContext run = SpringApplication.run(ShutdownServerApplication.class, args); 
  25.         run.registerShutdownHook(); 
  26.     } 
  27.  
  28.  
  29.     @Bean 
  30.     public ElegantShutdownConfig elegantShutdownConfig() { 
  31.         return new ElegantShutdownConfig(); 
  32.     } 
  33.  
  34.     @Bean 
  35.     public ServletWebServerFactory servletContainer() { 
  36.         TomcatServletWebServerFactory tomcat = new TomcatServletWebServerFactory(); 
  37.         tomcat.addConnectorCustomizers(elegantShutdownConfig()); 
  38.         return tomcat; 
  39.     } 
  40. } 

這樣我們就配置好了，我們再來測試一遍，test 的接口還是休眠 10 秒：

我們發(fā)現(xiàn)這次沒有報錯了，他是等待了一段時間之后再結(jié)束的線程池，這個時間就是我們在 ElegantShutdownConfig 類中配置的 waitTime。

那可能你會有疑問了，JVM 沒有立即停止，那這個時候在有請求會發(fā)生什么呢?如果關(guān)閉的時候有新的請求，服務(wù)將不在接收此請求。

數(shù)據(jù)備份操作

如果我想在服務(wù)停止的時候做點備份操作啥的，應(yīng)該怎么做呢?其實很簡單在你要執(zhí)行的方法上添加一個注解即可：@PreDestroy。

  • Destroy：消滅、毀滅。
  • pre：前綴縮寫。

所以合在一起的意思就是在容器停止之前執(zhí)行一次，你可以在這里面做備份操作，也可以做記錄停機(jī)時間等。

新增服務(wù)停止備份工具類：DataBackupConfig.java。

  1. package com.ymy.config; 
  2.  
  3. import org.springframework.context.annotation.Configuration; 
  4.  
  5. import javax.annotation.PreDestroy; 
  6.  
  7. @Configuration 
  8. public class DataBackupConfig { 
  9.  
  10.     @PreDestroy 
  11.     public  void backData(){ 
  12.  
  13.         System.out.println("正在備份數(shù)據(jù)。。。。。。。。。。。"); 
  14.     } 
  15. } 

我們再來測試然后打印控制臺日志：

[[401385]]

作者：流星007

編輯：陶家龍

出處：http://45dwz.com/GrTFl

圖片

 

責(zé)任編輯：姜華 來源： 51CTO技術(shù)棧
kill -9Linux kill -9 pid
相關(guān)推薦

2021-05-21 13:10:17

kill -9微服務(wù)Java

2021-02-04 11:30:06

CTOkill -9Linux

2022-04-14 11:17:41

MySQL字符配置

2020-12-02 11:18:50

print調(diào)試代碼Python

2020-12-04 10:05:00

Pythonprint代碼

2021-06-09 06:41:11

OFFSETLIMIT分頁

2021-01-29 11:05:50

PrintPython代碼

2020-12-03 09:05:38

SQL代碼方案

2020-12-15 08:06:45

waitnotifyCondition

2023-10-26 16:33:59

float 布局前段CSS

2022-01-27 07:48:37

虛擬項目Django

2020-07-17 07:15:38

數(shù)據(jù)庫ID代碼

2024-12-26 07:47:20

2024-06-12 13:54:37

編程語言字符串代碼

2019-03-12 14:48:29

路由器XBOXPS4

2022-10-27 21:34:28

數(shù)據(jù)庫機(jī)器學(xué)習(xí)架構(gòu)

2022-03-10 10:12:04

自動化腳本Bash

2023-09-08 08:35:42

層疊樣式表CSS

2023-06-26 08:20:02

openapi格式注解

2023-09-14 12:03:30

空指針判空
點贊
收藏

51CTO技術(shù)棧公眾號