AMQP RabbitMQ 性能指标

“高级消息队列协议” (AMQP) 的缩写，是一种开放标准，用于根据需要在应用程序之间来回传递业务消息。它是 RabbitMQ 的核心协议，而 RabbitMQ 本身就是一个消息代理。STORM（一种简单的、基于文本的消息协议）、MQTT（一种以轻量级消息传递而闻名的二进制协议）和 HTTP 都通过使用专门设计的插件，在某种程度上使用了 AMQP。

AMQP 值得关注，因为它实现了组织及其应用程序之间的加密和互操作消息传递——这在当今快节奏、移动驱动的世界中已变得至关重要。请注意，该协议也用于传递客户端/服务器消息，并且也用于物联网 (IoT) 设备管理。

效率、可移植性和安全性都是 AMQP 带来的主要优势。二进制协议通过 SASL 或 TLS 实现身份验证和加密，而 SASL 或 TLS 本身依赖于 TCP 等传输协议。总的来说，消息传递协议本身速度很快，并具有通过确认接收到的消息来保证交付的功能——确保绝对不允许任何消息遗漏。AMQP 也适用于多客户端环境，并提供了一种机制，可以将任务委派给必要的各方，并使服务器能够比优先级不太高的请求更快地处理即时请求。

AMQP Consumer Telegraf 输入插件，扩展而言，使消费者能够通过与 AMQP 0-9-1 兼容的代理（RabbitMQ 可能是最突出的例子）从 AMQP 消息生产者接收流数据。

为什么将 Telegraf 插件用于 AMQP Consumer？

只有通过 AMQP Consumer Telegraf 输入插件才能解锁大量与通信相关的优势。其中最主要的是，您现在可以直接从 PostgreSQL 发布消息，从而更好地跟踪事件消息，甚至以一种使每个人都易于访问和理解的方式发布 IoT 传感器数据。

这使您的团队成员处于理想的位置，不仅可以跟踪性能，还可以全面提高效率，从而创造最佳的最终用户体验。

如何使用 AMQP Consumer Telegraf 输入插件构建您的监控解决方案

如前所述，AMQP Consumer Telegraf 插件为消费者提供了通过与 AMQP 0-9-1 兼容的代理（如前面提到的 RabbitMQ）接收流数据的能力。指标是从使用队列 binding_key 的主题交换中读取的。

消息有效负载应以 Telegraf 数据格式之一格式化，其中 InfluxDB Line Protocol、Collectd、CSV、Graphite、JSON 和 Nagios 是主要候选格式。还有许多不同的配置选项可供选择，例如

• 交换类型（direct、fanout、topic、header 或 x-consistent hash）
• 交换持久性（transient 或 durable）
• 交换参数（{"hash_property" = "timestamp"}）

请注意，您还可以使用三个不同的 AMQP/RabbitMQ Telegraf 插件来构建您自己的解决方案 - 这更符合您作为组织的期望。在此过程中您将使用的值得注意的命令包括

• outputs.amqp - 将指标写入 AMQP 交换
• inputs.amqp_consumber - 从 AMQP 队列读取指标
• inputs.rabbitmq - 从 RabbitMQ 收集运行时指标

用于监控的关键 AMQP Consumer 指标

您应考虑关注的一些关键 AMQP Consumer 指标，以便最大限度地利用您的部署，包括

• 发布者，即消息代理从中获取消息的应用程序
• 消费者，即处理这些消息的应用程序
• 生产者，即发布这些消息的应用程序
• 队列，即消息分发到的机器
• 绑定，即队列用于在交换上正确分发消息的规则
• 消息属性，也称为消息元数据
• 持久性，即跟踪在代理重启后仍然存在的交换
• 参数，可用于跟踪特定于代理的功能

项目 URL   文档