56.storm 之 hello world (集群模式)
阿新 • • 發佈:2017-05-19
目錄 是否 代碼 -1 maven 參考 ntb 分享 log文件
回顧
在上一小節,我們在PWTopology1 這一個java類中註解掉了集群模式,使用本地模式大概了解一下storm的工作流程。這一節我們註解掉本地模式相關的代碼,放開集群模式相關代碼,並且將項目打包,在實際環境中運行一下。
集群模式部署步驟
項目打包
pom.xml右鍵 --> run as --> maven clean --> maven install
將大好的jar包上傳到 nimbus 的 /usr/local下
提交拓撲
storm jar storm01.jar bhz.topology.PWTopology1
運行上面的命令後結果是這樣的,終點看一下畫紅框的地方:
查看拓撲是否運行
在nimbus 運行 :storm list
結果是這樣的:
也可以到管控臺看到上面的信息
再查看一下supervisor的狀態:jps可以看到worker進程
也可以看一下logs目錄下的worker-****.log文件:
這些信息就是PrintBolt類中打印出的信息(完整代碼參考上一節):
不過還遇到一個未能解決的問題,就是其中一個supervisor報錯:
重啟虛擬機都沒有用。。而且這個Supervisor並沒有工作。暫時先用一個Supervisor吧,以後再考慮怎麽解決這個問題
56.storm 之 hello world (集群模式)