java - Storm BasicDRPC 客户端执行

Question

我是一名 Storm 新手用户。我正在远程模式下尝试 drpc 服务器。我启动了 drpc 服务器并在 yaml 文件中配置了 drpc 服务器位置。但是，我不明白 drpc 客户端代码应该是什么样子: https://github.com/nathanmarz/storm-starter/blob/master/src/jvm/storm/starter/BasicDRPCTopology.java

这是我所做的:

1. 启动了 DRPC 服务器(storm drpc 命令)
2. 配置 DRPC 服务器的位置(编辑 yaml 文件。添加本地主机名)
3. 将 DRPC 拓扑提交到 Storm 集群 - 执行此操作后，看起来拓扑已启动并正在运行。

但是如何让客户端在此拓扑上调用/执行呢？我需要这样的东西吗？ https://github.com/mykidong/storm-finagle-drpc-client/blob/master/src/main/java/storm/finagle/drpc/StormDrpcClient.java ??我尝试过，但我不断收到此错误:

storm/starter/DRPCClient.java:[68,18]错误:DRPCClient中的execute(String,String)无法在Iface中实现execute(String,String) [错误] 重写的方法不会抛出 TException

我在这里缺少什么？谢谢

Answer 1

这里是Storm DRPC Document也许对理解 DRPC 调用很有用:)

就像下面的代码:

DRPCClient client = new DRPCClient("drpc-host", 3772);
String result = client.execute("reach", "http://twitter.com");

创建到 DRP​​C-Server-Host 的客户端连接:位于 3772 端口的 drpc-host 。

DRPCClient 使用参数“http://twitter.com”调用“reach”函数

并返回一个名为result的字符串