简介
rabbitode 是一个用于 RabbitMQ 消息队列的 Node.js 客户端库，支持生产消息以及消费消息。它基于 amqplib 库实现，提供更加便捷的 API，并且支持 Promise。
安装
使用 npm 包管理器进行安装，命令如下：
npm install rabbitode
使用
初始化
使用如下代码进行初始化：
const Rabbitode = require('rabbitode');
const rabbitode = new Rabbitode('amqp://localhost');其中，'amqp://localhost' 为连接 RabbitMQ 的 URL，可以根据实际情况修改。
发送消息
使用如下代码进行发送消息：
async function sendMsg() {
const exchange = await rabbitode.assertExchange('logs', 'fanout');
const res = await exchange.publish(Buffer.from('Hello World!'));
console.log('Message sent successfully!');
}
sendMsg();其中，'logs' 为交换机名称，'fanout' 为交换机类型，详细的交换机类型请参考 RabbitMQ 的官方文档。
接收消息
使用如下代码进行接收消息：
-- -------------------- ---- -------
----- -------- ------------ -
----- -------- - ----- -------------------------------- ----------
----- ----- - ----- ------------------------- - ---------- ---- ---
-------------------- --- --------------
---------------------
------------------- ----- -- -
---------------------- ----------------------------
-- - ------ ---- ---
-
-------------其中，'logs' 为交换机名称，'fanout' 为交换机类型，详细的交换机类型请参考 RabbitMQ 的官方文档。'exclusive' 为 true， 表示该队列仅对本连接可见，连接断开后自动删除。
示例
以下为一个完整的发送和接收消息的示例：
-- -------------------- ---- -------
----- --------- - ---------------------
----- --------- - --- ------------------------------
----- -------- --------- -
----- -------- - ----- -------------------------------- ----------
----- --- - ----- ----------------------------------- ----------
-------------------- ---- ----------------
-
----- -------- ------------ -
----- -------- - ----- -------------------------------- ----------
----- ----- - ----- ------------------------- - ---------- ---- ---
-------------------- --- --------------
---------------------
------------------- ----- -- -
---------------------- ----------------------------
-- - ------ ---- ---
-
----------
-------------总结
rabbitode 是一个十分方便的 Node.js RabbitMQ 客户端库，使用起来非常简单，同时提供了很好的可扩展性。正常使用该库可以极大的提高 RabbitMQ 产品的开发效率，更好的应用于生产环境中。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6006735a890c4f7277583eaa