1. /**
    2. * 进程关闭时候清理业务数据
    3. */
    4. private void addShutdownHook() {
    5. Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    6. log.info(LOG_PRE + "进程即将退出,清理本次启动申请的zk资源");
    7. updateWorkerNodeInfo(null);
    8. zookeeperClient.deleteNode(workerIdAllocator.getWorkerNodePath() + SESSION_NODE);
    9. if (null != scheduler) {
    10. scheduler.shutdown();
    11. }
    12. }));
    13. }