如何从 Java 代码启动 Apache Storm UI？

Question

我用Storm开发了一个流处理项目。我通过执行我的项目的 Main class 创建了一个拓扑并运行它。

在 Storm 教程中，我看到了一个从 8080 端口访问的 UI，它显示了 spouts 和 bolts 的详细信息。但是，我找不到启动 UI 的方法。我该怎么做？

pom.xml 文件:

<dependency>
    <groupId>org.apache.storm</groupId>
    <artifactId>storm-core</artifactId>
    <version>1.2.2</version>
    <scope>compile</scope>
</dependency>

主要class:

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("TwitchSpout", new TwitchSpout());
builder.setBolt("MessageBolt", new MessageBolt()).shuffleGrouping("TwitchSpout");

Config conf = new Config();
conf.setDebug(false);

new LocalCluster().submitTopology("MyFirstTopo", conf, builder.createTopology());

我要入手的UI：

Answer 1

您正在运行将您的拓扑设置为本地集群，这仅用于测试。你应该运行它在一个真实的集群上而不是（参见 https://storm.apache.org/releases/2.0.0-SNAPSHOT/Setting-up-a-Storm-cluster.html）。

设置完成后，您可以使用 storm/bin 中的 storm.sh 脚本通过命令 storm ui 启动 Storm UI。当前无法在 LocalCluster 中启动 Storm UI。

如何从 Java 代码启动 Apache Storm UI？

How to start Apache Storm UI from Java code?

java

apache-storm