文档中心

云原生消息引擎

最佳实践

实时获取主题下丢弃的消息条数

实时获取主题下丢弃的消息条数

本文阐述如何在 MQTT 产品中实时获取主题下丢弃的消息条数。

背景信息

将 MQTT 消息和事件存储到 Redis 中，来实现 MQTT 业务的实时统计业务。

使用 Redis 来观察 MQTT 每个主题丢失的消息。

参考信息

EMQX 将 MQTT 数据写入到 Redis。

操作步骤

在 MQTT Dashboard 中创建 Redis 类型连接器。

配置以下连接器信息，详细操作请参见创建连接器。

连接器名称

服务器地址

用户名、密码

测试连接，显示连接成功。

配置 Redis 命令模版。

导出 dropped_count 到 Redis 中。

HINCRBY emqx_message_dropped_count ${topic} 1

配置 MQTT SQL 输出。

SELECT
*
FROM
"$events/message_dropped", "$events/delivery_dropped"

使用 MQTTX 模拟 Client 向 MQTT 集群发送数据。

成功发送 4 条数据，本例子中无人订阅，均被丢弃。

用开源 Redis UI 客户端连接到 Redis 集群，观察到 dropped_count 增加了 4。

Field
Value
TTL
t/2
4
No Limit

最近更新时间：2025.08.04 17:30:06

这个页面对您有帮助吗？

有用

有用

无用

无用