klg-mq

message queue

klg-mq

rabbitmq 连接工具

QuickStart

// 初始化
const mq = new Rabbitmq('amqp://joda:5672', 'test:')

// 发送消息
const queueName = 'a1'
const data = {a: 'ssss', b: 233}
await mq.queue(queueName, data)

// 消费(异步)
const prefetch = 2 // 消费速率
mq.consumeSingleQueue(queueName, prefetch, async function (data) {
  expect(data).toEqual({a: 'ssss', b: 233})
  done()
})

// 暂停消费 一般用于服务平滑重启
mq.disable()

// 重新激活
mq.active()

Test

没有做 mq mock,所以需要 mq 服务,开启 mq 服务,然后修改测试文件 Rabbitmq.test.ts 里 初始化连接的 url

$ npm i
$ npm test

History

1.1.1 默认所有消息都会持久化 persistent

Repository

https://github.com/kaolalicai/klg-mq


上一篇:klg-mq-koa
下一篇:klg-logger

相关推荐

  • zmq

    Bindings for node.js and io.js to ZeroMQ zmq   Build Status(https://travisci.org/JustinTulloss/zer...

    1 年前
  • zeromq

    Nextgeneration ZeroMQ bindings for Node.js ZeroMQ.js Next Generation Latest version(https://img.s...

    1 年前
  • websock(AMQ)通信-前端

    服务端和客户端之间的通信 前端开发经常会依赖后端,那么如果后端服务器还没做好推送服务器,那么前端该如何呢。 最简单的就是自己模拟一个服务器,用node来搭建,这边只简单介绍搭建的过程 node...

    2 年前
  • vue项目引入mqtt

    背景:如题。解决方案:这是教程注:1、不能按照教程那样网络引入,如下: image.png(/public/upload/64d5573f568e3c88f8e8bfc8789efb34) 若是网...

    2 个月前
  • tslint-config-klg

    tslint standard for klg 考拉 typescript 编码 标准 编辑 tslint.json 加入以下内容即可 Repository https://githu...

    6 个月前
  • streamqueue

    StreamQueue pipe the queued streams one by one in order to preserve their content order. streamqu...

    2 年前
  • simq

    ABANDONED Simple require for javascript (browser) NPM version(https://img.shields.io/npm/v/simq.svg...

    8 个月前
  • sass-mq

    mq() is a Sass mixin that helps manipulating media queries in an elegant way. Media Queries w...

    1 年前
  • paho-mqtt

    Eclipse Paho JavaScript MQTT client for Browsers Eclipse Paho JavaScript client The Paho JavaScri...

    2 年前
  • nativescript-mqtt

    NativeScript MQTT plugin NativeScript MQTT 3.1.1 Module Build Status(https://travisci.org/eduspero...

    2 个月前

官方社区

扫码加入 JavaScript 社区