Web 9版SDK下使用Firestore集合组查询获取每个会话最新消息

前置要求 #

• 提前为messages集合组创建查询索引，索引配置为按time字段降序，索引范围选择「集合组」。你也可以先执行一次查询，Firebase会在报错信息里直接给出一键创建对应索引的入口，不需要手动填写配置。
• 不需要提前在消息文档冗余存储会话ID，可直接通过消息文档的引用路径解析得到所属会话ID：doc.ref.parent.parent.id，对应的路径规则为conversations/{会话ID}/messages/{消息ID}。

核心代码实现 #

首先导入SDK相关方法和已经初始化的Firestore实例：

import { collectionGroup, query, orderBy, getDocs } from "firebase/firestore";
import { db } from "./firebase-config"; // 替换为你自己的Firebase初始化文件路径

集合组查询实现逻辑 #

// 构造messages集合组查询，按消息时间倒序排列所有消息
const messagesQuery = query(
  collectionGroup(db, "messages"),
  orderBy("time", "desc")
);

const querySnapshot = await getDocs(messagesQuery);
// 用Map存储每个会话的最新消息，自动去重
const conversationLatestMsg = new Map();

querySnapshot.forEach((msgDoc) => {
  const msgData = msgDoc.data();
  // 解析当前消息所属的会话ID
  const conversationId = msgDoc.ref.parent.parent.id;
  // 仅首次出现的会话消息是最新的，直接存入Map
  if (!conversationLatestMsg.has(conversationId)) {
    conversationLatestMsg.set(conversationId, {
      id: msgDoc.id,
      conversationId,
      ...msgData
    });
  }
});

// 转为数组即可得到所有会话的最新消息列表
const latestMessagesList = Array.from(conversationLatestMsg.values());

注意：该方案会查询所有消息文档，仅适合会话量级较小的场景，单条查询最多返回1万条文档，超出会被截断。

生产环境优化方案（推荐） #

直接在conversations集合的每个会话文档中新增latestMessage字段，每次写入新消息时同步更新对应会话文档的该字段内容。后续只需要查询conversations集合就能直接拿到所有会话的最新消息，不需要走集合组查询，读写成本更低、响应速度更快。

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