本文共 329 字，大约阅读时间需要 1 分钟。

bolt之间通信

• Spout会分配两个任务，对应sid1,sid2;
• 同时指定两个Acker，对应stid1:1010,stid2:1011;这两个数可以通过哈希找到对应的Acker，而且每次传递消息都会保存。
• Acker存储了自己的stid,对应的任务id是sid，同时还要存ack Value,初值被设置为了stid
  
• Bolt接受消息，但是任务在这里没有处理完，就先发送一波tid=1000，
• 注意到acker使用异或处理ackvalue
  
• 之后发送tid=stid，这样就把acker中的ack value变成上次发送的tid。
  
• 任务处理完，直接发送上一次传给Bolt2的tid，那么acker中的ack value就变成了0，任务被认为结束。

转载地址：https://blog.csdn.net/zaq15csdn/article/details/103688510 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！