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

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

>>阅读原文<<