status - 如何通过 java 代码获取风暴拓扑状态？

Question

我在暴风雨中很新。我想管理他们需要告知其状态的两个拓扑。我是否不可能了解拓扑的状态已停用或不在 java 类中提交另一个？

Answer 1

您可以使用 Thrift API：

  NimbusClient nimbusClient = NimbusClient.getConfiguredClient(Utils.readDefaultConfig())
  nimbusClient.getClient().getClusterInfo().get_topologies()
  …

见https://github.com/nathanmarz/storm/blob/master/storm-core/src/storm.thrift