1

我在 Storm 中为一件事而苦苦挣扎。所以整个想法是：

  1. 向storm（可能是DRPC Server）发送请求。该请求将告诉 Storm 流的来源是什么。例如：我有两个文件1 - '/var/log/syslog'和2- ' /var/log/udev' 的图像。我希望能够将请求发送到“Storm”，告诉它要处理什么文件。

我不明白的是：

当我说向“风暴”发送请求时， - 我应该将它发送到哪里？（我假设 DRPC 服务器控制需要发送到拓扑的源。但是如何实现 DRPC 服务器？是否有类似的类DRPCServer server = new DRPCServer()？以及如何告诉 Spout 查看 DRPCServer？或者是请求需要直接发送到? if那么Spout如何让它开始使用指定的源呢？我的意思是我需要向open()方法发送请求吗？

4

1 回答 1

1

不是 DRPCServer，它的 DRPCClient

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

我想你看到这个之后会很感兴趣

更新： 有关更多信息，您可以随时查看 nathanmarz 在 github 中的 Storm-starter 项目，尤其是BasicDRPCTopology和ReachTopology

于 2013-04-18T09:34:52.603 回答