Storm内部通信以及ack-fail机制

Storm集群架构中各模块进行外部通信，拓扑程序中各个Task进行内部通信。 内部通信 消息容错 内部通信   Bolt跨服务器发送Tuple的时候，需要借助socketServer保持网络连接状态。每个executor都有一个都有一个缓存队列：executor—>nextTuple/execute；每个worker都有输入和输出的管理器，其中管理器要维持socket连接。     输出：Map<

>>阅读原文<<