设计一个分布式的回调超时计时器

业务背景

有一个功能具有很多异步阶段的处理流程,有的阶段需要依赖回调触发任务,现在存在某些情况下回调不过来,导致下一阶段任务停滞

现在准备设计一个回调超时计时器(分布式的),从上个阶段任务完成起 规定时间内, 未回调触发下阶段任务, 重新告知回调任务进行回调。 梳理功能点大概有三个:

  1. 超时计时器 开始计时
  2. 回调之后 计时器移除
  3. 回调超时后 重新执行上一阶段任务

想法:

  1. zset score为超时时间戳, 轮训取回调超时的任务
  2. (想用go的channel 但是因为存在分布式的情况,貌似行不通)

大家有好想法/建议的话 教教我呀😄

我是哈哈怪,每天笑哈哈. go/php开发, 业余喜欢写技术文章,欢迎关注我的个人网站 公众号:哈哈怪玩编程
讨论数量: 0
(= ̄ω ̄=)··· 暂无内容!

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!