shutdown徹底關閉tomcat,以及多線程關閉


  最近做的一個Web項目,發現shutdown.sh后,無法關掉tomcat進程。

  ps -ef | grep tomcat

  返回tomcat進程仍然存在。經過調查發現是因為在Web應用中啟動了線程池,shutdown只會關閉web線程(默認監聽端口8080),關閉線程(默認監聽8005);對於通過線程池(包括Executors創建的ExecutorService),只能是手動清除。使用tomcat容器的好處就在於能夠包住應用的生命周期,比如解決這個問題就可以通過實現ServletContextListener里面的contextDestroyed方法,來進行手動刪除。

  多線程(線程池)的關閉是幾個階段的,RUNNING->SHUTDOWN->STOPT->IDYING->TERMINATED,線程池對象提供的isShutdown()對應的就是SHUTDOWN階段,isTerminated()對應的就是TERMINATED階段,前者只要調用了shutdown,返回就是true,后者只有所有的線程池中的任務結束了(中斷處理並退出)才會返回true。

  這意味着,所有的多線程runnable/callable的實現,如果是while(true)模式的,要對於中斷異常盡心捕獲,並且進行退出。

  while(true){

    try{

    ... ...

    catch (InterruptedException e) {
                logger.warn("ResponseQueueHandler接收到中斷請求,退出程序");
                return ;
            }catch (Throwable e) {
              ... ...
            }

  }

  很多時候我們處理異常,都會捕獲並且記錄下來完事,避免某個處理影響后續處理;但是對於中斷異常就要退出處理,只有關閉才會向一個線程發起中斷請求(如果有其他實現場景也要觸發中斷另說),所以只要中斷,就退出。

  中斷處理的機制,基於我們上面的討論,如下:

    public static void shutdownThread(ExecutorService service, String serviceName) {
        service.shutdown();
        try {
            if (!service.isTerminated()) {
                logger.debug("直接關閉失敗{}", serviceName);
                service.awaitTermination(3, TimeUnit.SECONDS);
                if (service.isTerminated()) {
                    logger.debug("成功關閉{}", serviceName);
                } else {
                    logger.debug("{}關閉失敗,直接shutdownNow!", serviceName);
                    if (service.shutdownNow().size() > 0) {
                        logger.debug("最終{}沒有關閉成功", serviceName);
                    } else {
                        logger.debug("shutdownNow終於成功關閉{}", serviceName);
                    }
                }
            } else {
                logger.debug("直接成功關閉{}", serviceName);
            }
        } catch (InterruptedException e) {
            logger.warn("接收到中斷請求,{}停止操作", serviceName);
        }
    }

  我的應用在實現的時候,FixedScheduleThread,還是newCachableThread都是單獨來搞的,現在回想一下,其實應該讓他們都來自於同一個ExecutorService,這樣,在contextDestroyed里面其實只要關閉一個executorService即可,現在是要關閉一堆。

  對於線程池的關閉(上面的代碼是共通關閉線程的方式),需要額外添加一段處理:

        for (Future<String> future : this.runTaskMap.values()) {
            future.cancel(true);
        }

  將線程池中多有得Future都取消,這個過程其實就是中斷線程的過程,逐個線程中斷后,再對ExecutorService進行shutdown()操作即可。

  kill -9 tomcat_PID將會暴力關閉應該用,kill tomcat_PID將會優雅關閉線程,和調用線程池的shutdown效果一樣。

  最后,其實可以有一種更加簡單粗暴的方式,那就是在contextDestroyed里面調用exit(0)。剛開始使用的時候,擔心會不會把整台機器的JVM都干掉。但是如果搞懂了JVM的原理,其實每一個運行的JAVA程序都有自己的JVM,並不會互相干擾。另外,如果你想要在exit(0)之前做些什么處理,可以為JVM添加鈎子,來進行諸如關閉線程的處理:

    @Override
    public void contextInitialized(ServletContextEvent sce) {
        logger.info("新版本 2016-12-12 22:19");
   ... ...
        Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
            @Override
            public void run() {
                ... ...
                // ThreadManager.getInstance().shutdown();
            }
        }));
    }

  自行忽略第一行的log,用意是打出來版本號,證明運行的jar包是最新版的。

  我們上面提到的關閉線程的方式可以放置到此處來做。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM