Flutter+Firebase聊天应用已读功能的架构与安全实现咨询

架构调整核心思路 #

放弃给单条消息加已读标记的方案，转而在会话层级维护已读状态，大幅降低写入操作量：

• 在Chats集合的每个conversationId文档中，新增两个字段：
  • userReadTimestamps: 键值对结构，{用户ID: 最后读取时间戳}，记录每个用户的最新已读节点
  • unreadCounts: 键值对结构，{用户ID: 未读消息数}，快速获取每个用户的会话未读数量
• 保留原有的Messages子集合，每条消息仅存储sentAt（发送时间戳），无需额外已读字段

核心功能实现 #

1. 实时聊天的未读消息识别 #

客户端流式获取Messages时，通过对比消息的sentAt和当前用户在userReadTimestamps中的时间戳，自动识别未读消息：

• 未读判定逻辑：消息.sentAt > 当前用户.userReadTimestamps
• 聊天页面激活（前台显示）时，执行单次写入操作：将当前用户在userReadTimestamps中的值更新为服务器当前时间戳，一次性标记所有之前的消息为已读

2. 未读消息计数维护 #

通过Cloud Function实现计数的自动更新，避免客户端篡改：

• 发送消息时触发：
  监听Messages子集合的新增事件，获取会话的participants成员列表（需在conversation文档中维护），对除发送者外的所有用户，执行unreadCounts[用户ID] += 1的批量更新
• 标记已读时触发：
  监听userReadTimestamps的更新事件，将对应用户的unreadCounts[用户ID]重置为0

安全控制方案 #

通过Firebase安全规则和服务端函数，彻底杜绝客户端篡改：

1. 安全规则限制 #

• 仅允许用户更新自己的userReadTimestamps条目：

  match /Chats/{conversationId} {
    allow update: if request.auth != null && 
                  request.resource.data.userReadTimestamps.keys().hasOnly([request.auth.uid]) &&
                  request.resource.data.userReadTimestamps[request.auth.uid] is timestamp;
  }
  

• 禁止客户端直接修改unreadCounts，仅允许Cloud Function的服务账号操作：

  match /Chats/{conversationId} {
    allow write: if request.auth != null && 
                  request.auth.token.email == "你的云函数服务账号邮箱@项目ID.iam.gserviceaccount.com";
  }
  

2. 服务端函数权限 #

所有unreadCounts的更新逻辑仅在Cloud Function中执行，使用Firebase Admin SDK操作，确保权限安全。

优化细节 #

• 会话成员较多时，Cloud Function中使用batch批量更新操作，减少网络请求次数
• 客户端缓存userReadTimestamps值，仅在页面初始化、切换前台时拉取最新数据，降低读取频率

内容的提问来源于stack exchange，提问作者Alex Stroescu