storm的worker进程之间消息传递机制图：

每个worker都有一个独立的监听进程，监听配置文件中配置过的端口列表supervisor.slots.ports，topology.receiver.buffer.size代表接收线程一次最多能接收多少条消息，用户可以自定义配置。接收线程将收到的消息传递给对应的executor(一个或多个)的incoming-queues。对应接收线程，每个worker存在一个独立的发送线程，它负责从worker的transfer-queue中读取消息，并通过网络发送给其他worker，transfer-queue的大小由参数topology.transfer.buffer.size来设置。transfer-queue的每个元素实际上代表一个tuple的集合，当executor的outgoing-queue中的tuple达到一定的阀值，executor的发送线程将批量获取outgoing-queue中的tuple,并发送到transfer-queue中。