监听.info/connected无法感知断开，Firebase在线状态异常排查

问题背景 #

客户端基于React+TypeScript开发，使用Firebase JS SDK v9.23.0，采用官方在线状态方案，核心逻辑：

• 利用onDisconnect让RTDB服务器在连接断开时自动设置在线状态节点
• 通过Cloud Function同步RTDB状态到Firestore文档
• 本地监听RTDB的.info/connected节点，触发onDisconnect配置、更新Firestore本地缓存并通知用户断开状态

异常现象 #

生产环境日志显示：

• 后端onDisconnect已触发，RTDB与Firestore的在线状态均更新为断开
• 本地.info/connected监听器未触发状态变更（无本地离线日志）
• Firestore的onSnapshot监听器收不到更新，用户完全无法感知已断开
  该问题无法复现，仅能通过生产日志观测

核心代码 #

客户端在线状态逻辑 #

const syncPrecense = async (sessionId: string, participantId: string) => {
   const reconnectHandler = async (): Promise<void> => {
      // 更新RTDB中的参与者状态
      await set(
         ref(
            getDefaultRTDatabaseInstance(),
            `/sessions/${sessionId}/participants/${participantId}/status`
         ),
         {
            presenceStatus: PresenceStatus.ACTIVE,
            lastPresenceChangeTime: databaseServerTimestamp,
         }
      );

      // 直接更新Firestore，避免Firestore服务器未连接时本地缓存不更新
      await updateDoc(
         doc(
            getFirestoreInstance(),
            `sessions/${sessionId}/participants/${participantId}`
         ),
         {
            presenceStatus: PresenceStatus.ACTIVE,
            lastPresenceChangeTime: firestoreServerTimestamp,
         }
      );
   };

   onValue(
      ref(getDefaultRTDatabaseInstance(), '.info/connected'),
      async (snapshot) => {
         const isOnline = snapshot.val() === true;
         bi.log(`Participant local presence online status: ${isOnline}`);
         if (!isOnline) {
            // 本地识别到断开时，更新Firestore本地缓存让用户感知
            await updateDoc(
               doc(
                  getFirestoreInstance(),
                  `sessions/${sessionId}/participants/${participantId}`
               ),
               {
                  presenceStatus: PresenceStatus.DISCONNECTED,
                  lastPresenceChangeTime: firestoreServerTimestamp,
               }
            );
            return;
         }
         // 连接时配置断开后的服务器操作
         onDisconnect(
            ref(
               getDefaultRTDatabaseInstance(),
               `/sessions/${sessionId}/participants/${participantId}/status`
            )
         )
            .set({
               presenceStatus: PresenceStatus.DISCONNECTED,
               lastPresenceChangeTime: databaseServerTimestamp,
            })
            .then(reconnectHandler)
            .catch((error) => {
               bi.error('Failed to set onDisconnect handler', error);
               throw error;
            });
      }
   );
};

RTDB同步到Firestore的Cloud Function #

const isPresenceStatusStillAccurate = async (
   statusSnapshot: DataSnapshot,
   statusFromDb: PresenceRecord
) => {
   const updatedSnapshot = await statusSnapshot.ref.once('value');
   const updatedStatus = updatedSnapshot.val() as PresenceRecord;
   return (
      updatedStatus.lastPresenceChangeTime <=
      statusFromDb.lastPresenceChangeTime
   );
};

onValueWritten(
   {
      instance: DEFAULT_DATABASE_NAME,
      ref: '/sessions/{sessionId}/participants/{participantId}/status',
   },
   async (event: DatabaseEvent<Change<DataSnapshot>>) => {
      const change = event.data;
      const statusSnapshot = change.after;
      const presenceStatus = statusSnapshot.val();
      // 忽略删除操作
      if (!statusSnapshot.exists()) {
         return;
      }
      const isStillAccurate = await isPresenceStatusStillAccurate(
         statusSnapshot,
         presenceStatus
      );
      if (!isStillAccurate) {
         return;
      }
      await firebaseInstance()
         .firestore()
         .doc(`sessions/${sessionId}/participants/${participantId}`)
         .update(presenceStatus);
   }
);

Firestore状态监听代码 #

onSnapshot(
   doc(
      getFirestoreInstance(),
      `sessions/${sessionId}/participants/${participantId}`
   ),
   (snapshot) => {
      // 处理参与者状态变更
   }
);

.info/connected的工作机制 #

.info/connected是RTDB的特殊系统节点，核心特性：

• 返回布尔值，仅反映客户端与RTDB服务器的实时连接状态，和Firestore连接状态完全独立
• 依赖心跳机制检测连接：客户端定期向服务器发送心跳包，服务器也会向客户端发送心跳响应
  • 服务器端：若超时（默认约45秒）未收到客户端心跳，会判定连接断开，触发已设置的onDisconnect操作
  • 客户端：若未收到服务器的心跳响应，才会将.info/connected的值设为false，触发本地监听器
• 注意：客户端网络处于“半连接”状态（如TCP连接未正常关闭、WiFi信号弱但未断网）时，客户端可能仍认为连接有效，.info/connected保持true，但服务器已判定断开

异常原因分析 #

1. 本地未检测到RTDB连接断开

   • 客户端处于“半连接”网络状态：TCP连接未触发FIN/RST，客户端仍向服务器发送心跳，但服务器未响应或响应丢失，此时服务器已触发onDisconnect，但客户端因未检测到心跳超时，.info/connected仍为true
   • RTDB客户端默认心跳超时（约45秒）与实际网络环境不匹配，服务器已判定断开，客户端还未完成超时检测

2. Firestore监听器无更新的连锁反应

   • 客户端与Firestore的连接也已断开，onSnapshot无法从服务器拉取更新
   • 本地缓存未被更新：因.info/connected未触发，客户端未执行本地Firestore更新逻辑，导致用户看不到断开状态

3. 代码潜在问题

   • .info/connected的监听器为异步函数，若更新Firestore时发生错误，可能被吞噬，导致后续逻辑中断
   • 未对onDisconnect设置做去重处理，连接波动时可能重复设置，引发未知逻辑冲突

优化方案 #

• 补充本地网络检测：结合浏览器navigator.onLineAPI作为.info/connected的补充（注意：该API仅检测是否有网络连接，不保证能到达Firebase服务器）
• 调整RTDB心跳超时：通过Firebase配置的connectTimeout参数缩短心跳超时时间，让客户端更快检测到连接断开
• 完善错误处理：在.info/connected监听器的异步操作中添加全局错误捕获，确保错误被记录且不中断后续逻辑
• 增强Firestore监听：给onSnapshot添加错误回调，监听连接异常并提示用户：

  onSnapshot(docRef, {
    next: (snapshot) => { /* 处理状态更新 */ },
    error: (error) => {
      bi.error('Firestore snapshot error', error);
      // 触发本地断开提示逻辑
    }
  });
  

• 定期主动校验：客户端每隔一段时间主动拉取Firestore中的状态，与本地缓存对比，若不一致则更新并提示用户

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