天天看點

storm實時計算執行個體(socket實時接入)

實作了一個簡單的從實時日志檔案監聽,寫入socket伺服器,再接入Storm計算的一個流程。

最後執行 

spout接受從socket伺服器實時發送過來的資料,經過topology處理,最終将資料寫入out_socket.txt檔案

本文轉自ljianbing51CTO部落格,原文連結:http://blog.51cto.com/ljianbing/1733313 ,如需轉載請自行聯系原作者

繼續閱讀