Storm內部通信以及ack-fail機制

Storm集羣架構中各模塊進行外部通信,拓撲程序中各個Task進行內部通信。 內部通信 消息容錯 內部通信   Bolt跨服務器發送Tuple的時候,需要藉助socketServer保持網絡連接狀態。每個executor都有一個都有一個緩存隊列:executor—>nextTuple/execute;每個worker都有輸入和輸出的管理器,其中管理器要維持socket連接。     輸出:Map<
相關文章
相關標籤/搜索