58到家实时消息平台架构：从早期到高性能演进

“云计算应用开发与运维专题论坛-任桃术 58到家实时消息平台架构实现细节.pdf”主要探讨了58到家在构建其实时消息平台过程中的架构设计与优化实践，由58到家架构部底层组负责人任桃术在第十届中国云计算大会上分享。 在业务背景部分，58到家的实时消息平台主要用于解决速运业务中的司机GPS实时位置上报以及订单的即时推送，同时也支持用户与商家、用户与客服、商家与客服之间的即时沟通。这一需求对消息系统的实时性、稳定性和到达率提出了高要求。 早期的架构存在一些问题，如Web-Server性能瓶颈，MQTT的单点故障，以及第三方推送服务在及时性、限速和可达性上的不足。因此，58到家构建了自己的实时消息平台，旨在实现高性能、高可用和高到达率。 58到家的消息平台采用分层设计，主要包括msg-Gate和msg-Logic两部分。msg-Gate负责连接整流、会话管理及安全防护，msg-Logic处理登录、登出、在线状态和离线消息拉取等逻辑。为了提高性能，采用了TCP长连接、异步化处理，并利用Redis存储在线状态。同时，通过部署多个msg-Gate实例来确保高可用性，使用gate-Detector监控整个系统。 核心业务流程包括用户登录消息平台、客户端到服务器(C2S)消息、服务器到客户端(S2C)消息，以及客户端到客户端(C2C)消息的处理。登录时，msg-Gate会扩展并保证高可用，使用appcode（端+用户体系）记录登录状态。C2S消息通过通用消息平台解耦，消息类型映射到DMQ主题。S2C消息通过msg-Gate实时推送，并统计到达率。对于C2C消息，考虑到移动端网络环境的不稳定性，优化了发送方体验，并处理离线消息。 离线消息的存储设计是消息平台的关键部分，包括msgid（唯一ID）、to_uid（接收用户ID）、to_appcode（接收用户使用的appcode）、from_uid（发送用户ID）、from_appcode（发送用户使用的appcode）、senddate（消息发送时间）和msgcontent（消息内容）等字段。离线消息的拉取采用小批量、全量且不重复的策略，确保用户上线后能完整获取所有消息。 58到家的实时消息平台架构实现细节涵盖了业务需求分析、早期架构的问题与挑战、新架构的设计原则、关键组件的功能、以及核心业务流程和离线消息处理机制。这个架构展示了如何通过技术创新和优化来满足云计算环境下的大规模实时消息传输需求。