跳到主要内容

插件开发基础

本指南涵盖 RabbitMQ 插件开发的基础知识。阅读本指南前,读者应基本了解 RabbitMQ 插件机制。

读者还应基本了解 ErlangOTP 设计原则

Learn You Some Erlang 是开始学习 Erlang 和 OTP 的绝佳途径。

为什么要开发插件?

编写 RabbitMQ 插件提供了许多有吸引力的可能性

  • 使您的应用程序能够访问未通过受支持协议之一公开的 RabbitMQ 内部功能。
  • 与 Broker 在同一个 Erlang VM 中运行可能会提高某些工作负载的性能。
  • 插件可以实现原本必须由系统中每个应用程序(服务)实现的功能,从而减少重复并降低维护负担

为什么不开发插件

与任何插件机制一样,在开发功能时应考虑是否将其作为插件嵌入是最合适的途径。您可能不想将功能开发为插件的一些原因如下

  • 依赖 RabbitMQ 内部 API 可能会导致您的应用程序在新的 RabbitMQ 版本发布时需要更改,包括补丁版本。如果可以在不使用 RabbitMQ 内部组件的情况下完成所需操作,则您的应用程序将具有更高的向前兼容性
  • 编写不佳的插件可能导致整个节点变得不可用或行为异常

入门

要开发 RabbitMQ 插件,首先请确保满足以下要求

  • 确保您已安装并正常运行 Git
  • 确保已安装并正常运行 服务器构建 指南中详细说明的依赖项

Erlang.mk 用于构建 RabbitMQ 及其插件。开始开发新插件的最简单方法可能是复制现有插件,例如rabbitmq-metronome如下例所示

在开发期间激活插件

要在开发期间测试插件,请使用以下 make 目标启动 RabbitMQ 节点,其中本地插件是从源代码构建并启用的

make run-broker

插件质量提示

编写不当的插件可能会对 Broker 的稳定性构成风险。为了确保您的插件能够安全运行而不会影响 RabbitMQ 核心,强烈建议采用以下几项安全最佳实践。

  1. 始终为您的应用程序使用顶级 Supervisor。
  2. 永远不要直接启动插件应用程序,而是选择创建一个(可能非常简单的)Supervisor,以防止 Erlang VM 因顶层应用程序崩溃而关闭。

Broker 和依赖项版本约束

可以使用插件应用程序环境中的 broker_version_requirements 键为插件指定 Broker 和依赖项版本要求。要求指定为每个发布系列中的最低版本列表。考虑以下示例

{application, my_plugin,[
%% ...
{broker_version_requirements, ["3.11.15", "3.10.22"]}
]}

以上要求 RabbitMQ 3.10.x 从 3.10.22 开始,以及 3.11.x 从 3.11.15 开始。请注意,当新的主要和次要(功能)RabbitMQ 版本发布时,插件维护者必须更新列表

插件可以具有依赖项。也可以为依赖项指定受支持的版本系列。这与上述非常相似,但使用类似字典的数据结构(proplist)。

例如

{application, my_plugin, [
%% ...
{dependency_version_requirements, [{rabbitmq_management, ["3.11.0", "3.10.22"]}]}
]}

表示插件依赖于 rabbitmq_management 3.10.x 从 3.10.22 开始以及 3.11.x 系列中的所有版本。

插件示例:节拍器

鉴于没有 Hello World 示例的开发指南是不完整的,以下内容尝试提供构建您自己的 RabbitMQ 插件的基础知识。

以下示例详细说明了如何构建一个像节拍器一样的简单插件。

每秒,它都会向名为“metronome”的主题交换器发送一条消息,该消息的路由键格式为 yyyy.MM.dd.dow.hh.mm.ss(默认为此交换器)。应用程序可以将队列附加到此交换器,并使用各种路由键以便按规律的间隔调用。例如,要每秒接收一条消息,可以应用“......*”的绑定。要每分钟接收一条消息,可以改为应用“......00”的绑定。

GitHub 上的 rabbitmq-metronome 存储库包含此插件的代码副本。

下表应解释存储库中各种文件的用途。

文件名用途
Makefile

此顶级 Makefile 定义插件的名称及其依赖项。名称必须与 Erlang 应用程序名称匹配。依赖项使用 erlang.mk 的变量声明。紧随其后,Makefile 包括rabbitmq-components.mkerlang.mk以及rabbitmq-plugins.mk使用 erlang.mk 插件工具。请参阅下文了解这些文件的描述。

erlang.mk

本地副本erlang.mk。这不是香草副本,因为 RabbitMQ 依赖于一些修改,这些修改在撰写本文时尚未合并到上游。这就是为什么ERLANG_MK_REPOERLANG_MK_COMMIT目前被覆盖。

rabbitmq-components.mk

本地副本rabbitmq-components.mk。原始文件位于rabbitmq-common您的插件将自动依赖于该文件。它包含其他 erlang.mk 扩展和帮助程序,必须在erlang.mk包含之前定义。此文件必须与rabbitmq-common保持同步:当它过时时,您将收到以下错误

error: rabbitmq-components.mk must be updated!

在这种情况下,只需运行以下命令来更新您的副本

make rabbitmq-components-mk
rabbitmq_metronome.schema

Cuttlefish 配置架构。用于将 配置文件 转换为 RabbitMQ 及其运行时使用的内部格式。

节拍器架构包含 metronome.exchange 设置的映射,用于设置插件使用的交换器。

启用插件后,将重新生成配置。如果插件尚未启用,则配置中的插件特定值将导致错误。

有关编写架构文件的更多信息,请参见 Cuttlefish 文档

src/rabbit_metronome.erl

Erlang“应用程序”行为的实现。为 Erlang VM 提供启动和停止插件的方法。

src/rabbit_metronome_sup.erl

Erlang“Supervisor”行为的实现。监视工作进程并在其崩溃时重新启动它。

src/rabbit_metronome_worker.erl

插件的核心。Worker 将在内部连接到 Broker,然后创建一个每秒触发一次的任务。

test/metronome_SUITE.erl

插件的自动化测试。

开发过程

运行 make 构建插件

make

要启动一个节点,其中插件已构建并在以下位置启用

make run-broker

要确保新插件已启动并正在运行,请运行以下命令

rabbitmq-diagnostics status

如果您的插件已成功加载,您应该在已启用插件列表中看到它

# => Plugins
# =>
# => Enabled plugin file: /var/folders/gp/53t98z011678vk9rkcb_s6ph0000gn/T/rabbitmq-test-instances/rabbit@warp10/enabled_plugins
# => Enabled plugins:
# =>
# => * rabbitmq_metronome
# => * amqp_client

要运行 Common Test 测试套件,请使用

make tests

最后,您可以生成一个 .ez 文件,适合分发

DIST_AS_EZS=yes make dist

该文件出现在plugins存储库根目录下的目录中。

© . All rights reserved.