设计一个分布式的回调超时计时器
业务背景
有一个功能具有很多异步阶段的处理流程,有的阶段需要依赖回调触发任务,现在存在某些情况下回调不过来,导致下一阶段任务停滞
现在准备设计一个回调超时计时器(分布式的),从上个阶段任务完成起 规定时间内, 未回调触发下阶段任务, 重新告知回调任务进行回调。 梳理功能点大概有三个:
- 超时计时器 开始计时
- 回调之后 计时器移除
- 回调超时后 重新执行上一阶段任务
想法:
- zset score为超时时间戳, 轮训取回调超时的任务
- (想用go的channel 但是因为存在分布式的情况,貌似行不通)
大家有好想法/建议的话 教教我呀😄
我是哈哈怪,每天笑哈哈. go/php开发, 业余喜欢写技术文章,欢迎关注我的个人网站 公众号:哈哈怪玩编程
推荐文章: