如何通过Firebase Admin SDK监听Firestore多层集合的文档变更

我正在开发一款聊天应用，需要在新消息到来时通知用户，使用Firebase Admin SDK的onSnapshot函数，但遇到以下问题：

• 无法通过占位符{userID}和{senderID}监听多层集合（users/{userID}/chats/{senderID}/messages）的变化
• 不能部署到Firebase Cloud，因此无法使用Firebase Functions
• 当前仅能监听单个用户与单个发送者的消息，若遍历所有用户和好友，时间复杂度达O(nk)（k为用户平均好友数），成本过高，需要低成本的可行方案

尝试的无效代码 #

const admin = require("firebase-admin");
const firebaseAdminKey = require("./firebase-admin-key.json");

admin.initializeApp({
  credential: admin.credential.cert(firebaseAdminKey),
  databaseURL: `https://${firebaseAdminKey.project_id}.firebaseio.com`,
});

let firestore = admin.firestore();
let messeging = admin.messaging();
let storage = admin.storage();
console.log("Firebase Admin Initialized");

firestore
  .collection("users")
  .doc("{userID}")
  .collection("chats")
  .doc("{senderID}")
  .collection("messages")
  .onSnapshot((snapshot) => {
    console.log("New Message ", snapshot.docs);
    snapshot.docChanges().forEach((change) => {
      console.log("New message: ", change.doc.data());
    });
  });

当前可用的单用户单发送者监听代码 #

const admin = require("firebase-admin");
const firebaseAdminKey = require("./firebase-admin-key.json");

admin.initializeApp({
  credential: admin.credential.cert(firebaseAdminKey),
  databaseURL: `https://${firebaseAdminKey.project_id}.firebaseio.com`,
});

let firestore = admin.firestore();
let messeging = admin.messaging();
let storage = admin.storage();
console.log("Firebase Admin Initialized");

firestore
  .collection("users")
  .doc("Zcpq0NHMODTGMT2Qry53ylksmvp2")
  .collection("chats")
  .doc("m79kGeXHKPNEgteCqxn2RG4eytL2")
  .collection("messages")
  .onSnapshot((snapshot) => {
    console.log("New Message ", snapshot.docs);
    snapshot.docChanges().forEach((change) => {
      console.log("New message: ", change.doc.data());
    });
  });

可行解决方案 #

方案1：使用Firestore集合组查询监听 #

Firestore支持集合组查询，可以监听所有同名子集合的变化。这里messages是所有chats文档下的子集合，直接创建集合组监听即可：

// 监听所有users/*/chats/*/messages集合的变化
firestore.collectionGroup("messages").onSnapshot((snapshot) => {
  snapshot.docChanges().forEach((change) => {
    if (change.type === "added") {
      const messageData = change.doc.data();
      // 从文档路径解析目标userID和senderID
      const docPathSegments = change.doc.ref.path.split("/");
      const userID = docPathSegments[1];
      const senderID = docPathSegments[3];
      
      // 执行通知逻辑，比如向userID对应的设备发送推送
      console.log(`用户${userID}收到来自${senderID}的新消息:`, messageData);
    }
  });
});

注意：如果需要添加过滤条件，需在Firebase控制台为messages集合创建对应复合索引，单纯监听新增消息无需额外配置。

方案2：调整数据结构降低监听成本 #

如果集合组监听范围过广，可调整数据结构优化：

• 新增全局incoming_messages集合，每条消息写入时同步写入该集合，并携带recipientID字段
• 监听该集合，通过where条件过滤仅关注在线用户的消息（若服务只为在线用户提供通知）

// onlineUserIDs为当前在线用户ID数组
firestore.collection("incoming_messages")
  .where("recipientID", "in", onlineUserIDs)
  .onSnapshot((snapshot) => {
    snapshot.docChanges().forEach((change) => {
      if (change.type === "added") {
        const message = change.doc.data();
        console.log(`用户${message.recipientID}收到新消息:`, message);
        // 发送通知后删除文档，避免重复监听
        change.doc.ref.delete();
      }
    });
  });

这种方式可大幅减少监听的文档数量，降低资源消耗。

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