【系统架构设计百科】长连接与推送架构：WebSocket、SSE 与 MQTT
💡
原文中文，约24600字，阅读约需59分钟。
📝
内容提要
现代应用需要实时推送技术，如WebSocket、SSE和MQTT，以满足在线聊天、股票行情和物联网等需求。WebSocket支持全双工通信，SSE用于单向推送，MQTT适合物联网。推送系统需解决连接管理、心跳检测和消息可靠性等问题，选择合适的协议和架构设计至关重要。
🎯
关键要点
- 现代应用需要实时推送技术，如WebSocket、SSE和MQTT，以满足在线聊天、股票行情和物联网等需求。
- WebSocket支持全双工通信，适合需要双向数据传输的场景。
- SSE用于单向推送，适合服务端主动向客户端发送数据的场景。
- MQTT是面向物联网的轻量级协议，适合低带宽和不稳定网络环境。
- 推送系统需解决连接管理、心跳检测和消息可靠性等问题，选择合适的协议和架构设计至关重要。
❓
延伸问答
WebSocket、SSE和MQTT的主要区别是什么？
WebSocket支持全双工通信，适合双向数据传输；SSE用于单向推送，适合服务端主动发送数据；MQTT是轻量级协议，适合物联网，支持低带宽和不稳定网络。
在什么场景下应该选择MQTT协议？
MQTT适合物联网和低带宽、不稳定网络环境，特别是需要可靠消息传递的场景。
SSE协议的自动重连机制是如何工作的？
SSE内置断线重连机制，浏览器会自动尝试重连，并在请求头中携带Last-Event-ID，以便服务端从断点处继续推送。
WebSocket的心跳机制是怎样的？
WebSocket使用Ping/Pong机制，任何一方可以发送Ping帧，另一方必须回复Pong帧，以保持连接活跃。
推送系统中如何处理消息的可靠性？
推送系统需要引入ACK机制，确保消息在发送后得到确认，并使用离线消息队列处理客户端不在线的情况。
如何设计一个支持百万长连接的推送系统？
可以使用epoll事件驱动模型和Go语言的goroutine模型，优化内存使用，分离连接层和业务层以提高扩展性。
➡️
