我在Storm中挣扎着。所以整个想法是：
向storm发送请求（可能是向drpc服务器）。请求将告诉storm什么是流的来源。例如：我有两个文件的图像 1 - '/var/log/syslog' 以及 2- ' /var/log/udev ' . 我想能够发送请求到“风暴”告诉它什么文件处理。
我不明白的是：
当我说向“风暴”发送请求时，我应该把它发送到哪里我假设drpc服务器控制需要发送到拓扑的源。但是如何实现drpc服务器呢？有这样的班级吗 DRPCServer server = new DRPCServer() ? 那么如何让spout查看drpcserver？或者请求需要直接发送到 Spout ? 如果是这样，如何让它开始使用指定的源？我是说我需要把请求发送到 open() 方法？
1条答案
按热度按时间tjvv9vkg1#
不是drpcserver，而是drpcclient
我想你看完后会很感兴趣的
更新：有关更多信息，您可以随时查看nathanmarz在github中的storm starter项目，尤其是BasicDPTopology和reachtopology