背景

• 可以将 MQTT 消息和事件存储到 Redis 中，来实现 MQTT 业务的实时统计业务
• 可以使用 redis 来观察 MQTT 每个主题丢失的消息

参考

• EMQx 将 MQTT 数据写入到 Redis

操作

• MQTT 集群中创建 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