storm(1.0.3版本)系統中消息傳遞過程圖

storm系統中進程間的通信在新版中已經完全採用netty,進程內通信依舊是採用disruptor隊列,每一個在系統中處理的tuple在生命週期內會經過很多個隊列,被多個線程進行處理,其具體的處理過程如下,其中,管狀形的代表disruptor隊列,橢圓形中間帶曲線條的表示線程:
相關文章
相關標籤/搜索