sweet-queue
v1.0.0sweet-queue
一个以Redis为后端存储的简单队列,实现了消息的入队、消费等功能,可以指定消息的消费者,即点对点消息。
安装
npm install --save sweet-queue
使用
创建消息队列
const Queue=require("sweet-queue")
let q = await Queue.Create(new Queue.Store(6379, "127.0.0.1"), "TEST");
消息入队
await q.Push("aaaaa:" + Date.now(),"q");
读取一条消息
await q.Pop(30,"q");
确认消费
await q.Ack("c99997d73fa9438ebb07f98fb7a337318b11cf0ec6354ebf842bee996c6f879c","q");
开启超时消息处理
q.OpenExpiresServer(async function(){
//console.log("读取子队列",id,Date.now())
return ["q1"]
});
关闭超时消息处理
await q.CloseExpiresServer();
所有接口
- Queue.Push(msg,to)
- Queue.Pop(expires,to)
- Queue.Ack(id,to)
- Queue.OpenExpiresServer(p2pListCall)
- Queue.CloseExpiresServer()