Firestore 9.10.0 onSnapshot监听连续创建文档触发GRPC流错误求助

一、优化监听器逻辑，减少重复请求 #

把频道配置的获取移到监听器外部，只初始化一次并缓存，避免每次快照触发都重复请求Firestore和Discord API：

// 提前获取并缓存Discord频道对象
let cachedChannel;
const initChannel = async () => {
  const channelRef = doc(db, "discordbot", "postchannels");
  const channelData = await getDoc(channelRef);
  if (channelData.exists()) {
    const data = channelData.data();
    const guildId = Object.keys(data.itemsMap)[0];
    const channelId = data.itemsMap[guildId];
    const guild = await client.guilds.fetch(guildId);
    cachedChannel = await guild.channels.fetch(channelId);
  }
};
initChannel();

// 监听器直接使用缓存的频道
onSnapshot(collection(db, "items"), async (snapshot) => {
  if (!cachedChannel) return;

  // 用for...of替代forEach，确保异步操作串行执行
  for (const change of snapshot.docChanges()) {
    if (change.type === "added") {
      const item = change.doc.data();
      await cachedChannel.send({ embeds: [someEmbed] });
    }
  }
});

原代码每次快照触发都重复拉取频道配置，连续添加文档时会短时间内发起大量请求，容易触发API限流或Firestore连接不稳定。

二、控制异步操作并发量 #

原代码中forEach(async (change) => {})会导致多个channel.send同时执行，Discord API有请求频率限制，连续发送可能触发限流，间接加剧Firestore连接压力：

• 改用for...of配合await实现串行发送，或者添加短延迟降低请求密度：

  for (const change of snapshot.docChanges()) {
    if (change.type === "added") {
      const item = change.doc.data();
      try {
        await cachedChannel.send({ embeds: [someEmbed] });
        await new Promise(resolve => setTimeout(resolve, 500)); // 500ms延迟，可调整
      } catch (err) {
        console.error("消息发送失败:", err);
      }
    }
  }
  

三、添加错误捕获与重连机制 #

给onSnapshot添加错误回调，捕获连接异常后自动重试监听：

let unsubscribe;
const startListening = () => {
  unsubscribe = onSnapshot(
    collection(db, "items"),
    async (snapshot) => {
      // 处理快照逻辑
    },
    (error) => {
      console.error("Firestore监听出错:", error);
      setTimeout(startListening, 5000); // 5秒后重新启动监听
    }
  );
};
startListening();

同时给channel.send添加try-catch，避免单个消息发送失败导致后续逻辑中断。

四、检查环境与依赖版本 #

• 升级Firestore SDK到最新稳定版（当前使用的9.10.0后续版本可能修复了GRPC连接相关bug）。
• 确认服务器网络稳定，无防火墙或代理拦截GRPC流量（Firestore依赖443端口的GRPC协议）。

五、改用定时轮询（可选） #

如果对实时性要求不高，可以放弃长连接监听，改用定时轮询查询新增文档：

let lastCheckTimestamp = Date.now();
setInterval(async () => {
  const snapshot = await getDocs(collection(db, "items"));
  snapshot.forEach(doc => {
    const createTime = doc.createTime.toDate().getTime();
    if (createTime > lastCheckTimestamp) {
      // 发送消息逻辑
    }
  });
  lastCheckTimestamp = Date.now();
}, 30000); // 每30秒查询一次，可调整间隔

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