延迟队列, 参考有赞延迟队列设计实现
go语言版本1.7+go get -d github.com/ouqiang/delay-queuego build
./delay-queue -c delay-queue.conf
HTTP Server监听
0.0.0.0:9277, Redis连接地址127.0.0.1:6379, 数据库编号1
- 请求方法
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格式需转义 |
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唯一标识 |
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent