Storm內部的通信機制原理

1,不同的supervisor之間通過網絡進行通信,每個supervisor的工作環境中都會有一個輸入和輸出的緩存隊列; 2,由於spout和bolt處理任務的數量不一致,因此在bolt的前面也會有一個消息隊列對數據進行緩存,同理WordCountBolt也會有一個消息隊列,對數據進行緩存
相關文章
相關標籤/搜索