Strom的簡單實現
?
Spout的實現
- 對文件的改變進行分開的監聽，并監視目錄下有無新日志文件添加。
- 在數據得到了字段的說明后，將其轉換成tuple。
- 聲明Spout和Bolt之間的分組，并決定tuple發送給Bolt的途徑。
?Spout中open、nextTuple和delcareOutputFields方法的邏輯：
?
?
declareOutputFileds（）決定了tuple發射的格式，這樣的話Bolt就可以用類似的方法將tuple譯碼。Spout持續對日志文件的數據的變更進行監聽，一旦有添加Spout就會進行讀入并且發送給Bolt進行處理。
Bolt的實現
Spout的輸出結果將給予Bolt進行更深一步的處理。
：
?
一旦Spout和Bolt準備就緒（等待被執行），topology生成器將會建立topology并準備執行。下面就來看一下執行步驟。
在本地集群上運行和測試topology
- 通過TopologyBuilder建立topology。
- 使用Storm Submitter，將topology遞交給集群。以topology的名字、配置和topology的對象作為參數。
- 提交topology。
?
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
