- 服务器需要安装
Redis 5.0
或以上版本。
- 基于 redis stream(轻量级MQ)实现 mqtt 集群,仅供参考请按实际情况选择MQ。
- 基于 redis 实现客户端状态存储。
- 基于 redis 实现遗嘱、保留消息存储。
- 修改 auth 包下的 MqttAuthHandler、MqttSubscribeValidator 和 MqttHttpAuthFilter 认证实现。
- 上行消息(设备 -> 云端)在 MqttMessageServiceImpl 中添加业务逻辑。
- 下行消息(云端 -> 设备)云端 Message 到
mqtt:channel:down
(详见:RedisKeys
) 即可。
注意:云端发送到设备不指定 clientId 会按 topic 订阅关系进行广播消息到设备。