NodeJS下使用
使用amqplib操作RabbitMQ
安装 amqplib
1 | npm install amqplib --save |
注意以下几点
建立连接后库会自己发送心跳包保活,不用开发者处理。
发送消息
工具类
1 | class RabbitMQ { |
注意
发送完成后关闭的时候一定要添加延时,否则可能还没发送出去,就被关闭了。
调用
1 | const { |
加入了失败重发机制
接收消息
工具类
1 | const amqp = require('amqplib'); |
调用
1 | const {RabbitMQ} = require("./src/utils/RabbitMQ") |