JStorm2.1.1集群的安裝和使用

Storm是一個免費開源、分布式、高容錯的實時計算系統，而JStorm是阿里巴巴開源的基于Storm采用Java重寫的一套分布式實時流計算框架，在性能和支持的集群規模上做了較大優化。

官方地址：https://github.com/alibaba/jstorm
相關文章：Storm深入理解
相關項目：Leek——簡易版實時智能選股平臺

JStorm集群的安裝:

?

1、Zookeeper集群的安裝

見：ZooKeeper高可用集群的安裝及配置

2、JStorm的安裝(安裝前需先安裝JDK和Python)

?

下載JStorm

wget https://github.com/alibaba/jstorm/wiki/Downloads

在服務器A和服務器B上：

unzip jstorm-2.1.1
vim /etc/profile
#profile中添加如下內容：
export JSTORM_HOME=/XXXXX/XXXX
export PATH=$PATH:$JSTORM_HOME/bin

在服務器A上配置：

 vim /home/jstorm/jstorm-2.1.1/conf/storm.yaml storm.zookeeper.servers:- "192.168.xx.100"- "192.168.xx.101"- "192.168.xx.102"nimbus.host: "192.168.xx.100"storm.zookeeper.root: "/jstorm"storm.local.dir: "%JSTORM_HOME%/data"supervisor.slots.ports:- 6800- 6801- 6802- 6803

在服務器B上配置：

 vim /home/jstorm/jstorm-2.1.1/conf/storm.yaml storm.zookeeper.servers:- "192.168.xx.100"- "192.168.xx.101"- "192.168.xx.102"nimbus.host: "192.168.xx.100"storm.zookeeper.root: "/jstorm"storm.local.dir: "%JSTORM_HOME%/data"supervisor.slots.ports:- 6800- 6801- 6802- 6803

3、在各個服務器提交jar的節點上執行:

mkdir ~/.jstorm
cp -f $JSTORM_HOME/conf/storm.yaml ~/.jstorm

4、啟動JStorm

?

在服務器A上啟動：

nohup jstorm nimbus &
nohup jstorm supervisor &
#查看啟動情況
jps

在服務器B上啟動：

nohup jstorm supervisor &
#查看啟動情況
jps

在服務器A上部署TOPOLOGY

jstorm jar Leek-1.0-SNAPSHOT.jar com.yingjun.stock.topology.StockStategyTopology xxx

注：TOPOLOGY的寫法可參考項目：Leek——簡易版實時智能選股平臺

?

5、安裝JStorm Web UI

mkdir ~/.jstorm
cp -f $JSTORM_HOME/conf/storm.yaml ~/.jstorm
#下載tomcat 7.x （以apache-tomcat-7.0.37 為例）
tar -xzf apache-tomcat-7.0.37.tar.gz
cd apache-tomcat-7.0.37
cd webapps
cp $JSTORM_HOME/jstorm-ui-0.9.6.3.war ./
../bin./startup.sh
訪問地址：http://192.168.xx.xxx:8080/jstorm-ui-2.1.1/

效果圖：