1）为毛不用websocket？

原生WebSocket服务单机支撑万级连接就会出现内存、线程瓶颈；

移动端、IoT设备弱网环境频繁断连是常态：WebSocket断连后所有未推送消息直接丢失，需要业务手动缓存重推。

MQTT服务EMQX基于Erlang轻量进程模型，单机轻松支撑百万级并发长连接，内存占用极低，海量设备、多用户在线场景碾压WebSocket；

MQTT原生支持QoS1/QoS2消息持久化，断连重连后自动补发未接收消息，弱网场景无需自己写缓存逻辑。

2）主题订阅模型（实现私聊、群聊、广播）

MQTT采用分层主题通配符设计，天然适配各类通讯场景，无需复杂关系存储：

　　个人私有消息：msg/user/{userId}，仅当前用户订阅，实现一对一私聊；

　　 群聊频道：msg/group/{groupId}，群内所有用户订阅，群发消息；

　　全局系统广播：msg/system/all，全部在线用户接收公告；

　　分类通知：msg/order/{userId}、msg/notice/{userId}，按业务模块隔离消息。

　　通配符+单层匹配、#多层匹配，灵活批量订阅多类消息。

3）QoS消息质量等级，解决消息丢失痛点

　　QoS0（最多一次）：消息发完即丢弃，不重试，适合实时性要求高、丢失无影响的普通在线通知；

　　QoS1（至少一次）：保证消息一定送达，可能重复接收，适合聊天消息、业务告警；

　　 QoS2（恰好一次）：握手确认，只接收一次，适合订单、支付、设备上报等不能重复的核心数据。

4）会话持久化 + 离线消息缓存

客户端连接时开启cleanSession=false，broker会保存当前订阅关系与未接收消息。

用户APP退出、断网、后台杀进程，所有未读消息全部缓存；

下次重新建立连接，自动批量推送离线消息，完美实现“离线存消息，上线自动读”，不用业务层额外存储。

5）遗嘱消息（异常下线自动通知）

客户端建立连接时预先设置遗嘱主题与消息，当客户端无心跳、网络异常、崩溃离线，broker自动向遗嘱主题发送预设消息，服务端可监听该主题，实时感知用户离线状态，替代复杂的心跳检测逻辑。

6）心跳保活机制

连接时指定心跳间隔，客户端定时上报心跳，长时间无心跳broker判定离线，精准管理连接状态，相比WebSocket自定义心跳逻辑更标准、低开销。