瞭解消息的Storm處理流程

Question

1.我有一個拓撲（1個噴嘴和3個螺栓）和3個機器（1個nimbus和2個工作節點）。我是否想在所有3個節點上運行拓撲或運行靈氣足夠了嗎？它是否會將代碼分發到其他節點？

2.我的噴嘴將運行在nimbus或任何工人節點上？

3. 3個螺栓是在3個獨立的節點上運行還是在同一個節點上運行？它會照顧靈氣嗎？

4.我們如何跟蹤節點中螺栓的處理？

5.是否有任何文檔可用於理解在Storm中處理消息的完整流程？

Answer 1

答案：

1. 雨雲只是保持拓撲。像部署主jar等任務是靈活的，但靈活自己不做任何有關拓撲的處理。所以你絕對需要工人節點。擁有多個工作節點總是好的，這樣風暴拓撲可以適應任何工作失敗的情況。啓動nimbus節點時，需要指定nimbus服務器，然後自動選擇拓撲jar以在此worker節點上運行。

2. 正如第一點所述，nimbus僅僅是一個管理者，只是在工作節點上運行。

3. 關於第三個問題，我建議你閱讀這http://www.michael-noll.com/blog/2012/10/16/understanding-the-parallelism-of-a-storm-topology/

4. 看看風暴UI當您啓動風暴處理它會告訴你如何在管道中的每個步驟進行，因此你可以調整對每個步驟進行研究後，並行性。

5. 爲了尋找到風暴詳細經過教程風暴在github https://github.com/nathanmarz/storm/wiki/_pages

Answer 2

我有一個拓撲結構（1個噴口和3個螺栓）和3臺機器（1個雨雲和2個工作節點）。我想在所有3個節點上運行拓撲還是在nimbus上運行足夠了？

使用多個節點，您可以跨集羣分配負載，所以肯定這應該是有益的多個節點，而不是one.And也是一個節點發生故障靈氣就能夠重新分配任務的情況下，到另一臺機器。但是，可以在單個節點中設置風暴，並且可以在單臺機器上運行所有內容。

它是否會將代碼分配給其他節點？

是

我的嘴將在靈氣或任何工作節點

從屬節點負責運行或執行拓撲的運行，他們跑了一個名爲Supervisor

守護

3個螺栓在3個單獨的節點上運行或在同一節點上運行？它會照顧靈氣嗎？

該分佈由Nimbus（主節點）負責.Nimbus負責在集羣周圍分發代碼，將任務分配給機器並監視故障。

我們如何跟蹤節點中螺栓的處理？

Storm提供了一個基於Web的用戶界面，可以選擇在主節點上運行（運行Nimbus守護進程）。 Storm UI通過顯示集羣級別和拓撲級別診斷來提供集羣狀態的基本概述。同樣可以使用下面的命令

# cd /path/to/storm/install/dir 
    # bin/storm ui 

默認情況下，監聽8080端口，並且可以使用http://nimbus_host:8080/網址在瀏覽器中看到可以吃午飯。

是否有任何文檔可用於理解在Storm中處理消息的完整流程？

Storm Wiki頁面是學習和理解風暴工​​作的好地方。您還可以按照basic tutorial瞭解更多詳細信息

Answer 3

nimbus負責分配作業，但所有包括噴嘴或螺栓的代碼都將在工作節點上運行。

您應該能夠通過風暴UI跟蹤螺栓的進度。另外，您可以記錄一些消息來檢查數據的處理流程。