简介
amqplib-retryable 是一个基于 amqplib 封装的 npm 包，主要用于 RabbitMQ 消息队列的接入。该包可以实现自动重试机制的消息发送，保证消息的可靠性。
安装
首先，在项目中安装 amqplib-retryable：
npm install amqplib-retryable --save
然后，安装 amqplib：
npm install amqplib --save
使用
在使用 amqplib-retryable 之前，需要先创建一个 RabbitMQ 的连接，然后创建一个 channel，这里不再赘述。
const amqp = require('amqplib');
const amqpRetryable = require('amqplib-retryable');
const connection = amqp.connect('amqp://localhost');
const channel = connection.createChannel();
接下来，就可以使用 amqplib-retryable 的功能了。
发送消息
amqplib-retryable 提供了一个 sendToQueueWithRetry 方法，用于发送消息。该方法的参数和 channel.sendToQueue() 方法类似，但是增加了一些额外的参数。
-- -------------------- ---- ------- ----- --------- - ------------- ----- ------- - ------- -------- ------------------------------------------- ---------- --------------------- - ------------- -- -- ----- --------- -- -- ----- ----------- -------- -- ----------- ----------- -- -- ---- -------------- ----- -- --------- ---------- -- - -------------------- ---- --------------- -------------- -- - --------------------- -- ---- ---------- ----- ---
在发送消息时，可以指定消息的持久化、优先级、过期时间等信息。如果发送失败，会自动进行重试，直到达到最大的重试次数为止。
接收消息
amqplib-retryable 也提供了一个 consumeQueueWithRetry 方法用于接收消息。该方法返回一个 Promise，resolve 的值为消费者 tag。
-- -------------------- ---- ------- ----- --------- - ------------- -------------------------------------------- ---------- --------- -- - --------------------- ---------- ---------------------------- --------------------- -- - --------- -- -- ----- --------- -- -- ------------- - --- ----------- -- -- ---- -------------- ----- -- --------- --------------------- -- - --------------------- ------- ------------- ------ ------------- -------------- -- - --------------------- -- ----- ----------- ----- ---
在接收消息时，可以指定消费者的消费行为，比如最多一次取出多少个消息（prefetch）、消费者 tag 等信息。如果消费消息失败，也会自动进行重试。
总结
通过 amqplib-retryable，我们可以很方便地实现 RabbitMQ 消息队列的接入，以及自动重试机制的消息发送和消费。这对于需要处理消息队列的前端应用来说，是非常有学习和指导意义的。
代码示例
下面是一个完整的 RabbitMQ 发送消息和接收消息的示例代码。
-- -------------------- ---- -------
----- ---- - -------------------
----- ------------- - -----------------------------
----- --------- - -------------
----- ------- - ------- --------
-- ----
-------------------------------------------------- -- -
------ ---------------------------
----------------- -- -
------ ------------------------------------------- ---------- --------------------- -
------------- -- -- -----
--------- -- -- -----
----------- -------- -- -----------
----------- -- -- ----
-------------- ----- -- ---------
---
---------- -- -
-------------------- ---- ---------------
-------------- -- -
--------------------- -- ---- ---------- -----
---
-- ----
-------------------------------------------------- -- -
------ ---------------------------
----------------- -- -
------ -------------------------------------------- ---------- --------- -- -
--------------------- ---------- ----------------------------
---------------------
-- -
--------- -- -- -----
--------- -- -- ------------- - ---
----------- -- -- ----
-------------- ----- -- ---------
---
--------------------- -- -
--------------------- ------- ------------- ------ -------------
-------------- -- -
--------------------- -- ----- ----------- -----
---
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/60065f8f238a385564ab6f44