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

发布时间:2021-12-23 11:53:53 作者:iii
来源:亿速云 阅读:157

本篇内容介绍了“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集群搭建的方法是什么”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站,小编将为大家输出更多高质量的实用文章!

推荐阅读:
  1. storm问题总结
  2. storm drpc怎么定义

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

storm drpc

上一篇:Flume应用场景及用法有哪些

下一篇:mysql中出现1053错误怎么办

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》