sweet-queue

    1.0.0 • Public • Published

    sweet-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()

    Keywords

    none

    Install

    npm i sweet-queue

    DownloadsWeekly Downloads

    0

    Version

    1.0.0

    License

    ISC

    Unpacked Size

    8.37 kB

    Total Files

    9

    Last publish

    Collaborators

    • zsea