Storm单机安装

一、下载安装包

http://www.apache.org/dyn/closer.lua/storm/apache-storm-1.1.1/apache-storm-1.1.1.tar.gz

##二、修改配置文件
vim storm.yaml

##zookeeper
storm.zookeeper.servers:
     - "localhost"
##nimbus所在节点
nimbus.seeds: ["localhost"]
##可用端口号配置，每个对应一个worker，可配置多个
supervisor.slots.ports:
    - 6700

##三、启动组件
###1.启动zookeeper
Storm中使用Zookeeper主要用于Storm集群各节点的分布式协调工作，所以最先启动zookeeper，当然zookeeper也是需要下载，自行下载启动>>http://zookeeper.apache.org/

##先启动zookeeper
zkServer.sh start

###2.启动nimbus
主控节点运行Nimbus守护进程，类似于Hadoop中的jobtracker，负责在集群中分发代码，对节点分配任务，并监视主机故障。所以再启动nimbus。

##启动nimbus
./bin/storm nimbus &

###3.启动Storm UI

storm UI是一个监控storm运行状态的网页，bin/storm ui，访问地址: http://{nimbus.host}:ui.port/。默认端口8080。

./bin/storm ui &

###4.Supervisor
Supervisor负责监听工作节点上已经分配的主机作业，启动和停止Nimbus已经分配的工作进程。

##启动supervisor
./bin/storm supervisor &

##四、测试使用
###1.提交storm任务

./bin/storm jar /Users/delin/stromdemo/target/strom-demo-1.0-SNAPSHOT.jar com.ailpha.SimpleTopology wordcount

###2.杀死任务
格式：storm kill name -w seconds

storm kill wordcount -w 10

###3.停用任务命令
格式：storm deactivte name

storm deactivte wordcount

###4.启用任务命令
格式：storm activate name

storm activate wordcount

###5.平衡任务命令
格式：storm rebalance name

storm rebalance wordcount