56.storm 之 hello world （集羣模式）

回顧

　　在上一小節，咱們在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吧，之後再考慮怎麼解決這個問題

過了一天，上面的問題的解決了，根本問題不是上面的那個錯誤，而是：StormClientErrorHandler [INFO] Connection failed Netty-Client-rocketmq-nameserver2:6703

解決方案是：假如咱們的集羣是3臺機器，則在每臺機器上的/etc/hosts中 將全部機器的映射配置便可，具體實例看下面的配置，記得要在每臺機器上都配置。

具體能夠看一下 http://blog.csdn.net/mic403/article/details/47147785