zk服務器異常報警和線程服務關閉機制

這篇文章主要講解了“zk服務器異常報警和線程服務關閉機制”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“zk服務器異常報警和線程服務關閉機制”吧！

主要查看ZooKeeperServer

監聽與服務器關系類圖

疑問：重要線程關閉或中斷的時候？這個監聽器在什么時候被調用呢？

接口 ZooKeeperServerListener

void notifyStopping(String threadName, int errorCode);

實現類ZooKeeperServerListenerImpl

@Override

public void notifyStopping(String threadName, int exitCode) {

LOG.info("Thread {} exits, error code {}", threadName, exitCode);

zkServer.setState(State.ERROR);

}

報警危機線程ZooKeeperCriticalThread繼承了ZooKeeperThread

重新實現了父類方法，調用監聽通知方法，改變服務狀態

@Override protected void handleException(String threadName, Throwable e) { LOG.error("Severe unrecoverable error, from thread : {}", threadName, e); listener.notifyStopping(threadName, ExitCode.UNEXPECTED_ERROR.getValue()); ServerMetrics.getMetrics().UNRECOVERABLE_ERROR_COUNT.add(1); }

處理器實現ZooKeeperServerShutdownHandler

private final CountDownLatch shutdownLatch;

void handle(State state) { if (state == State.ERROR || state == State.SHUTDOWN) { shutdownLatch.countDown(); } }

把shutdownLatch減去1

1異常處理流程

SessionTrackerImpl 運行中如果遇到異常

catch (InterruptedException e) {

handleException(this.getName(), e);

}

2調用繼承類的方法handleException

3方法中調用監聽類ZooKeeperServerListener的.notifyStopping通知方法

4通知接口實現ZooKeeperServerListenerImpl具體指定處理

設置服務狀態為zkServer.setState(State.ERROR);

5調用zkServer.setState方法，內部調用ZooKeeperServerShutdownHandler處理器方法

6處理器中調用handle方法

void handle(State state) {

if (state == State.ERROR || state == State.SHUTDOWN) {

shutdownLatch.countDown();

}

}

6 計數器關閉ZooKeeperServerMain中注冊了關閉服務處理器

// Registers shutdown handler which will be used to know the

// server error or shutdown state changes.

final CountDownLatch shutdownLatch = new CountDownLatch(1);

zkServer.registerServerShutdownHandler(new ZooKeeperServerShutdownHandler(shutdownLatch));

...

containerManager.start();

// Watch status of ZooKeeper server. It will do a graceful shutdown

// if the server is not running or hits an internal error.

shutdownLatch.await();

感謝各位的閱讀，以上就是“zk服務器異常報警和線程服務關閉機制”的內容了，經過本文的學習后，相信大家對zk服務器異常報警和線程服務關閉機制這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！