storm流处理框架
发布日期:2021-06-29 03:38:15
浏览次数:4
分类:技术文章
本文共 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 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
留言是一种美德,欢迎回访!
[***.207.175.100]2024年04月28日 17时16分13秒
关于作者
喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
go中gin框架支持的简单上传下载读取csv等文件
2019-04-29
go 闭包
2019-04-29
go 捕获处理error
2019-04-29
Input dispatching timed out 导致anr问题分析
2019-04-29
主线程中Thread.Sleep()是否会导致ANR
2019-04-29
Android 为什么主线程的looper 一直循环不会ANR
2019-04-29
Android View 的绘制流程
2019-04-29
ContentProvider和数据库的区别
2019-04-29
Android四大组件——ContentProvider的增删改查和优化
2019-04-29
华为入局 VR 眼镜能让 VR 早普及几年?|CSDN博文精选
2019-04-29
做好以下四点,拒做 “ 空心 ” 程序员 | CSDN 博文精选
2019-04-29
程序员为什么非得参加一场编程竞赛?
2019-04-29
V 语言强势登顶 GitHub TOP1,欲取 Go 而代之?
2019-04-29
关于RocketMQ消息拉取与重平衡的一些问题探讨
2019-04-29
不同业务场景下如何进行数据库水平切分?
2019-04-29
如何准备算法工程师面试,斩获一线互联网公司机器学习岗offer?
2019-04-29
循环、递归与魔术(一)——递归与循环的数理逻辑
2019-04-29
1030MD
2019-04-29
发布文章---状态--恢复
2019-04-29