前言
在现代网站开发中，如何快速转发消息成为了一个关键问题。 Message Queues 是一个流行的方案，它提供了一个可靠和可扩展的方式来传输和接收消息。 AMQP （Advanced Message Queuing Protocol）是其中一个协议，它定义了如何在消息队列客户端和服务器之间进行通信。
在 node.js 生态系统中，你可以使用 amqplib 来实现 AMQP 通信。 本文简要介绍、安装和配置了一个新的 npm 包-- amqp-dl -- 使得 AMQP 消费者可以直接自动下载消息体，而不必为此额外编写代码。
概述
amqp-dl 是一个基于 amqplib 的扩展，它允许 AMQP 消费者自动下载消息体。这极大地简化了消息队列的开发，因为你可以专注于简单的消息逻辑，而不必担心在一大堆异步回调中正确处理消息。
安装
使用 npm 包管理器，通过以下命令安装 amqp-dl：
npm install amqp-dl
或者你也可以直接在你的项目的 package.json 文件中添加依赖：
"dependencies": {
"amqp-dl": "^1.0.0"
}使用
基本用法
首先，你需要使用 amqplib 建立一个连接到你的消息队列的连接对象。一旦创建了连接，你就可以创建一个通道并消费队列消息。在消费消息期间，你可以使用 amqp-dl 自动下载消息体。
-- -------------------- ---- -------
----- --------- - -------------------
----- --------- - -------------------
------ -- -- -
----- ---------- - ----- ----------------------------
----- ------- - ----- ---------------------------
----- -----------------------------
----- ---------------- -------- ----- ----- --- -- -
----- ---- - ------------
-------------------- -- ------- ------
-- -- ---- ---- ---- --- ---- -------
-- ---- --- ---- -- ---------
----- -----------------
-- -------- --- ---- ----
----- -----
---
-----在上面的代码片段中，你首先建立了连接到 localhost 的连接，然后创建了一个名为 'tasks' 的队列。使用 amqp-dl 则可以在消费消息期间下载消息体。一旦完成了一个任务，你只需要从队列中取消息就行了。
内部工作原理
在这个例子中，consume() 函数本来接受一个回调函数。你可以像以前一样处理消息。然而，在调用你的回调函数之前，consume() 函数实际上会在 AMQP 服务器上下载消息体。如果你的消息体比较大，这可能会花费一些时间。
为了帮助你写出高质量的 AMQP 消费者，amqp-dl 实现了一些有用的功能。
第一，amqp-dl 跟踪消息的到期时间，并在消息过期时将消息拒绝。这个功能对于处理过期的和失效的情况非常有用。
其次，amqp-dl 跟踪消息的重新分配次数，并在分配次数达到阈值时拒绝消息。这有助于处理死信队列，以及其他由于恶意或故障导致的问题。
第三，如果消费者已经下载了消息体，并开始处理却在处理消息时遇到错误，amqp-dl 会将消息重新放回队列，不考虑消息的重新分配次数。这有助于处理像网络错误或数据库故障等技术性问题导致的处理失败。
指导意义
在 AMQP 消息队列消费过程中，amqp-dl 包大大简化了处理过程，使得开发人员可以专注于逻辑的编写，而无需处理异步回调。它的使用也极为简单，只需简单的两三行代码就可以了。
最值得注意和感谢的是，amqp-dl 还跟踪消息的到期时间，重新分配次数等等，这些特性有助于开发人员处理死信队列、过期或失效情况等。
总之，amqp-dl 是一个非常棒的包，非常值得你去使用。
示例代码
下载并为消息驱动 worker 创建一个简单的示例：
-- -------------------- ---- -------
----- --------- - -------------------
----- --------- - -------------------
------ -- -- -
----- ---------- - ----- ----------------------------
----- ------- - ----- ---------------------------
----- -----------------------------
----- ---------------- -------- ----- ----- --- -- -
----- ---- - -----------------------------------
-------------------- -- ------- ------
-- -- ---- ---- ---- --- ---- -------
----- ------ - -----------------
-- ---- --- ---- -- ---------
----- -----------------
-- -------- --- ---- ----
----- -----
---
-----
-------- ---------------- -
-- ------- -- -- ---- ---- ---- --- ---- ----
------ -----
-来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/74025