[TOC] # 簡介  # storm架構圖  Nimbus：負責資源分配和任務調度。 Supervisor：負責接受nimbus分配的任務，啟動和停止屬于自己管理的worker進程。 Worker：運行具體處理組件邏輯的進程。 Task：worker中每一個spout/bolt的線程稱為一個task. 在storm0.8之后，task不再與物理線程對應，同一個spout/bolt的task可能會共享一個物理線程，該線程稱為executor。 # storm編程模型  ## 基本介紹 Topology：Storm中運行的一個實時應用程序，因為各個組件間的消息流動形成邏輯上的一個拓撲結構。 Spout：在一個topology中產生源數據流的組件。通常情況下spout會從外部數據源中讀取數據，然后轉換為topology內部的源數據。Spout是一個主動的角色，其接口中有個nextTuple()函數，storm框架會不停地調用此函數，用戶只要在其中生成源數據即可。 Bolt：在一個topology中接受數據然后執行處理的組件。Bolt可以執行過濾、函數操作、合并、寫數據庫等任何操作。Bolt是一個被動的角色，其接口中有個execute(Tuple input)函數,在接受到消息后會調用此函數，用戶可以在其中執行自己想要的操作。 Tuple：一次消息傳遞的基本單元。本來應該是一個key-value的map，但是由于各個組件間傳遞的tuple的字段名稱已經事先定義好，所以tuple中只要按序填入各個value就行了，所以就是一個value list. Stream：源源不斷傳遞的tuple就組成了stream。