Strom的簡(jiǎn)單實(shí)現(xiàn)

?

Spout的實(shí)現(xiàn)

• 對(duì)文件的改變進(jì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ù)對(duì)日志文件的數(shù)據(jù)的變更進(jìn)行監(jiān)聽，一旦有添加Spout就會(huì)進(jìn)行讀入并且發(fā)送給Bolt進(jìn)行處理。

Bolt的實(shí)現(xiàn)

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

：

?

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

在本地集群上運(yùn)行和測(cè)試topology

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

?

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