storm Worker之间的通讯

要理解worker之间的通讯首先须要知道有哪些角色或组件参与其中，storm worker之间的通讯包括如下角色： 注意：tuple是消息传输的单元 1. Receiver Thread:接收线程，负责从其余worker接收tuple消息并根据taskid发送到相应的executer 2. Receiver Queue(incoming queue): 接收队列，全部从接收线程收到的消息都会先进入

>>阅读原文<<