EMQX 可观测性最佳实践

EMQX 介绍

EMQX 是一款开源、高度可伸缩、高可用的分布式 MQTT 消息服务器，同时也支持 CoAP/LwM2M 等一站式 IoT 协议接入。以下是 EMQX 的一些主要特点和功能：

海量连接与高并发：EMQX 能够处理千万级别的并发客户端，支持大规模分布式架构，具有高可用集群架构和弹性伸缩部署。
多协议支持：EMQX 完整支持 MQTT V5.0 协议规范，并向下兼容 MQTT V3.1 和 V3.1.1。此外，它还可以扩展支持 MQTT-SN、CoAP、LwM2M、WebSocket、STOMP 或私有 TCP 等多种物联网协议。
规则引擎与数据集成：EMQX 内置强大的规则引擎，可以进行数据提取、过滤与转换，并灵活集成 SQL、NoSQL、时序数据库以及 Kafka 等流处理中间件。
边缘到云端的部署：EMQX 支持从资源受限的边缘计算设备到私有云、混合云和公共云的部署，包括物理机、VM、容器/K8S 跨平台任意部署。
完全开源：EMQX 基于 Apache Version 2.0 开源协议，支持开源免费使用，适用于产品原型设计、物联网创业公司以及大规模的商业部署。
安全性：EMQX 提供端到端数据加密（支持国密）、细粒度访问控制，保障数据安全，满足企业合规需求。
易运维：EMQX 提供图形化配置、操作与管理，实时监测运行状态，并支持 MQTT 跟踪进行端到端问题分析。
云原生支持：EMQX 支持通过 Kubernetes Operator 和 Terraform 在企业内部和公共云中进行部署。
产品线：EMQX 提供多种产品，包括 EMQX Broker（开源版）、EMQX Enterprise（企业版）和 EMQX Platform（平台版），以满足不同规模和需求的 IoT 网络和应用。
功能列表：EMQX 支持完整的 MQTT V3.1/V3.1.1 及 V5.0 协议规范，QoS0, QoS1, QoS2 消息支持，持久会话与离线消息支持，Retained 消息支持，Last Will 消息支持，TCP/SSL 连接支持，MQTT/WebSocket/SSL 支持，HTTP 消息发布接口支持等。

EMQX 作为物联网应用开发和物联网平台搭建的基础设施软件，主要在边缘和云端实现物联网设备互联与设备上云，提供物联网设备接入、协议处理、消息路由、数据存储、流数据处理等核心能力。

观测云

观测云是一款专为 IT 工程师打造的全链路可观测产品，它集成了基础设施监控、应用程序性能监控和日志管理，为整个技术栈提供实时可观察性。这款产品能够帮助工程师全面了解端到端的用户体验追踪，了解应用内函数的每一次调用，以及全面监控云时代的基础设施。此外，观测云还具备快速发现系统安全风险的能力，为数字化时代提供安全保障。

安装 DataKit

DataKit 是一个开源的、跨平台的数据收集和监控工具，由观测云开发并维护。它旨在帮助用户收集、处理和分析各种数据源，如日志、指标和事件，以便进行有效的监控和故障排查。DataKit 支持多种数据输入和输出格式，可以轻松集成到现有的监控系统中。

登录观测云控制台，在集成 -> DataKit 选择对应安装方式，当前采用 Linux 主机部署 DataKit。

采集 EMQX 指标

EMQX 默认暴露指标端口为：18083 ，可通过浏览器查看指标相关信息：http://clientIP:18083/api/v5/prometheus/stats 。

由于 EMQX 能够直接暴露 metrics url ，所以可以直接通过 prom 采集器进行采集。进入 DataKit 安装目录 /usr/local/datakit/conf.d ，复制 prom 目录下的配置文件并命名为 emqx.conf 。示例如下：

cp prom.conf.sample emqx.conf

调整内容如下：

[[inputs.prom]]## Exporter URLs.urls = ["http://clientIP:18083/api/v5/prometheus/stats"]source = "emqx"keep_exist_metric_name = true## Customize tags.[inputs.prom.tags]job = "emqx"  
...

调整文档以上参数。

重启 DataKit

systemctl restart datakit

关键指标

统计（Statistics）

Metrics	描述
emqx_connections_count	当前连接数量
emqx_topics_count	当前主题数量
`emqx_suboptions_count`	即 `subscriptions_count`
emqx_subscribers_count	当前订阅者数量
emqx_cluster_nodes_running	集群 `running` 状态的 node
emqx_cluster_nodes_stopped	集群 `stop` 状态的 node

消息 (PUBLISH 报文)

Metrics	描述
emqx_messages_received	接收来自客户端的消息数量，等于 messages.qos0.received，messages.qos1.received 与 messages.qos2.received 之和
emqx_messages_sent	发送给客户端的消息数量，等于 messages.qos0.sent，messages.qos1.sent 与 messages.qos2.sent 之和
emqx_messages_dropped	EMQX 内部转发到订阅进程前丢弃的消息总数

字节 (Bytes)

Metrics	描述
emqx_bytes_received	已接收字节数
emqx_bytes_sent	已发送字节数

报文 (Packets)

Metrics	描述
emqx_packets_connect	接收的 CONNECT 报文数量
emqx_packets_connack_sent	发送的 `CONNACK` 报文数量
emqx_packets_connack_error	发送的原因码不为 0x00 的 `CONNACK` 报文数量，此指标的值大于等于 `packets_connack_auth_error` 的值
emqx_packets_connack_auth_error	发送的原因码为 0x86 和 0x87 的 `CONNACK` 报文数量
emqx_packets_disconnect_sent	发送的 DISCONNECT 报文数量
emqx_packets_disconnect_received	接收的 DISCONNECT 报文数量
emqx_packets_publish_received	接收的 PUBLISH 报文数量
emqx_packets_publish_sent	发送的 PUBLISH 报文数量
emqx_packets_publish_error	接收的无法被发布的 PUBLISH 报文数量
emqx_packets_publish_dropped	超出接收限制而被丢弃的 PUBLISH 报文数量
emqx_packets_subscribe_received	接收的 SUBSCRIBE 报文数量
emqx_packets_subscribe_error	接收的订阅失败的 SUBSCRIBE 报文数量
`emqx_packets_suback_sent`	发送的 `SUBACK` 报文数量
emqx_packets_unsubscribe_received	接收的 UNSUBSCRIBE 报文数量
emqx_packets_unsubscribe_error	接收的取消订阅失败的 UNSUBSCRIBE 报文数量