runtime - 在浏览器上显示风暴集群的螺栓结果

Question

是否可以在运行时在 Web 浏览器或 UI 上显示从风暴进程的螺栓中的进程派生的结果？它是如何完成的？

Answer 1

不确定您在寻找什么，但很有可能将任何螺栓输出写入文件。您只需要一个工作螺栓，它可以清除文件中传递给它的任何内容。您将流写入文件的逻辑应该在螺栓的execute(Tuple tuple)方法中。那是你正在寻找的吗？

更新

在螺栓和 Websocket 之间放置一个队列（Kafka/Krestel）怎么样。我在这里找到了这篇文章， 它说

为了在 Storm 和前端（通过 WebSockets）之间轻松集成，我选择了 Apache Camel 来为我完成繁重的工作。通过让 Storm 拓扑中的螺栓将其输出写入 ActiveMQ 队列，我可以创建一个订阅此队列并将消息推送到 WebSockets 的 Camel 路由，如下所示：

    public class StreamingRoute extends RouteBuilder {
        @Override
        public void configure() throws Exception {
              from("activemq:storm.queue")
                .to("websocket://storm?sendToAll=true");
       }
   }

还发现这篇文章谈论集成JMS and Websockets