JStorm2.1.1集群的安装和使用

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/

效果图：