IM群聊消息究竟是存1份(即扩散读)还是存多份(即扩散写)？

1、前言

IM的群聊消息，究竟存1份（即扩散读方式）还是存多份（即扩散写方式）？

上一篇文章《IM群聊消息的已读回执功能该怎么实现？》里说，“很容易想到，是存一份”，被网友们骂了，大家争论的很激烈（见下图）。



网友骂的对，任何技术方案，都不是天才般灵感乍现想到的，一定是一个演进迭代，逐步优化的过程。今天就聊一聊，IM群聊消息，为啥只需要存一份。

不过，从公开的技术资料来看，微信的群聊消息应该使用的是存多份（即扩散写方式），详细的方案可以在微信团队分享的这篇文章里找到答案：《微信后台团队：微信后台异步消息队列的优化升级实践分享》。

2、本文作者

沈剑：58技术委员会主席，58高级架构师，58到家技术总监。C2C技术部负责人，58技术学院优秀讲师。

沈剑的另外几篇有关IM的文章也值得你去阅读：

• 《理论联系实际：一套典型的IM通信协议设计详解》
• 《IM群聊消息的已读回执功能该怎么实现？》
• 《IM开发基础知识补课(三)：快速理解服务端数据库读写分离原理及实践建议》
  

3、IM开发干货系列文章

本文是系列文章中的第15篇，总目录如下：

• 《IM消息送达保证机制实现(一)：保证在线实时消息的可靠投递》
• 《IM消息送达保证机制实现(二)：保证离线消息的可靠投递》
• 《如何保证IM实时消息的“时序性”与“一致性”？》
• 《IM单聊和群聊中的在线状态同步应该用“推”还是“拉”？》
• 《IM群聊消息如此复杂，如何保证不丢不重？》
• 《一种Android端IM智能心跳算法的设计与实现探讨（含样例代码）》
• 《移动端IM登录时拉取数据如何作到省流量？》
• 《通俗易懂：基于集群的移动端IM接入层负载均衡方案分享》
• 《浅谈移动端IM的多点登陆和消息漫游原理》
• 《IM开发基础知识补课(一)：正确理解前置HTTP SSO单点登陆接口的原理》
• 《IM开发基础知识补课(二)：如何设计大量图片文件的服务端存储架构？》
• 《IM开发基础知识补课(三)：快速理解服务端数据库读写分离原理及实践建议》
• 《IM开发基础知识补课(四)：正确理解HTTP短连接中的Cookie、Session和Token》
• 《IM群聊消息的已读回执功能该怎么实现？》
• 《IM群聊消息究竟是存1份(即扩散读)还是存多份(即扩散写)？》（* 本文）
• 《IM开发基础知识补课(五)：通俗易懂，正确理解并用好MQ消息队列》
• 《一个低成本确保IM消息时序的方法探讨》
• 《IM开发基础知识补课(六)：数据库用NoSQL还是SQL？读这篇就够了！》
• 《IM里“附近的人”功能实现原理是什么？如何高效率地实现它？》
• 《IM开发基础知识补课(七)：主流移动端账号登录方式的原理及设计思路》
• 《IM开发基础知识补课(八)：史上最通俗，彻底搞懂字符乱码问题的本质》
• 《IM的扫码登功能如何实现？一文搞懂主流应用的扫码登陆技术原理》
• 《IM要做手机扫码登陆？先看看微信的扫码登录功能技术原理》
• 《IM开发基础知识补课(九)：想开发IM集群？先搞懂什么是RPC！》
• 《IM开发实战干货：我是如何解决大量离线聊天消息导致客户端卡顿的》
• 《IM开发干货分享：如何优雅的实现大量离线消息的可靠投递》
  

另外，如果您是IM开发初学者，强烈建议首先阅读《新手入门一篇就够：从零开发移动端IM》。

4、更多关于IM群聊的文章

IM系统中的群聊功能，是个很大话题，下面几篇在关群聊的文章您也可以读一读：

• 《如何保证IM实时消息的“时序性”与“一致性”？》
• 《IM单聊和群聊中的在线状态同步应该用“推”还是“拉”？》
• 《IM群聊消息如此复杂，如何保证不丢不重？》
• 《微信后台团队：微信后台异步消息队列的优化升级实践分享》
• 《移动端IM中大规模群消息的推送如何保证效率、实时性？》
• 《现代IM系统中聊天消息的同步和存储方案探讨》
• 《关于IM即时通讯群聊消息的乱序问题讨论》
• 《IM群聊消息的已读回执功能该怎么实现？》
• 《一套高可用、易伸缩、高并发的IM群聊架构方案设计实践》
  

>> 更多同类文章 ……

另外，《一套海量在线用户的移动端IM架构设计实践分享(含详细图文)》一文中也包含了群聊的完整设计，如果您设计IM不知从何下手，可以详细地参考此文。

5、最基本的方案：“在线的群友不存储消息，离线的群友才存储”

群信息，用户信息，群成员关系都是基础数据：

group_info(gid, group_info);
user_info(uid, user_info);
group_members(gid, uid);

假设一个群(gid)里有4个成员，其中三个在线(A, uid1, uid2)，一个不在线(uid3)。

A发送了一条消息，很容易想到，对于不同的群友消息存多份，每个群友一个队列来存储。但由于在线的用户会实时的收到消息，所以暂定只为离线的用户存储。

用户收到的群消息，也是基础数据：

user_msgs(uid,msgid,gid,sender_uid,time,content);

很容易想到，整个群消息的发送流程如上图1-4：

• 1）发送消息；
• 2）查询状态；
• 3）不在线的存储离线；
• 4）在线的实时推送。
  

“在线的群友不存储，离线的群友才存储”会带来的问题是，如果第四步发生异常，群友会丢失消息。

6、优化的方案：“不管群员是否在线，都要先存储消息”

消息的可达性是聊天系统中最重要的要素（没有之一），故这个方案是不行的，需要优化为“不管是否在线，都要先存储”。



发送群消息的流程优化为，如上图1-4：

• 1）发送消息；
• 2）所有人都存一份；
• 3）查询状态；
• 4）在线的实时推送。
  

先将消息落地，能够保证消息可达性，那何时才能删除已经落地的群消息呢？我们继续往下看。



对于在线的群友：收到群消息后，给个ack确认才能删除。

画外音：逻辑删除，还是物理删除，根据业务是否有消息漫游决定。



对于离线的群友：在下次登陆后，拉取完离线消息再给ack确认才能删除。

总之：为了保证消息的可达性，不管是在线消息还是离线消息，必须接收方给ack确认，才能删除消息。

7、“不管群员是否在线，都冗余一份群消息”带来的问题

“不管是否在线，都冗余一份群消息”带来的问题是：同一条消息存储了很多次，对磁盘和带宽造成了很大的浪费。

很容易想到的优化是：群消息实体存储一份，用户只冗余消息ID。



故基础数据可以由：

user_msgs(uid,msgid,gid,sender_uid,time,content);
优化为：
group_msgs(msgid,gid,sender_uid,time,content);
user_msgs(uid, msgid, gid);

这个优化，对于消息投递，以及消息删除的核心流程没有影响，几个实践为：

• 在线用户投递消息实体，ack消息ID；
• 离线用户先拉取消息ID，再拉取消息实体，再ack消息ID。
  

如此这般，假如在某个群友A期间，群里陆续发送了N条消息，则user_msgs(uid, msgid, gid)里，会有 uidA -> mid1,mid2, mid3, … midN 等N条离线记录，拉取离线消息时，可以把这N条消息一次性拉取出来，然后再删除：

delete from user_msgs  where msgid in($mid1,$mid2…, $midN) and gid=$gid

8、终级方案：利用群消息的“偏序”特性优雅地实现“只存1份”

然而，群消息具备“偏序”特性，上面的一次性删除完全可以优化为：

delete from user_msgs
where msgid >= $mid1 and gid=$gid

这就意味着，每个用户只需要记录“最近一次收到的消息ID”，而不用记录“所有未收到的消息ID集合”，每当收在线消息ack，以及拉离线消息ack时，只需要更新这个“最近一次收到的消息ID”即可。

于是乎，基础数据可以由：
group_members(gid, uid);
group_msgs(msgid,gid,sender_uid,time,content);
user_msgs(uid, msgid, gid);

优化为：
group_members(gid, uid, last_ack_msgid);
group_msgs(msgid,gid,sender_uid,time,content);
user_msgs(uid, msgid, gid); // 不再需要


即：群消息只存储一份，群友无需冗余任何消息实体，或者消息ID了。


对于在线的群友：收到群消息后，修改这个last_ack_msgid。


对于离线的群友：拉取群消息后，也修改这个last_ack_msgid。

画外音：这里的讨论，仅限于接收方收到了哪些消息，和发送方的已读回执没有关系。（这里指的是作者的上篇文章《IM群聊消息的已读回执功能该怎么实现？》）

9、本文小结

任何架构方案都不是灵光一现，而是逐步迭代优化产生的：

• 方案1：群聊消息存多份，只存在线，消息容易丢；
• 方案2：群聊消息存多份，所有群友都存储，消息冗余多；
• 方案3：群聊消息存多份，只存ID，未利用偏序；
• 终极方案：群聊消息存一份，只存last_ack_msgid。
  

架构不（只）是设计出来的，更是演进出来的。

（原文链接：点此进入，有改动）

这篇文章最终方案就是把写扩散变成了读扩散。对于第7点，消息删除的时候只提到user_msgs的删除，那group_msgs表的数据什么时候删除呢？

delete from user_msgs  where msgid in($mid1,$mid2…, $midN) and gid=$gid

引用：JackJiang 发表于 2025-06-17 11:28
高并发和顺序，其实是矛盾的，如果真的为了保证绝对有序性，那就只能在业务层实现有向环队列。

不过， ...

嗯嗯，谢谢Jack

引用：andy23 发表于 2025-06-17 11:14
关于同步，我有一个问题，当客户端发送的顺序，消息服务多线程消费，可能出现入库和同步到客户端顺序不一致 ...

高并发和顺序，其实是矛盾的，如果真的为了保证绝对有序性，那就只能在业务层实现有向环队列。

不过，im就是人在聊天说话，是有上下文的，偶尔的乱序，一是可以在客户端根据有序id号重整顺序，二是极端情况下极少概率顺序真的乱了，问题也不大，必竟，看不懂你可以让对方再发一次啊。

im在设计的时候，是可以接受万有一失原则的。

关于同步，我有一个问题，当客户端发送的顺序，消息服务多线程消费，可能出现入库和同步到客户端顺序不一致的现象。一般怎么处理比较好呢。

终极方案是不是和http://www.52im.net/forum.php?mod=viewthread&tid=1230这个文章冲突了，因为有收件箱了

当同时有单聊和群聊的时候，单聊用的是写扩散，有收信箱，群聊好像存储方式又不同，这里的会话列表设计应该是什么样的呢，两者结合又需要根据时序。。

引用：researchboy 发表于 2018-07-09 20:27
我们现实方案与最后一种方案不谋而合

这有个问题，就是重连初始化更新会话列表状态信息时，读扩散的话就会去拉取每个会话和计算未读。有点麻烦。

目前在遇到一个困扰，如果是维护一个last_id。
假设发生了这种场景，last_id + 1消息在中途丢失了，而last_id + 3 消息先达到客户端，客户端先收到了last_id +3的消息，而丢失了后面两个消息。

是不是客户端必须实现类似于滑动窗口这种去重机制，同时还必须搭配比较强的全局唯一自增id才能解决。有没有更廉价的方案，比如，只需要id自增，而不需要严格连续。

终极方案里，假设id递增的msg1，msg2，msg3；msg3应答了，msg2没有应答；这时last_ack_msgid该怎么处理呢？

暂时想到客户端存储一个最后一次离线消息ID， 没有按照离线消息ID 批量拉取消息，然后去重，不知道有什么更好的设计方法，这样子每个消息被多拉了1次。

优化为：
group_members(gid, uid, last_ack_msgid);
group_msgs(msgid,gid,sender_uid,time,content);
user_msgs(uid, msgid, gid); // 不再需要
-----------------------------

这里好像没考虑多终端在线的情况吧？last_ack_msgid跟用户id层面绑定的话

引用：1mok 发表于 2019-03-06 18:06
服务端肯定是可以计算出，但问题的关键是效率。一个人的会话数很多的时候（无限建群模式），如何快速找到 ...

消息同步模型，如果是有新消息来，先推送新消息的通知给接收端，接收端来从库里面拉取消息。
如果在读扩散的模型下， 推送新消息通知的时候带上群ID或者发送方ID，然后接收端按照群ID来拉取消息，不知道这样的做法是不是可以解决找到未读消息的会话列表。

引用：sidney 发表于 2021-05-06 19:35
终极方案的群成员只有在一个群只记录一个last_ack_msgid   怎么处理群成员在离线情况下，用户被频繁的拉进 ...

不用想这么复杂，就保留最后一个操作记录就好了。
用产品经理的话说：哪有那么多神经病，一会进群、一会被踢、一会又拉进群。。。。

终极方案的群成员只有在一个群只记录一个last_ack_msgid   怎么处理群成员在离线情况下，用户被频繁的拉进群、踢出群、还能正确的只拉取到在群期间应该看到的消息？
例如 群聊A里面发送了消息1、2 、3 、4、5 、 6 、7 、 8 、9
用户在消息2之后3之前被拉进了群聊A，然后再消息4之后5之前踢出了群聊A又在消息7之后8之前拉进了群聊A
当用户再次上线时应该收取到群聊A的消息3、 4 、 8、 9

引用：weixiaoyao 发表于 2021-03-30 17:49
Jack Jiang就是沈剑老师么？

不是

Jack Jiang就是沈剑老师么？

引用：GarageBand 发表于 2020-11-03 11:53
比如说一个用户有八个群，是每个群都对应一个last_ack_msgid，还是所有群对应一个last_ack_msgid？

从技术实现的复杂度上来说，如是能做到全局唯一消息id的话，所有群用一个id是最简单经济的

引用：JackJiang 发表于 2020-09-04 21:31
是的

比如说一个用户有八个群，是每个群都对应一个last_ack_msgid，还是所有群对应一个last_ack_msgid？

引用：张小驰_q6jys 发表于 2020-10-29 15:35
微信生成消息ID 里提到按用户生成msgid，那群消息只存一份，群中各个用户的msgid和群消息是如何关联的？

群消息是一个表，每个群还有个群成员表，在群成员表上针对各人做文章

微信生成消息ID 里提到按用户生成msgid，那群消息只存一份，群中各个用户的msgid和群消息是如何关联的？

引用：GarageBand 发表于 2020-09-04 20:11
客户端拉取携带服务端返回给他最新的last_ack_msgid，服务端只返回比last_ack_msgid大的消息列表给客户端？ ...

是的