在现代 web 应用中，很多业务都需要使用到消息队列来处理异步任务，例如请求处理、日志记录、系统监控等。而本文将介绍如何使用 Fastify 和 RabbitMQ 构建一个稳定可靠的消息队列系统。
RabbitMQ 简介
RabbitMQ 是一款基于 AMQP（Advanced Message Queuing Protocol）协议的消息队列系统，它是由一个 Erlang 实现的服务端和多种客户端组成的。用户可以使用多种编程语言来编写 RabbitMQ 客户端，并通过 API 对其进行操作。
Fastify 简介
Fastify 是一个快速且低开销的 web 框架，它使用了现代的 JavaScript 和 Node.js 标准库，从而获得更高的性能和更少的内存使用。Fastify API 呈现洁净、先进且简单的设计，易于学习和维护。
因此，我们可以将这两个强大的工具结合起来，构建一个消息队列系统，以更好地服务于我们的业务应用程序。
步骤一：安装 RabbitMQ
首先，需要在本地或服务器上安装 RabbitMQ。可以通过访问RabbitMQ官网下载适合您的平台的二进制文件进行安装。
安装完成后，请启动 RabbitMQ 服务，切换到命令行或终端中，并执行以下命令，检查 RabbitMQ 是否正常运行：
$ rabbitmqctl status
输出应该是类似这样的：
-- -------------------- ---- -------
------ -- ---- ---------------- ---
------------
---------------------------------------------------
---------------------------
------------ --- --- -------------
---------------------------
----------- ------------------
----------- --- --- -----------
------------- --- --- -----------
------------- --- --- -------------
------------------
--------------------------- -- ---------- -------- -------- --------- ------------------ -----------------------
--------------------------
-----------------------
-----------------------
------------------------
---------------------
----------------
----------------------
------------
----------------------
---------------
------------
--------------
-------------------
---------------
----------------
--------------
-------------------------
------------
-------------------------------------------------------
-------------------------------
----------------------------
---------------------------
------------------------
---------------------------------------
---------------
----------------------
-------------------
-----------------------------------------
--------------
------------ --------步骤二：使用 npm 安装 fastify 和 amqp 协议
接下来，需要使用 npm 来安装 fastify 和 amqp 协议：
$ npm install --save fastify amqp
其中，fastify 用于构建 web API，amqp 则是 rabbitmq 的客户端，用于在 Node.js 中连接 rabbitmq 服务端。
步骤三：创建消息队列消费者
在本例中，我们将创建一个消费者，在接收到消息后将其写入 JSON 文件中。如果您需要执行不同的任务，则应在 amqp 收到消息后执行不同的任务。
-- -------------------- ---- -------
----- -- - -------------
----- ---- - ------------------
----- --------- - ---------------
--- ------- - ----
----- ------------- - ----- -- -- -
--- -
----- ---- - ----- --------------------------------
----- -- - ----- --------------------
----- -------------------------
------------- --- ------- --- -------- -- --- -- ---- ----- -------- ----------
----- --------------------- ------- -- -
------------- --- -------- ---- ---------------------------
----- ---------- - ------------------------------------------
------------------------------- -----------
-- - ------ ---- --
- ----- ------- -
--------------------
-
-
---------------在上面的代码中，我们从 rabbitmq 连接到本地服务并等待接收消息。每当有新消息到达时，我们将消息内容写入 output.json 文件中。
在这里你也可以执行其他任务，只需要更改换写文件的部分代码即可。
步骤四：创建消息队列生产者
接下来，让我们创建一个生产者程序，用于将数据发送到 rabbitmq 队列中：
-- -------------------- ---- -------
----- ---- - ------------------
----- --------- - ---------------
----- ------- - ------- -------
----- ------------- - ----- -- -- -
--- -
----- ---- - ----- --------------------------------
----- -- - ----- --------------------
----- ------ - ----- -------------------------
------------- --- ------- --- -------- -- ----- ----------
----- ----------- - ----- ------------------------- ---------------------
------------- --- ---- ---- --------
----- ----------
----- ------------
- ----- ------- -
--------------------
-
-
---------------在上面的代码中，我们使用 amqp 连接到 rabbitmq，并在 assertQueue() 函数中声明一个名称为 example-queue 的队列。然后我们使用 sendToQueue() 函数发送消息并打印发送的消息。发送后，我们关闭频道和连接。
步骤五：使用 Fastify 构建 API 服务
接下来，使用 Fastify 构建简单的 API 服务，用于发送消息到消息队列。
-- -------------------- ---- -------
----- ------- - --------------------
----- ---- - ------------------
----- --------- - ---------------
----------------------------- ----- --------- ------ -- -
--- -
----- ------- - --------------------
----- ---- - ----- --------------------------------
----- -- - ----- --------------------
----- ------ - ----- -------------------------
------------- --- ------- --- -------- -- ----- ----------
----- ----------- - ----- ------------------------- ---------------------
------------- --- ---- ---- --------
----- ----------
----- ------------
-------------- ------- ---- -- ----- ----
- ----- ------- -
--------------------
-------------------
-
--
-------------------- ----- -------- -- -
-- ----- ----- ---
------------------- --------- -- ------------
--在上面的代码中，我们创建了一个 Fastify API 服务(send-message)，监听 POST 请求，并通过 amqp 协议发送带有 JSON 消息体的请求。在 Fastify 应用程序中，我们使用 sendToQueue() 函数将消息添加到 example-queue 队列，并将消息体作为 JSON 对象发送。
总结
本文提供了一个基于 Fastify 和 RabbitMQ 的消息队列系统的简单概述。我们见练习使用 RabbitMQ 中的生产者和消费者，以及使用 Fastify 创建 API 服务，以将消息添加到队列时发送。通过这些操作，可以构建出可以在应用程序中使用的异步任务系统，并为后续的扩展添加路径。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6503eccf95b1f8cacd0add38