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

本篇內(nèi)容介紹了“Storm DRPC集群搭建的方法是什么”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細閱讀，能夠?qū)W有所成！

1、什么是DRPC

RPC:遠程過程調(diào)用協(xié)議

DRPC:rpc請求流式，并進行處理

RPC請求參數(shù)當(dāng)做輸入流，結(jié)果當(dāng)做輸出流

利用Strom的分布式進行處理機制和能力

借助RPC  server接收請求，返回響應(yīng)

*   storm只能獲取數(shù)據(jù)，不能接請求和發(fā)響應(yīng)，所以這里借助一個DRPC  Server來幫忙完成

*   DRPC服務(wù)器協(xié)調(diào)：1、接收一個rpc請求；2、發(fā)送請求到  storm  topology；3、從storm  topology接收結(jié)果；4、把結(jié)果發(fā)回給等待的客戶端。

2、DRPC的集群搭建

導(dǎo)入安裝包

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

在源碼包有一個執(zhí)行任務(wù)的命令

目錄：/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集群搭建的方法是什么”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！