几万条群离线消息，如何高效拉取？（第111讲，万字收藏）

《架构师之路：架构设计中的100个知识点》

111.群离线消息架构

图片

继续回答星球提问：

1. 群离线消息是推还是拉？

2. 几万条群离线消息，怎么保证不丢失？

画外音：欢迎大家加入星球提问（免费）。

群离线消息，是推还是拉？

关于写扩散、读扩散的问题，之前专门撰文写过，今天重点说说设计的思考过程。

假如群离线是推，流程应该如何？会遇到什么问题？

先看看群离线消息的核心数据结构。

群成员表：

t_group_users(group_id, user_id)

画外音：用来描述一个群里有多少成员。

群离线消息表：

t_offine_msgs(user_id, group_id, sender_id,time, msg_id, msg_detail)

画外音：用来描述一个群成员的离线消息。

推，写扩散，存储群离线消息的过程如何？

1. 先从群成员表中，获取群里有多少个用户；

2. 从某个服务中，获取这些用户有多少个不在线；

3. 将群消息，插入到这些用户的群离线消息表；

画外音：如果要支持消息漫游，则可以省略步骤二。

此时，用户拉取离线消息的过程如何？

1. 用户登录，向server拉取离线消息；

2. server返回并删除离线消息；

离线消息推，存在什么问题？

对于同一份群消息的内容，多个离线用户要存储很多份。假设群中有200个用户离线，离线消息则冗余了200份，这极大的增加了数据库的存储压力。

如何优化，减少消息冗余量？

为了减少离线消息的冗余度，增加一个群消息表，用来存储所有群消息的内容，离线消息表只存储用户的群离线消息msg_id，就能大大的降低数据库的冗余存储量。

群消息表：

t_group_msgs(group_id, sender_id, time, msg_id, msg_detail)

画外音：用来存储一个群中所有的消息内容。

群离线消息表，需要进行优化：

t_offine_msgs(user_id, group_id, msg_id)

画外音：优化后只存储msg_id。

这样优化后，群消息的发送和存储要做一些升级：

1. 每次发送群消息之前，先存储群消息的内容；

2. 每次存储离线消息时，只存储msg_id，而不用为每个用户存储msg_detail；

相应的，拉取离线消息也要做对应的升级：

1. 先拉取所有的离线消息msg_id；

2. 再根据msg_id拉取msg_detail；

3. 删除时，只删除自己的离线msg_id，而不删除msg_detail；

画外音：毕竟msg_detail只存储了一份，不能随便删。

上述过程，能保证离线消息的可达性么？

不能。

例如：server返回客户端离线消息之后，删除了离线消息，但客户端没有展现就崩溃了，离线消息就会丢失。

如何解决离线消息可达性呢？

很容易想到，通过ACK机制，server返回离线消息之后，不能立刻删除离线消息，而必须等客户端ACK，才能删除。

此时，离线消息拉取升级为：

1. 用户登录，向server拉取离线消息；

2. server返回离线消息；

3. 客户端确认收到了离线消息；

4. server再删除离线消息；

画外音：增加了3和4两个步骤。

还有一个问题，一次有几十个群，每个群有几千条离线消息，共计几万条群离线消息，消息量过大怎么办？

当然不能一次性拉取，可以：

1. 分群拉取；

2. 每个群分页拉取；

3. 拉取一页，删除一页，拉取下一页，删除下一页...

如果拉取了消息，却没来得及应用层ACK，会收到重复的消息么？

可以在客户端去重，对于重复的msg_id，对用户不展现，从而不影响用户体验。

图片

如上所示，简单总结就是：

1. 群消息表存储消息实体msg_detail；

2. 群离线消息表，存每个用户的msg_id；

3. 分页拉取+应用层ACK，既保证性能，又保证消息可达性；

4. 客户端msg_id去重，保证用户体验；

上面讲的都是“推”模式，群离线消息的设计，真正线上应用较多的，是“拉”模式。

推模式，存在什么问题？

对于离线的每一条消息，虽然只存储了msg_id，但是每个用户的每一条离线消息都将在数据库中保存一条记录，有没有办法减少离线消息的记录数呢？

对于一个群用户，在ta登出后的离线期间内，肯定是所有的群消息都没有收到的，完全不用对所有的每一条离线消息存储一个离线msg_id，而只需要存储最近一条拉取到的离线消息的time（或者msg_id），下次登录时拉取在那之后的所有群消息即可，而完全没有必要存储每个人未拉取到的全部离线消息msg_id。

拉模式，需要对数据结构进行怎样的升级？

群成员表，增加一个属性：

t_group_users(group_id, user_id, last_ack_msg_id)

画外音：用来描述一个群里有多少成员，以及每个成员最后一条ack的群消息的msg_id（或者time）。

群消息表，不变：

t_group_msgs(group_id, sender_id, time, msg_id, msg_detail)

画外音：还是用来存储一个群中所有的消息内容。

群离线消息表：不再需要。

使用拉模式后，群消息的发送和存储也要升级：

1. 在消息msg_detail存储到群消息表后，不再需要操作离线消息表（之前需要将msg_id插入离线消息表）；

2. 用户收到消息，应用层ACK后，将last_ack_msg_id更新（之前需要将msg_id从离线消息表删除）；

图片

群离线消息的拉取流程也类似：

1. 分页拉取离线消息；

2. ACK离线消息；

3. 更新last_ack_msg_id；

总结

群消息还是非常有意思的，做个简单总结：

1. 群离线消息一般采用拉取模式，只存一份，不需要为每个用户存储离线群msg_id，只需存储一个最近ack的群消息id/time；

2. 为了保证消息可达性，在线消息和离线消息都需要ACK；

3. 离线消息过多，可以分群拉取、分页拉取等优化；

画外音：还可按需拉取，登录不拉取，点进群再拉取。

4. 如果收到重复消息，需要msg_id去重，让用户无感知；

群离线消息架构架构设计要点，你学废了吗？

知其然，知其所以然。

思路比结论更重要。