如何仅监听Cloud Firestore集合的新增文档？

嘿，这个问题我太有共鸣了——默认的Firestore实时监听器确实会在每次有新文档加入时，把整个集合的快照都返回一遍，不仅浪费带宽，处理起来也麻烦。不过好在Firestore有两种靠谱的解决思路，完全能满足你「只追踪新增、不传输冗余数据」的需求，下面给你拆解清楚：

方法一：基于服务器时间戳的服务器端过滤（推荐） #

这是最优解，因为它直接在Firestore服务器端就过滤掉了已存在的文档，不会把旧数据传到客户端。核心思路是给每个文档加一个创建时间戳，然后只监听该时间戳之后新增的文档。

步骤拆解： #

1. 给新增文档添加服务器时间戳字段
   每次创建tweet文档时，用Firestore提供的serverTimestamp()来设置createdAt字段，确保时间是服务器端的统一时间，避免客户端时间不一致导致的问题：

   db.collection('tweets').add({
     content: '我的第一条推文',
     createdAt: firebase.firestore.FieldValue.serverTimestamp()
   });
   

2. 初始化监听器并动态更新时间戳
   一开始先记录当前时间作为起始点，之后每次监听到新增文档，就把起始时间更新为最新文档的创建时间，这样后续的监听只会针对更晚的新增内容：

   // 初始化起始时间戳，第一次可以设为当前时间（或更早，如果你需要先拉历史数据）
   let lastCreatedAt = firebase.firestore.Timestamp.now();
   
   // 设置实时监听器
   const unsubscribe = db.collection('tweets')
     .where('createdAt', '>', lastCreatedAt)
     .onSnapshot((snapshot) => {
       snapshot.docChanges().forEach((change) => {
         if (change.type === 'added') {
           console.log('新增推文:', change.doc.data());
           // 更新起始时间戳为当前新增文档的创建时间
           const currentTimestamp = change.doc.data().createdAt;
           if (currentTimestamp > lastCreatedAt) {
             lastCreatedAt = currentTimestamp;
           }
         }
       });
     });
   

   敲黑板：如果需要先获取所有历史推文，只需要把初始的lastCreatedAt设为一个非常早的时间（比如Timestamp.fromDate(new Date(2000, 0, 1))），第一次拉取完所有历史后，后续就只会监听新增内容了。

方法二：客户端过滤文档变化类型（适合无法添加时间戳的场景） #

如果你因为某些原因没法给文档加时间戳字段，也可以在客户端通过docChanges()的类型来过滤。不过要注意：第一次监听时，所有已存在的文档都会被标记为added，所以需要加一个标记来跳过第一次的批量返回。

let isFirstLoad = true;

const unsubscribe = db.collection('tweets').onSnapshot((snapshot) => {
  snapshot.docChanges().forEach((change) => {
    if (change.type === 'added') {
      // 跳过第一次加载时的所有已存在文档
      if (!isFirstLoad) {
        console.log('新增推文:', change.doc.data());
      }
    }
  });
  // 第一次加载完成后，标记为false
  isFirstLoad = false;
});

⚠️ 缺点：这种方法第一次还是会下载整个集合的所有数据，只是客户端过滤掉了旧内容，所以如果集合很大，还是推荐第一种方法。

关键注意事项 #

• 一定要用serverTimestamp()而不是客户端时间，不然不同设备的时间差会导致漏收或重复接收文档。
• 如果需要处理离线场景，Firestore的本地缓存会自动同步，不用担心离线时的新增数据丢失。

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