NanoMQ中QoS 1/2消息持久化与会话管理机制解析

核心机制概述

NanoMQ通过SQLite实现了MQTT协议中QoS 1和QoS 2级别消息的持久化存储，这是保障消息可靠传输的关键设计。当启用SQLite持久化功能后，系统会确保以下两类消息的可靠性：

1. 桥接场景下：所有处于传输窗口(inflight window)中的消息会在连接中断时持久化保存
2. 本地代理场景下：仅QoS 1/2级别的消息会被持久化存储，并在收到接收方ACK确认后自动删除

持久化会话配置要点

要实现完整的离线消息保障（包括代理重启场景），需要同时满足两个条件：

1. 在nanomq.conf中启用SQLite持久化
2. 客户端连接时设置clean_start=false标志

这种配置下，当客户端离线期间：

• 所有发送给该客户端的QoS 1/2消息会被持久化存储
• 客户端重新上线后会自动恢复这些消息的投递
• 系统会保持完整的会话状态（包括订阅关系等）

性能权衡提醒

需要注意的是，启用完整的持久化会话机制会显著影响系统性能。在实际部署时，建议根据业务场景的需求在可靠性和性能之间做出权衡：

• 对可靠性要求高的场景（如金融交易）建议启用
• 对实时性要求高但允许偶发消息丢失的场景（如传感器数据采集）可考虑禁用

最佳实践建议

1. 针对不同的客户端群体采用差异化配置：

   • 关键业务客户端：启用持久化+clean_start=false
   • 普通数据采集端：可禁用持久化或使用clean_start=true

2. 监控SQLite存储增长：

   • 定期检查持久化消息的堆积情况
   • 对长期离线的客户端考虑设置消息过期策略

3. 性能调优方向：

   • 调整SQLite的同步模式（WAL模式性能更好）
   • 合理设置消息存储时限
   • 考虑使用更高性能的存储介质