如何从storm拓扑主类调用关闭钩子？
我有一个storm拓扑类，它启动了一个kafka spout and bolts。这个类是主类。我正在尝试清理退出风暴拓扑，因此我在该拓扑主方法的旁边创建了一个关闭钩子。
//Shutdown hook
Runtime.getRuntime().addShutdownHook(new Thread() {
public void run() {
System.out.println("Inside shutdown hook.");
Utils.sleep(1000000);
cluster.killTopology("netra-fault-management");
cluster.shutdown();
logger.info("Shutting down Topology.");
}
});这是我的shutdown钩子，它位于tolpology类的main方法中。我从命令提示符运行它，当我执行ctrl+c时，它应该运行这个关闭钩子，但它只是关闭，没有钩子代码被调用。有没有朋友知道如何在ctrl+c上运行它。
回答 3
Stack Overflow用户
发布于 2015-02-04 20:36:21
使用Runtime#addShutdownHook，这是可能的。
问题应该是由Utils.sleep(1000000);引起的。您不应该让关闭的线程“休眠”，因为Java虚拟机(和其他应用程序)不允许这样做。关机钩子被设计成在应用程序即将关闭时调用，以保存重要的东西或卸载资源等。Java虚拟机将在几秒钟后终止，即使线程没有完全执行。
在极少数情况下，虚拟机可能会中止，即在未完全关闭的情况下停止运行。当虚拟机在外部终止时，例如Unix上的SIGKILL信号或Microsoft Windows上的TerminateProcess调用，就会发生这种情况。如果本机方法因例如破坏内部数据结构或试图访问不存在的存储器而出错，则虚拟机也可能中止。如果虚拟机中止，则不能保证是否将运行任何关闭挂钩。
来自运行时类的JavaDoc。有时不会调用关闭钩子。祝好运!
Stack Overflow用户
发布于 2015-06-11 07:12:08
几年前，Nathan Marz在评论一个类似的问题时，我假设行为没有改变：
https://groups.google.com/forum/#!topic/storm-user/A4-uFS6px2Y
Storm使用SIGKILL关闭工作进程，JVM在这些情况下不会执行关闭钩子(就像SIGINT一样)。
https://stackoverflow.com/questions/28321305
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号