tomcat 正常關閉

我的最后兩個博客討論了長時間輪詢和Spring的DeferredResult技術，并且為了展示這些概念，我將我的Producer Consumer項目中的代碼添加到了Web應用程序中。 盡管該代碼演示了博客所提出的觀點，但其邏輯上確實包含大量漏洞。 除了在實際的應用程序中不會使用簡單的LinkedBlockingQueue而是會選擇JMS或其他一些具有工業實力的消息傳遞服務這一事實，以及只有一個用戶可以掌握匹配更新的事實之外，還有一個問題生成行為不佳的線程，這些線程在JVM終止時不會關閉。

您可能想知道為什么這應該是一個問題……對您來說，作為開發人員，這根本不是問題，這只是一點點草率的編程，但是對于您的其中一個操作人員而言，它可能會使生活變得不必要地困難。 這樣做的原因是，如果您有太多行為異常的線程，那么鍵入Tomcat的shutdown.sh命令將幾乎沒有效果，并且您必須通過鍵入以下命令來嚴重殺死Web服務器：

ps -ef | grep java

得到pid然后

kill -9 <<pid>>

…并且當您有一個Tomcat Web服務器字段來重新啟動所有這些額外的問題時，這將變得非常痛苦。 當您鍵入shutdown.sh您希望Tomcat停止。

在我的前兩篇博客中，我創建的行為不良的線程具有以下run()方法，其中第一個方法run()如下所示）的行為確實不良：

@Override public void run() { while (true) { try { DeferredResult<Message> result = resultQueue.take(); Message message = queue.take(); result.setResult(message); } catch (InterruptedException e) { throw new UpdateException("Cannot get latest update. " + e.getMessage(), e); } } }

在這段代碼中，我使用了一個無限的while(true) ，這意味著線程將一直運行并且永不終止。

@Override public void run() { sleep(5); // Sleep to allow the reset of the app to load logger.info("The match has now started..."); long now = System.currentTimeMillis(); List<Message> matchUpdates = match.getUpdates(); for (Message message : matchUpdates) { delayUntilNextUpdate(now, message.getTime()); logger.info("Add message to queue: {}", message.getMessageText()); queue.add(message); } start = true; // Game over, can restart logger.warn("GAME OVER"); }

上面的第二個示例也表現不佳。 它將繼續從MatchUpdates列表中獲取消息，并在適當的時候將其添加到消息隊列中。 它們唯一的好處是，它們可能會拋出InterruptedException ，如果處理不當，將導致線程終止。 但是，這不能保證。

確實，有一個快速修復程序……您要做的就是確保您創建的任何線程都是守護程序線程。 守護程序線程的定義是一個線程，它不會阻止JVM在程序完成時退出，但該線程仍在運行。 守護程序線程的通常示例是JVM的垃圾回收線程。 要將線程轉換為守護程序線程，只需調用：

thread.setDaemon(true);

…然后當您鍵入shutdown.sh ， WHAM ，所有線程將消失。 但是，這有一個問題。 如果您的守護程序線程中的一個正在做重要的事情并將其砍掉，這會丟失一些非常重要的數據怎么辦？

您需要做的是確保所有線程正常關閉，以完成當前可能正在執行的所有工作。 本博客的其余部分演示了針對這些錯誤線程的修復程序，通過使用ShutdownHook優雅地協調了它們的ShutdownHook 。 根據文檔 ，“ shutdown hook”只是一個初始化但未啟動的線程。 當虛擬機開始其關閉序列時，它將以某種未指定的順序啟動所有已注冊的關閉掛鉤，并使其同時運行。” 因此，在閱讀了最后一句話之后，您可能已經猜到您需要做的是創建一個線程，該線程負責關閉所有其他線程，并作為關閉鉤子傳遞給JVM。 所有這些都可以在幾個小類中通用，并且可以通過對現有線程run()方法執行一些棘手的操作來實現。

要創建的兩個類是ShutdownService和Hook 。 我將首先演示的Hook類用于將ShutdownService鏈接到您的線程。 Hook的代碼如下：

public class Hook { private static final Logger logger = LoggerFactory.getLogger(Hook.class); private boolean keepRunning = true; private final Thread thread; Hook(Thread thread) { this.thread = thread; } /** * @return True if the daemon thread is to keep running */ public boolean keepRunning() { return keepRunning; } /** * Tell the client daemon thread to shutdown and wait for it to close gracefully. */ public void shutdown() { keepRunning = false; thread.interrupt(); try { thread.join(); } catch (InterruptedException e) { logger.error("Error shutting down thread with hook", e); } } }

Hook包含兩個實例變量： keepRunning和thread 。 thread是對該線程的引用，該Hook該實例負責關閉，而keepRunning告訴該線程…繼續運行。

Hook有兩個公共方法： keepRunning()和shutdown() 。 線程調用keepRunning()以確定是否應該繼續運行，而ShutdownService的shutdown鉤子線程調用shutdown()來使線程關閉。 這是兩種方法中最有趣的。 首先，它將keepRunning變量設置為false。 然后，它調用thread.interrupt()來中斷線程，迫使其引發InterruptedException 。 最后，它調用thread.join()并等待thread實例關閉。

請注意，此技術依賴于您所有線程的協作。 如果混合中有一個行為不佳的線程，那么整個事情可能會死機。 要解決此問題，請向thread.join(…)添加超時。

@Service public class ShutdownService { private static final Logger logger = LoggerFactory.getLogger(ShutdownService.class); private final List<Hook> hooks; public ShutdownService() { logger.debug("Creating shutdown service"); hooks = new ArrayList<Hook>(); createShutdownHook(); } /** * Protected for testing */ @VisibleForTesting protected void createShutdownHook() { ShutdownDaemonHook shutdownHook = new ShutdownDaemonHook(); Runtime.getRuntime().addShutdownHook(shutdownHook); } protected class ShutdownDaemonHook extends Thread { /** * Loop and shutdown all the daemon threads using the hooks * * @see java.lang.Thread#run() */ @Override public void run() { logger.info("Running shutdown sync"); for (Hook hook : hooks) { hook.shutdown(); } } } /** * Create a new instance of the hook class */ public Hook createHook(Thread thread) { thread.setDaemon(true); Hook retVal = new Hook(thread); hooks.add(retVal); return retVal; } @VisibleForTesting List<Hook> getHooks() { return hooks; } }

ShutdownService是一個Spring服務，其中包含一個Hook類的列表，并因此通過推斷線程負責關閉。 它還包含一個內部類ShutdownDaemonHook ，該類擴展了Thread 。 的一個實例ShutdownDaemonHook的施工過程中創建ShutdownService ，然后通過調用傳遞給JVM作為關閉掛鉤

Runtime.getRuntime().addShutdownHook(shutdownHook);

ShutdownService具有一個公共方法： createHook() 。 該類要做的第一件事是確保傳遞給它的任何線程都轉換為守護程序線程。 然后，它創建一個新的Hook實例，傳入線程作為參數，最后將結果存儲在列表中并將其返回給調用者。

現在剩下要做的唯一一件事就是將ShutdownService集成到DeferredResultService和MatchReporter ，這兩個類包含行為不良的線程。

@Service("DeferredService") public class DeferredResultService implements Runnable { private static final Logger logger = LoggerFactory.getLogger(DeferredResultService.class); private final BlockingQueue<DeferredResult<Message>> resultQueue = new LinkedBlockingQueue<>(); private Thread thread; private volatile boolean start = true; @Autowired private ShutdownService shutdownService; private Hook hook; @Autowired @Qualifier("theQueue") private LinkedBlockingQueue<Message> queue; @Autowired @Qualifier("BillSkyes") private MatchReporter matchReporter; public void subscribe() { logger.info("Starting server"); matchReporter.start(); startThread(); } private void startThread() { if (start) { synchronized (this) { if (start) { start = false; thread = new Thread(this, "Studio Teletype"); hook = shutdownService.createHook(thread); thread.start(); } } } } @Override public void run() { logger.info("DeferredResultService - Thread running"); while (hook.keepRunning()) { try { DeferredResult<Message> result = resultQueue.take(); Message message = queue.take(); result.setResult(message); } catch (InterruptedException e) { System.out.println("Interrupted when waiting for latest update. " + e.getMessage()); } } System.out.println("DeferredResultService - Thread ending"); } public void getUpdate(DeferredResult<Message> result) { resultQueue.add(result); } }

此類的第一個更改是在Shutdown服務實例中自動連線。 接下來要做的是在創建線程之后但在thread.start()之前，使用ShutdownService創建Hook的實例：

thread = new Thread(this, "Studio Teletype"); hook = shutdownService.createHook(thread); thread.start();

最后的更改是將while(true)替換為：

while (hook.keepRunning()) {

…告訴線程何時退出while循環并關閉。

您可能還注意到上面的代碼中拋出了一些System.out.println()調用。 這是有原因的，這是因為執行關閉鉤子線程的順序不確定。 請記住，您的類不僅試圖優雅地關閉，而且其他子系統也試圖關閉。 這意味著我的原始代碼logger.info(…)失敗， logger.info(…)以下異常：

Exception in thread "Studio Teletype" java.lang.NoClassDefFoundError: org/apache/log4j/spi/ThrowableInformationat org.apache.log4j.spi.LoggingEvent.(LoggingEvent.java:159)at org.apache.log4j.Category.forcedLog(Category.java:391)at org.apache.log4j.Category.log(Category.java:856)at org.slf4j.impl.Log4jLoggerAdapter.info(Log4jLoggerAdapter.java:382)at com.captaindebug.longpoll.service.DeferredResultService.run(DeferredResultService.java:75)at java.lang.Thread.run(Thread.java:722) Caused by: java.lang.ClassNotFoundException: org.apache.log4j.spi.ThrowableInformationat org.apache.catalina.loader.WebappClassLoader.loadClass(WebappClassLoader.java:1714)at org.apache.catalina.loader.WebappClassLoader.loadClass(WebappClassLoader.java:1559)... 6 more

這是因為當我嘗試調用記錄器時，它已經被卸載。 同樣，如文檔所述：“ Shutdown hooks在虛擬機生命周期的微妙時間運行，因此應進行防御性編碼。 尤其應將它們編寫為線程安全的，并盡可能避免死鎖。 它們也不應盲目地依賴可能已經注冊了自己的關閉鉤子的服務，因此可能自己處于關閉過程中。 嘗試使用其他基于線程的服務，例如AWT事件調度線程，可能會導致死鎖。”

MatchReport類具有一些非常相似的修改。 主要區別在于hook.keepRunning()代碼位于run()方法的for循環內。

public class MatchReporter implements Runnable { private static final Logger logger = LoggerFactory.getLogger(MatchReporter.class); private final Match match; private final Queue<Message> queue; private volatile boolean start = true; @Autowired private ShutdownService shutdownService; private Hook hook; public MatchReporter(Match theBigMatch, Queue<Message> queue) { this.match = theBigMatch; this.queue = queue; } /** * Called by Spring after loading the context. Will "kick off" the match... */ public void start() { if (start) { synchronized (this) { if (start) { start = false; logger.info("Starting the Match Reporter..."); String name = match.getName(); Thread thread = new Thread(this, name); hook = shutdownService.createHook(thread); thread.start(); } } } else { logger.warn("Game already in progress"); } } /** * The main run loop */ @Override public void run() { sleep(5); // Sleep to allow the reset of the app to load logger.info("The match has now started..."); long now = System.currentTimeMillis(); List<Message> matchUpdates = match.getUpdates(); for (Message message : matchUpdates) { delayUntilNextUpdate(now, message.getTime()); if (!hook.keepRunning()) { break; } logger.info("Add message to queue: {}", message.getMessageText()); queue.add(message); } start = true; // Game over, can restart logger.warn("GAME OVER"); } private void sleep(int deplay) { try { TimeUnit.SECONDS.sleep(10); } catch (InterruptedException e) { logger.info("Sleep interrupted..."); } } private void delayUntilNextUpdate(long now, long messageTime) { while (System.currentTimeMillis() < now + messageTime) { try { Thread.sleep(100); } catch (InterruptedException e) { logger.info("MatchReporter Thread interrupted..."); } } } }

此代碼的最終測試是在匹配更新序列中途發出Tomcat shutdown.sh命令。 在JVM終止時，它將從ShutdownDaemonHook類調用shutdown鉤子。 當此類的run()方法執行時，它將在整個Hook實例列表中循環，告訴它們關閉各自的線程。 如果在服務器日志文件的末尾添加tail -f （在我的案例中為catalina.out，但Tomcat可能配置為與我不同），則將看到條目痕跡，使服務器正常關閉。

該博客隨附的代碼可在Github上找到： https ： //github.com/roghughe/captaindebug/tree/master/long-poll 。

參考：來自Captain Debug's Blog博客的Tomcat的通過守護程序和Shutdown Hooks進行的Graceful Shutdown和我們的JCG合作伙伴 Roger Hughes。

翻譯自: https://www.javacodegeeks.com/2013/10/tomcats-graceful-shutdown-with-daemons-and-shutdown-hooks.html

tomcat 正常關閉

總結

以上是生活随笔為你收集整理的tomcat 正常关闭_Tomcat的带有守护程序和关闭钩子的正常关闭的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。