2013-10-22 172 views

回答

2

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

UPDATE

如何把一个队列(卡夫卡/ Krestel)在您的螺栓和WebSockets的之间。我发现这篇文章here它说

为了便于风暴和前端(通过 的WebSockets)之间的集成我选择了Apache的骆驼做繁重的我。通过在风暴拓扑螺栓 写自己的输出到 ActiveMQ的队列,我可以创建支持这一 队列中的骆驼航线,推动消息的WebSockets,像这样:

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

而且发现this文章谈论集成JMS and Websockets

+0

我实际上试图运行一个风暴过程,扫描一个文件并在运行时将这些过程的结果发送到Web浏览器。任何想法?我正在使用Web套接字来实现在浏览器上获取数据,而无需发送任何请求。我猜想关于该文件的部分是误导性的。将删除它。尽管感谢您的回答。 – rudd0211

+0

你是否设法做到这一点?如果你可以更新帖子! – change

相关问题