storm Worker之間的通訊

要理解worker之間的通訊首先須要知道有哪些角色或組件參與其中，storm worker之間的通訊包括如下角色： 注意：tuple是消息傳輸的單元 1. Receiver Thread:接收線程，負責從其餘worker接收tuple消息並根據taskid發送到相應的executer 2. Receiver Queue(incoming queue): 接收隊列，全部從接收線程收到的消息都會先進入

>>阅读原文<<