如何檢查Storm拓撲結構是否已加載並運行在Java中

Question

如何檢查Storm是否已加載並運行實際的Storm拓撲結構，以便對其進行測試。由於執行集成測試需要等待拓撲運行，然後才能開始測試邏輯。在本地羣集上。

Answer 1

您可以使用storm command line interface或直接使用Java客戶端API。例如：

NimbusClient nimbusClient = new NimbusClient(conf, nimbusHost, nimbusPort, 30000); 
List<TopologySummary> topologies = nimbusClient.getClient().getClusterInfo().get_topologies();