标记已读
2020-04-29 本文已影响0人
枭龙gogogo
单聊
- 发送方发送一条消息
- 服务端消息入库，检查接收方在线状态。若在线，推送；不在线，接收方登录时拉取
- 接收方收到消息，发送已读回执
- 服务端收到回执并入库，通知发送方
- 发送方更新本地数据库，修改已读状态
群聊
群消息投递流程，以及可达性保证
核心问题
- 群消息，只存一份？还是，每个成员存一份？
存一份 - 如果群消息只存一份，怎么知道每个成员读了哪些消息？
记录每个成员的last_ack_msgid - 如何保证接收方一定收到群消息？
各个群成员收到消息后，要修改各群成员的last_ack_msgid，以告诉系统，这一条消息确认收到了 - 如果ack丢失，群友会不会拉取重复的群消息？
会，可以根据msgid在客户端本地做去重
核心数据结构
- 群消息表：记录群消息。
group_msgs(msgid, gid, sender_uid, time, content);
各字段的含义为：消息ID，群ID，发送方UID，发送时间，发送内容。 - 群成员表：记录群里的成员，以及每个成员收到的最后一条群消息。
group_users(gid, uid, last_ack_msgid);
各字段的含义为：群ID，群成员UID，群成员最后收到的一条群消息ID。
群消息发送的流程
群消息发送的流程
- A发出群消息
- server收到消息后，一来要将群消息落地，二来要查询群里有哪些群成员，以便实施推送
- 对于群成员，查询在线状态
- 对于在线的群成员，实施推送
群消息确认流程
在线成员
离线成员
已读回执流程
对于发送方发送的任何一条群消息，都需要知道，这条消息有多少人已读多少人未读，就需要一个基础表来记录这个关系。
消息回执表：用来记录消息的已读回执。
msg_acks(sender_uid, msgid, recv_uid, gid, if_ack);
各字段的含义为：发送方UID，消息ID，回执方UID，群ID，回执标记。
群消息流程
消息流程
- 将群消息入库
- 查询群里有哪些群成员，以便实施推送
-
插入每条消息的初始回执状态
发送方已读回执
- 发送ack请求
- 修改last_ack_msgid，并且，修改已读回执if_ack状态
- 查询发送方在线状态
- 向发送方实时推送已读回执（如果发送方在线）
- 如果发送方不在线，ta会在下次登录的时候，从关联表里拉取每条消息的已读回执
流程优化方案
群消息已读回执的“消息风暴扩散系数”
假设每个群有200个用户，其中20%的用户在线，即40各用户在线。群用户每发送一条群消息，会有：
- 40个消息，通知给群友
- 40个ack修改last_ack_msgid，发给服务端
- 40个已读回执，通知给发送方
- 需要存储40条ack记录
优化方案
- 群消息的推送，能否改为接收方轮询拉取？
答：不能，消息接收，实时性是核心指标。 - 对于last_ack_msgid的修改，真的需要每个群消息都进行ack么？
答：其实不需要，可以批量ack。有副作用（不实时，拉取重复消息） - 发送方在线时，对于已读回执的发送，真的需要实时推送么？
答：其实不需要，发送方每发一条消息，会收到40个已读回执，采用轮询拉取或放入keepalive请求里。副作用是不实时。
