时间戳

首页 > 解决方案 > 如何从 Java 代码启动 Apache Storm UI？

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

问题描述

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

在 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>

主类：

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： 用户界面

标签： javaapache-storm

解决方案

您正在将拓扑作为本地集群运行，该集群仅用于测试。您应该改为在真正的集群上运行它（请参阅https://storm.apache.org/releases/2.0.0-SNAPSHOT/Setting-up-a-Storm-cluster.html）。

设置完成后，您可以storm ui使用storm.sh. storm/bin目前没有办法在 LocalCluster 中启动 Storm UI。

推荐阅读