Skip to content

Latest commit

 

History

History
54 lines (43 loc) · 1.56 KB

README.md

File metadata and controls

54 lines (43 loc) · 1.56 KB
Raw

延迟队列服务

设计要点

Role

  • 1: Timer
    • a: 任务投递到ReadyQueue之前需要先生成检测类型的任务到Bucket中（为了防止任务中断)
    • b: 接受任务并且负责扫描任务，把过期任务丢进执行队列中
  • 2: Worker
    • a: 仅从执行队列取出任务进行回调处理
  • 3: Timer&Worker

Timer

  • 1: redis zset
  • 2: 本地时间轮【如果是该类型，timer启动时会重载之前的数据进入内存】

Worker

  • 任务确认&任务回调
  • 重试次数

Ready-Queue

  • 1: redis list
  • 2: memory chan 【role: timer&worker】

配置

参考: https://github.com/zywaited/delay-queue/blob/master/config/config.example.toml

如果使用mongo存储

# 创建uid唯一索引
db.task.createIndex({"uid":1},{"unique":1})
# 创建分数&重载索引
db.task.createIndex({"token":1, "score":1},{"unique":1})

访问

参考: https://github.com/zywaited/delay-queue/blob/master/visit.md

其他

任务检测

  • 目前配置的最大检测次数是8次
  • 每次回调配置次数是3次

回调时间

  • 2次重试回调的时间：2，4 (s)
  • 回调HTTP必须是返回的状态码为<400才算成功, GRPC不返回err即可

检测

  • 实际检测次数会比配置多一次，比如配置8次，实际检测是9次，最后一次不进入队列，只是为了确认任务是否回调成功，没有成功就打印日志并且去除当前任务(防止无效任务过多)
每次检测延后执行时间
  • 1-3：15、30、60 (s)
  • 4-6：15、30、60 (m)
  • 7-9：4、8、12 (h)
  • 10及以上：1 (d)