java - 在 java 中杀死 Storm 中的拓扑后的通知

Question

当你杀死一个拓扑时，有没有办法通知它实际上在 java 中被杀死了？

对于我的集成测试，我在@Before 中使用我的拓扑启动本地集群，然后在@After 中终止它。这样，我的拓扑永远不会因为同时在其上运行的其他测试而变得“脏”，即使运行所有测试可能需要很长时间。

例如在 Windows 中，您不能完全关闭集群(关闭所有东西)，有没有办法确保拓扑被终止，因为如果另一个拓扑我不想启动一个新的拓扑还活着。

我已经将 Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS 减少到 0 以强制尽快杀死工作人员，但我仍然必须等待一段时间以确保拓扑在提交新的“干净”拓扑以进行下一次测试之前被杀死。

Answer 1

对我来说，这听起来更像是一个隔离集成测试的问题，而不是知道拓扑何时真正失效。在同一个集群上同时运行多个拓扑应该没有问题，而且那些旧的 worker，即使它们没有完全停止，也不应该干扰作为新部署的拓扑的一部分旋转起来的新 worker。

如果担心工作人员访问 Storm 集群外部的资源，您最好尝试在测试之间隔离这些资源，而不是确保所有 Storm 工作人员都已死亡。