Strom的簡單實現(xiàn)

?

Spout的實現(xiàn)

• 對文件的改變進行分開的監(jiān)聽，并監(jiān)視目錄下有無新日志文件添加。
• 在數(shù)據(jù)得到了字段的說明后，將其轉(zhuǎn)換成tuple。
• 聲明Spout和Bolt之間的分組，并決定tuple發(fā)送給Bolt的途徑。

?Spout中open、nextTuple和delcareOutputFields方法的邏輯：

?

?

declareOutputFileds（）決定了tuple發(fā)射的格式，這樣的話Bolt就可以用類似的方法將tuple譯碼。Spout持續(xù)對日志文件的數(shù)據(jù)的變更進行監(jiān)聽，一旦有添加Spout就會進行讀入并且發(fā)送給Bolt進行處理。

Bolt的實現(xiàn)

Spout的輸出結(jié)果將給予Bolt進行更深一步的處理。

：

?

一旦Spout和Bolt準(zhǔn)備就緒（等待被執(zhí)行），topology生成器將會建立topology并準(zhǔn)備執(zhí)行。下面就來看一下執(zhí)行步驟。

在本地集群上運行和測試topology

• 通過TopologyBuilder建立topology。
• 使用Storm Submitter，將topology遞交給集群。以topology的名字、配置和topology的對象作為參數(shù)。
• 提交topology。

?

storm學(xué)習(xí)之入門篇（二）