netbeans - 如何在 Netbeans 中关闭 Apache Storm 的拓扑？答案

【问题标题】：netbeans - How to shutdown a Apache Storm's Topology in Netbeans?netbeans - 如何在 Netbeans 中关闭 Apache Storm 的拓扑？
【发布时间】：2016-12-09 11:45:59
【问题描述】：

我的项目使用 Maven。
要执行拓扑，我只需在 Netbeans 中运行拓扑文件。问题是我不知道如何关闭它。
我根本不想停止程序的执行（停止按钮）。我想告诉拓扑它需要关闭。
我该怎么做？

【问题讨论】：

标签： maven netbeans apache-storm

【解决方案1】：

您为什么不想使用停止按钮？对我来说似乎很好......

另一种方法是休眠一会儿，然后使用 Storm 的 API 关闭集群：

LocalCluster cluster = new LocalCluster();
LOG.info("Submitting local topology, will be shutdown in 60s");
cluster.submitTopology("CountingTopology", conf, builder.createTopology());
Thread.sleep(60000);    
cluster.shutdown();

如果它在集群上运行，您可以使用 Storms CLI 运行类似 storm kill topology-name 的命令，这基本上是一个大的停止按钮。 :)

【讨论】：

我不认为停止从 bolts 调用清理方法。
这很现实，因为在生产中也可能不会调用清理。
但我正在测试一些东西，所以现在我希望调用清理。
你的回答很好，是我用的，但我并不总是知道确切的关机时间。
我没有尝试过，但也许你可以运行一个单独的应用程序，它可以获取LocalCluster 的实例并调用shutdown？