編輯“Apache Storm”（章節(jié)）

== 核心架構(gòu) ==
'''1、Nimbus'''

Nimbus是Storm的主節(jié)點(diǎn)，它負(fù)責(zé)資源分配和任務(wù)調(diào)度。在一個(gè)Storm集群中，只有一個(gè)Nimbus節(jié)點(diǎn)。

'''2、Supervisor'''

Supervisor是Storm的工作節(jié)點(diǎn)，它負(fù)責(zé)接收Nimbus分配的任務(wù)并管理所有的Worker進(jìn)程。一個(gè)Supervisor節(jié)點(diǎn)可以包含多個(gè)Worker進(jìn)程。

'''3、Worker'''

Worker是工作進(jìn)程，每個(gè)Worker進(jìn)程都包含多個(gè)Task。

'''4、Task'''

Task是任務(wù)，在Storm集群中，每個(gè)Spout和Bolt都由若干個(gè)任務(wù)來(lái)執(zhí)行。每個(gè)任務(wù)都與一個(gè)執(zhí)行線程相對(duì)應(yīng)。

'''5、Topology'''

Topology是計(jì)算拓?fù)洌菍?duì)實(shí)時(shí)計(jì)算應(yīng)用邏輯的封裝。與MapReduce的任務(wù)（Job）類似，區(qū)別在于MapReduce的一個(gè)Job在得到結(jié)果后會(huì)結(jié)束，而拓?fù)鋾?huì)一直在集群中運(yùn)行，直到你手動(dòng)終止它。拓?fù)湟部梢岳斫鉃橛梢幌盗型ㄟ^(guò)數(shù)據(jù)流（Stream Grouping）相互關(guān)聯(lián)的Spout和Bolt組成的拓?fù)浣Y(jié)構(gòu)。

'''6、Stream'''

Stream是數(shù)據(jù)流，是Storm中最核心的抽象概念。一個(gè)數(shù)據(jù)流指的是在分布式環(huán)境中并行創(chuàng)建、處理的一組元組（tuple）的無(wú)界序列。數(shù)據(jù)流可以通過(guò)一種能夠描述數(shù)據(jù)流中元組域（fields）的模式來(lái)定義。

'''7、Spout'''

Spout是數(shù)據(jù)源，它是拓?fù)渲袛?shù)據(jù)流的起點(diǎn)。通常，Spout會(huì)從一個(gè)外部數(shù)據(jù)源讀取元組并將它們發(fā)送到拓?fù)渲小８鶕?jù)需求的不同，Spout可以被定義為可靠的或不可靠的數(shù)據(jù)源?？煽康腟pout能夠在其發(fā)送的元組處理失敗時(shí)重新發(fā)送該元組，以確保所有元組都能得到正確處理；相反，不可靠的Spout在元組發(fā)送后不會(huì)進(jìn)行任何其他處理。一個(gè)Spout可以發(fā)送多個(gè)數(shù)據(jù)流。

'''8、Bolt'''

Bolt是拓?fù)渲型瓿伤袛?shù)據(jù)處理的組件。通過(guò)數(shù)據(jù)過(guò)濾、函數(shù)處理、聚合、聯(lián)結(jié)、數(shù)據(jù)庫(kù)交互等功能，Bolt幾乎可以完成任何類型的數(shù)據(jù)處理需求。一個(gè)簡(jiǎn)單的數(shù)據(jù)流轉(zhuǎn)換可以由一個(gè)Bolt實(shí)現(xiàn)，而更復(fù)雜的數(shù)據(jù)流變換通常需要使用多個(gè)Bolt并通過(guò)多個(gè)步驟完成。

'''9、Stream grouping'''

Stream grouping是為拓?fù)渲械拿總€(gè)Bolt確定輸入數(shù)據(jù)流的方式。數(shù)據(jù)流分組定義了如何在Bolt的不同任務(wù)之間劃分?jǐn)?shù)據(jù)流。Storm提供了八種內(nèi)置的數(shù)據(jù)流分組方式。

'''10、Reliability'''

Reliability是可靠性。Storm可以通過(guò)拓?fù)浯_保每個(gè)發(fā)送的元組都能得到正確處理。通過(guò)跟蹤由Spout發(fā)出的每個(gè)元組構(gòu)成的元組樹(shù)，可以確定元組是否已經(jīng)完成處理。每個(gè)拓?fù)涠加幸粋€(gè)“消息延時(shí)”參數(shù)，如果Storm在延時(shí)時(shí)間內(nèi)沒(méi)有檢測(cè)到元組是否處理完成，就會(huì)將該元組標(biāo)記為處理失敗，并在稍后重新發(fā)送該元組。