Storm DRPC集群搭建的方法是什么

共计 1163 个字符，预计需要花费 3 分钟才能阅读完成。

本篇内容介绍了“Storm DRPC 集群搭建的方法是什么”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让丸趣 TV 小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

1、什么是 DRPC

RPC: 远程过程调用协议

DRPC:rpc 请求流式，并进行处理

RPC 请求参数当做输入流，结果当做输出流

利用 Strom 的分布式进行处理机制和能力

借助 RPC  server 接收请求，返回响应

*   storm 只能获取数据，不能接请求和发响应，所以这里借助一个 DRPC  Server 来帮忙完成

*   DRPC 服务器协调：1、接收一个 rpc 请求；2、发送请求到  storm  topology；3、从 storm  topology 接收结果；4、把结果发回给等待的客户端。

2、DRPC 的集群搭建

导入安装包

pip-8.0.0.tar.gz

setuptools-19.6.tar.gz

thrift-0.9.3.tar.gz

## 使用 root 用户安装 python 模块

1）、安装 python 模块、安装 thrift

tar -zxvf pip-8.0.0.tar.gz 

tar -zxvf setuptools-19.6.tar.gz 

cd setuptools-19.6

python setup.py install

cd ../pip-8.0.0

python setup.py install

tar -zxvf  thrift-0.9.3.tar.gz 
cd thrift-0.9.3
python setup.py install

2）更改 storm 配置

vim conf/storm.yaml
drpc.servers:
    – node1

scp  storm.yaml  root@node12:/usr/storm/conf/
scp  storm.yaml  root@node13:/usr/storm/conf/

3）、启动 drpc

前提启动 storm 集群

zkServer.sh  start

bin/storm  drpc

4）测试

 bin/storm jar examples/storm-starter/storm-starter-topologies-0.9.4.jar storm.starter.BasicDRPCTopology drpc

在源码包有一个执行任务的命令

目录：/usr/apache-storm-0.9.4/storm-core/src/py/storm

./DistributedRPC-remote -h 192.168.47.21:3772 -f execute exclamation testdfdf

“Storm DRPC 集群搭建的方法是什么”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注丸趣 TV 网站，丸趣 TV 小编将为大家输出更多高质量的实用文章！