什么是 node-red-contrib-amqp2
node-red-contrib-amqp2 是一个 Node-RED 的插件，可以让你在 Node-RED 的流程中接收和发送 AMQP2.0 协议的消息。
Node-RED 是基于 Node.js 构建的一款可视化编程工具，它可以让用户通过拖拽节点的方式简单地搭建数据流应用程序。Node-RED 是一个非常流行的物联网应用程序的构建工具，能够快速搭建智能家居、自动化控制、工业监控等应用程序。
AMQP2.0 是高级消息队列协议（Advanced Message Queuing Protocol）的一个版本，是一种跨平台、面向消息的中间件协议。AMQP 的消息处理机制非常灵活，允许消费者按照自己的需要订阅特定类型的消息，生产者也可以根据自己的需求发送各种类型的消息。因此，AMQP2.0 协议被广泛应用于物联网、金融、医疗、电信等行业。
node-red-contrib-amqp2 的出现，让 Node-RED 用户能够方便地与 AMQP2.0 协议集成，实现更加强大的应用程序。
如何安装 node-red-contrib-amqp2
首先，确保你已经安装了 Node.js 和 Node-RED。如果还没有安装，可以分别通过以下链接下载：
安装 Node-RED 后，进入 Node-RED 的目录，在命令行中输入以下命令安装 node-red-contrib-amqp2 插件：
--- ------- ----------------------
安装完成后，启动 Node-RED：
--------
打开浏览器，输入 http://localhost:1880 访问 Node-RED 的流程编辑器。
node-red-contrib-amqp2 的使用方法
接收 AMQP2.0 消息
首先，在 Node-RED 的工具栏中找到 amqp2 in 节点，将其拖拽到流程编辑器中。再拖拽一个 debug 节点到 amqp2 in 节点的右侧，连接两个节点。
双击 amqp2 in 节点，在弹出的配置窗口中，输入要接收的 AMQP2.0 消息所使用的，RabbitMQ 或 ActiveMQ 等消息队列服务器的连接字符串。
点击右上角的 Done 按钮保存配置。现在，你可以观察到 debug 节点上出现了从 AMQP2.0 消息队列中接收到的消息。你可以通过 debug 节点输出消息的任何内容，例如消息的正文、标头、属性等。
发送 AMQP2.0 消息
接收到 AMQP2.0 消息后，很多场景下需要对消息进行处理，并将处理后的消息发送到其他的消息队列。在 Node-RED 中，这个过程非常简单。
将接收到的 AMQP2.0 消息通过各种方法处理（如计算、过滤、格式化等），然后将处理后的消息通过 amqp2 out 节点发送到其他消息队列。将 amqp2 out 节点拖拽到流程编辑器中，并连接处理过的消息。
双击 amqp2 out 节点，在弹出的配置窗口中，输入要发送到的 AMQP2.0 消息队列所使用的，RabbitMQ 或 ActiveMQ 等消息队列服务器的连接字符串。
点击右上角的 Done 按钮保存配置。现在，处理后的消息已经被发送到了 AMQP2.0 消息队列中。
示例代码
下面是一个完整的示例代码，可以在 Node-RED 中使用此代码，测试 node-red-contrib-amqp2 插件的使用方法。
-------------------------------------- -------------------------------------------------------------------- --------------------------------------------------------------------------------------------------- ---------------------------------------------------------------------------------------- ------------------------------------------------------------ ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ --------- - -------------------------------- - ---------------------------------------------------------- ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------- ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
这个示例代码包含了一个 inject 节点，用于向 amqp2 in 节点发送一个简单的 AMQP2.0 消息。程序首先接收这个消息，并将其 text 数据部分通过 function 节点取出来，接着将 text 数据部分通过 amqp2 out 节点发送到 amqp_output 的队列中。同时，debug 节点会显示接收到的消息内容。
小结
node-red-contrib-amqp2 的使用方法很简单，只需要将 amqp2 in 和 amqp2 out 节点拖拽到 Node-RED 工作区中进行设置即可。这个插件为 Node-RED 所连接的各种消息队列提供了全功能的支持，展示了 AMQP2.0 协议的灵活性和可扩展性。
对于需要快速构建大型物联网、工业自动化系统和交易处理等应用程序的开发人员来说，Node-RED 平台和 node-red-contrib-amqp2 插件是非常有用的工具。希望本文的介绍可以帮助你更好地应用这个插件，在应用程序开发中取得更好的效果。
来源：JavaScript中文网 ，转载请联系管理员！ 本文地址：https://www.javascriptcn.com/post/60055d1581e8991b448daab6