1. 程式人生 > >56.storm 之 hello world (集群模式)

56.storm 之 hello world (集群模式)

目錄 是否 代碼 -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 (集群模式)