分享
  1. 首页
  2. 文章

基于Redis实现的延迟队列

order_c · · 5545 次点击 · · 开始浏览
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

delay-queue

延迟队列, 参考有赞延迟队列设计实现

项目地址

运行

./delay-queue -c delay-queue.conf 默认监听0.0.0.0:9277

HTTP接口

  • 请求方法 POST

  • 请求Body及返回值均为json

返回值

{
 "code": 0,
 "message": "添加成功",
 "data": null
}
参数名 类型 含义 备注
code int 状态码 0: 成功 非0: 失败
message string 状态描述信息
data object, null 附加信息

添加任务

URL地址 /push

{
 "topic": "order",
 "id": "15702398321",
 "delay": 3600,
 "ttr": 120,
 "body": "{\"uid\": 10829378,\"created\": 1498657365 }"
}
参数名 类型 含义 备注
topic string Job类型
id string Job唯一标识
delay int Job需要延迟的时间, 单位:秒
ttr int Job执行超时时间, 单位:秒
body string Job的内容,供消费者做具体的业务处理,如果是json格式需转义

长轮询ready queue是否有任务, 有任务立即返回或等待180秒后超时返回

URL地址 /pop

{
 "topic": "order"
}
参数名 类型 含义 备注
topic string Job类型

队列中有任务返回值

{
 "code": 0,
 "message": "操作成功",
 "data": {
 "id": "15702398321",
 "body": "{\"uid\": 10829378,\"created\": 1498657365 }"
 }
}

队列为空返回值

{
 "code": 0,
 "message": "操作成功",
 "data": null
}

删除任务

URL地址 /delete

{
 "id": "15702398321"
}
参数名 类型 含义 备注
id string Job唯一标识

完成任务

URL地址 /finish

{
 "id": "15702398321"
}
参数名 类型 含义 备注
id string Job唯一标识

有疑问加站长微信联系(非本文作者)

本文来自:Segmentfault

感谢作者:order_c

查看原文:基于Redis实现的延迟队列

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

关注微信
5545 次点击
暂无回复
添加一条新回复 (您需要 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传

用户登录

没有账号?注册
或
(追記) (追記ここまで)

今日阅读排行

    加载中
(追記) (追記ここまで)

一周阅读排行

    加载中

关注我

  • 扫码关注领全套学习资料 关注微信公众号
  • 加入 QQ 群:
    • 192706294(已满)
    • 731990104(已满)
    • 798786647(已满)
    • 729884609(已满)
    • 977810755(已满)
    • 815126783(已满)
    • 812540095(已满)
    • 1006366459(已满)
    • 692541889

  • 关注微信公众号
  • 加入微信群:liuxiaoyan-s,备注入群
  • 也欢迎加入知识星球 Go粉丝们(免费)

给该专栏投稿 写篇新文章

每篇文章有总共有 5 次投稿机会

收入到我管理的专栏 新建专栏