重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
本篇内容介绍了“Storm DRPC集群搭建的方法是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
创新互联公司坚持“要么做到,要么别承诺”的工作理念,服务领域包括:网站设计制作、成都做网站、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的万山网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
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集群搭建的方法是什么”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!