Firebase事务使用咨询：Storage与Database操作原子性实现

我来帮你梳理这个问题的解决方案——因为Firebase的Storage和Database是两个独立的服务，没有原生的跨服务事务支持，所以我们得用补偿式逻辑来模拟原子性，保证两个操作要么都成功，要么都回滚到初始状态。

核心思路：分阶段执行+失败回滚 #

我们把整个流程拆成「准备标记→执行上传→更新状态→失败回滚」四个环节，确保每一步都有可追溯的关联标识，出问题时能精准撤销已执行的操作。

1. 先在Database中写入"待处理"标记 #

在开始上传文件前，先往Database里插入一条带唯一uploadId的待处理记录，用来关联后续的文件上传操作。这一步必须先成功，否则直接终止流程，避免出现无记录的孤立文件。

// 生成唯一的上传标识，用来关联DB记录和Storage文件
const uploadId = firebase.database().ref().push().key;
// 写入待处理状态的记录
await firebase.database().ref(`uploads/${uploadId}`).set({
  userId: currentUserId,
  fileName: file.name,
  status: 'pending',
  createdAt: firebase.database.ServerValue.TIMESTAMP
});

2. 上传文件到Storage，关联uploadId #

上传文件时，把uploadId作为文件路径的一部分（比如放在文件夹名里），这样后续能通过这个ID快速定位到对应的文件。

const storageRef = firebase.storage().ref(`user-uploads/${uploadId}/${file.name}`);
// 执行上传并等待完成
await storageRef.put(file);
// 获取文件的下载URL
const fileUrl = await storageRef.getDownloadURL();

3. 更新Database记录为"完成"状态 #

如果文件上传成功，就把之前的pending记录更新为completed，同时添加上文件的下载URL，完成整个流程。

await firebase.database().ref(`uploads/${uploadId}`).update({
  status: 'completed',
  fileUrl: fileUrl,
  completedAt: firebase.database.ServerValue.TIMESTAMP
});

4. 失败场景的回滚逻辑 #

用try/catch捕获任何环节的异常，一旦出错就执行回滚：

• 如果DB已经写入待处理记录，但文件上传失败：删除这条DB记录
• 如果文件已经上传成功，但DB更新失败：删除对应的Storage文件

完整的带回滚的代码示例：

let uploadId;
try {
  // 步骤1：创建待处理记录
  uploadId = firebase.database().ref().push().key;
  await firebase.database().ref(`uploads/${uploadId}`).set({
    userId: currentUserId,
    fileName: file.name,
    status: 'pending',
    createdAt: firebase.database.ServerValue.TIMESTAMP
  });

  // 步骤2：上传文件到Storage
  const storageRef = firebase.storage().ref(`user-uploads/${uploadId}/${file.name}`);
  await storageRef.put(file);
  const fileUrl = await storageRef.getDownloadURL();

  // 步骤3：更新DB为完成状态
  await firebase.database().ref(`uploads/${uploadId}`).update({
    status: 'completed',
    fileUrl: fileUrl,
    completedAt: firebase.database.ServerValue.TIMESTAMP
  });

  console.log("上传与DB更新全部完成！");
} catch (error) {
  console.error("操作失败，开始回滚：", error);
  // 回滚已执行的操作
  if (uploadId) {
    // 尝试删除DB中的待处理记录
    await firebase.database().ref(`uploads/${uploadId}`).remove().catch(err => console.error("删除DB记录失败：", err));
    // 尝试删除Storage中的文件（如果已上传）
    const storageRef = firebase.storage().ref(`user-uploads/${uploadId}`);
    await storageRef.delete().catch(err => console.error("删除Storage文件失败：", err));
  }
  // 抛出错误让上层处理
  throw error;
}

额外保障：清理遗留的无效记录 #

极端情况下（比如APP突然崩溃），可能会留下pending状态的DB记录和对应的Storage文件。你可以通过以下方式清理：

• 在APP启动时，检查所有超过1小时的pending记录，自动删除对应的DB记录和文件
• 用Firebase Cloud Functions定时执行清理任务（比如每小时跑一次）

示例Cloud Functions定时任务：

exports.cleanupPendingUploads = functions.pubsub.schedule('every 60 minutes').onRun(async (context) => {
  const cutoffTime = Date.now() - 3600000; // 清理1小时前的待处理记录
  const pendingUploadsRef = firebase.database().ref('uploads')
    .orderByChild('createdAt')
    .endAt(cutoffTime)
    .equalTo('pending');
  
  const snapshot = await pendingUploadsRef.once('value');
  const cleanupPromises = [];
  
  snapshot.forEach(childSnapshot => {
    const uploadId = childSnapshot.key;
    // 删除DB记录
    cleanupPromises.push(childSnapshot.ref.remove());
    // 删除Storage中的对应文件
    const storageRef = firebase.storage().ref(`user-uploads/${uploadId}`);
    cleanupPromises.push(storageRef.delete().catch(err => console.error("清理文件失败：", err)));
  });
  
  await Promise.all(cleanupPromises);
  console.log("遗留待处理记录清理完成");
  return null;
});

注意事项 #

• 权限控制：确保Storage和Database的安全规则设置正确，用户只能操作自己的上传记录和文件
• 重试机制：对于临时网络波动，可以在catch块中加入有限次数的重试，避免不必要的回滚
• 唯一标识：必须用uploadId关联DB记录和Storage文件，这是回滚逻辑的核心前提

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