IM/docs/IM 系统消息存储与推送策略文档.md

IM 系统消息存储与推送策略文档

1. 概述

本策略文档定义了 消息在系统中的存储、读取和推送流程，目标是：

• 保证 消息实时性
• 支持 离线消息存储与同步
• 支持 多端登录同步
• 支持 单聊、群聊及系统消息

---

2. 消息存储策略

2.1 消息表设计

表结构参考前期设计：

表名	作用
Messages	存储所有聊天消息（单聊/群聊）
Conversation	缓存用户最近会话信息（last_message_id, target_id, unread_count）
Files	附件 / 图片 / 语音存储URL

---

2.2 消息存储规则

1. 单聊消息
   • 写入 Messages 表
   • 更新发送者和接收者 Conversation 表
   • 更新 UnreadCount
2. 群聊消息
   • 写入 Messages 表
   • 更新群成员对应的 Conversation 表（except 发送者）
   • 更新每个成员的 UnreadCount
3. 文件消息
   • 文件存储到对象存储（OSS/S3/MinIO）
   • Messages.Content 存文件 URL + metadata
4. 消息撤回
   • 消息允许撤回时，修改 `message.status = 1
   • 更新 Conversation.LastMessageId（如撤回的是最后一条消息）

---

3. 消息推送策略

3.1 推送原则

• 实时性：在线用户立即通过 WebSocket 推送
• 可靠性：离线用户存储消息，登录时同步
• 顺序保证：消息按 timestamp 或 messageId 顺序发送
• 幂等性：客户端可根据 messageId 去重

---

3.2 单聊推送流程

1. 发送者通过 WebSocket 或 HTTP API 发送消息
2. 服务端写入 Messages 表
3. 查询接收者是否在线
   • 在线：通过 WebSocket 推送
   • 离线：存储到 Redis 或 Conversation.UnreadCount
4. 接收者收到消息后发送 MESSAGE_ACK
5. //暂不要求：更新消息状态（已送达 / 已读）

---

3.3 群聊推送流程

1. 发送者发送群消息
2. 服务端写入 Messages 表
3. 查询群成员列表（GroupMember 表）
4. 遍历成员：
   • 在线成员：WebSocket 推送
   • 离线成员：增加 UnreadCount，保存在 Redis/数据库
5. //暂不要求：接收者回 ACK 后更新 message_receipt（已读）

---

3.4 离线消息处理

• 离线消息存储位置：
  1. 数据库 Messages 表（长期保存）
  2. Redis 缓存（短期加速推送）
• 客户端上线时：
  1. 请求 /syncMessages 接口
  2. 返回未读消息 + 未读计数
• 消息同步完成后清除缓存或更新状态

---

3.5 多端同步策略

• 每个设备维护独立的 deviceId
• WebSocket 推送时：
  • 排除发送设备
  • 推送给同账号其他设备
• //暂不要求：消息回执：
  • 每端发送 ACK
  • 服务端更新 Voncers 和 message_receipt

---

4. 消息可靠性保障

场景	解决方案
消息丢失	发送端生成 requestId，服务端去重
消息顺序错乱	按 messageId 或 timestamp 排序
WebSocket 异常断开	客户端重连后同步离线消息
群聊大消息量	异步推送 + 批量 ACK

---

5. //暂不要求：高性能优化策略

1. 消息表索引：(chat_type, to_id, created_at)
2. 会话表缓存：conversation 表避免全表查询
3. Redis 缓存：用户在线状态、未读消息数
4. 分表/分库：按月或按用户分表
5. 异步推送队列：消息通过 MQ（Kafka/RabbitMQ）推送，保证高并发

---

6. 消息撤回与删除策略

1. 撤回条件：超时限制（ 2 分钟内可撤回）
2. 撤回操作：
   • 更新 message.status = 1
   • 更新 Conversation.LastMessageId
   • 推送撤回事件到在线用户

---

7. 系统消息与通知策略

• 系统消息（好友申请、群邀请、公告）走 同样的消息推送流程
• 保留在 Notification 表
• 支持离线同步