部署
(1)安裝Java 7和Pythong 2.6.6
(2)下載下傳storm安裝包,解壓縮,重命名,配置環境變量
(3)修改storm配置檔案
mkdir /var/storm
conf/storm.yaml
storm.zookeeper.servers:
-"111.222.333.444"
-"555.666.777.888"
storm.local.dir: "/mnt/storm"
nimbus.seeds: ["111.222.333.44"]
slots.ports,指定每個機器上可以啟動多少個worker,一個端口号代表一個worker
supervisor.slots.ports:
-6700
-6701
-6702
-6703
(4)啟動storm叢集和ui界面
第一台機器 storm nimbus >/dev/null2>&1 &
stormsupervisor >/dev/null 2>&1 &
stormui >/dev/null 2>&1 &
第二台 storm supervisor >/dev/null 2>&1&
stormlogviewer >/dev/null 2>&1 &
第三台 storm supervisor >/dev/null2>&1 &
storm logviewer >/dev/null 2>&1 &
一個節點,storm nimbus >/dev/null 2>&1&
三個節點,storm supervisor >/dev/null2>&1 &
一個節點,storm ui >/dev/null 2>&1&
storm logviewer >/dev/null 2>&1&
(5)通路一下ui界面,8080端口
-------------------------------------------------基本指令---------------------------------------------------
送出作業到storm叢集來運作
将eclipse中的工程,進行打包
(1)送出作業到storm叢集
storm jar path/to/allmycode.jarorg.me.MyTopology arg1 arg2 arg3
(2)在storm ui上觀察storm作業的運作
(3)kill掉某個storm作業
storm kill topology-name