如何选择什么来源的流需要在Storm中处理

Question

我在Storm中遇到了一个问题。所以整个思路是:

1. 发送请求到风暴(可能到DRPC服务器)。这个请求会告诉Storm信息流的来源。例如:图像，我有两个文件1 - '/var/log/syslog'和2- ' /var/log/udev '。我希望能够向"风暴"发送请求，告诉它要处理哪个文件。

我不明白的地方:

当我说向"Storm"发送请求时，-我应该发送到哪里?(我假设DRPC服务器控制需要发送到拓扑的源。但是如何实现DRPC服务器呢?有像DRPCServer server = new DRPCServer()这样的课程吗?如何告诉Spout查看DRPCServer?还是请求需要直接发送给Spout ?那么如何使它开始使用指定的源?我的意思是我需要发送请求到open()方法吗?

Answer 1

不是DRPCServer，而是DRPCClient

DRPCClient client = new DRPCClient("drpc-host", 3772);

我想你看完这个会很感兴趣的。

更新:要了解更多信息，可以查看github中nathanmarz的storm-starter项目特别是BasicDRPCTopologyand ReachTopology