Flutter中如何用事务同时写入Realtime Database、Cloud Storage和Firestore？

首先明确：Firebase的原生事务仅支持单一服务内的原子操作，没法跨Realtime Database、Cloud Storage、Firestore这三个不同服务使用事务来实现统一的原子性。要实现你需求的"全部成功或全部回滚"，得手动实现补偿式回滚逻辑——也就是每一步操作成功后记录状态，一旦后续操作失败，就反向删除之前已写入的数据。

具体实现思路 #

按操作的回滚难度排序执行（优先执行容易回滚的操作），每一步成功后保存需要回滚的资源标识，失败时依次回滚前面的所有成功操作：

1. 第一步：上传头像到Cloud Storage

   • 用唯一文件名（比如提前生成的用户ID）上传，避免重复上传的问题
   • 成功后记录头像的存储路径和文件引用

2. 第二步：写入用户信息到Realtime Database

   • 把包含头像路径的用户信息写入指定节点
   • 成功后记录Realtime DB的节点路径

3. 第三步：写入字符串列表到Firestore

   • 把列表写入指定的Firestore文档
   • 若此步骤失败，先删除Realtime DB的用户节点，再删除Cloud Storage的头像文件；若第二步失败，直接删除Cloud Storage的头像

Flutter代码示例 #

import 'package:firebase_database/firebase_database.dart';
import 'package:firebase_storage/firebase_storage.dart';
import 'package:cloud_firestore/cloud_firestore.dart';
import 'dart:io';

Future<void> createUser({
  required Map<String, dynamic> userInfo,
  required File avatarImage,
  required List<String> stringList,
}) async {
  // 提前生成唯一用户ID（确保重复执行无副作用）
  final userId = FirebaseDatabase.instance.ref().push().key!;
  final storageRef = FirebaseStorage.instance.ref('avatars/$userId.jpg');
  final dbRef = FirebaseDatabase.instance.ref('users/$userId');
  final firestoreDoc = FirebaseFirestore.instance.collection('user_lists').doc(userId);

  bool avatarUploaded = false;
  bool userInfoWritten = false;

  try {
    // 1. 上传头像
    await storageRef.putFile(avatarImage);
    avatarUploaded = true;
    userInfo['avatarUrl'] = await storageRef.getDownloadURL();

    // 2. 写入Realtime DB用户信息
    await dbRef.set(userInfo);
    userInfoWritten = true;

    // 3. 写入Firestore字符串列表
    await firestoreDoc.set({'list': stringList});

    // 全部成功，无需回滚
  } catch (e) {
    // 发生错误，执行回滚
    if (userInfoWritten) {
      await dbRef.remove();
    }
    if (avatarUploaded) {
      await storageRef.delete();
    }
    // 重新抛出错误，让上层处理
    rethrow;
  }
}

关键注意事项 #

• 幂等性保障：所有操作要确保重复执行不会产生副作用，比如用固定的用户ID作为文件名和数据库节点ID，避免重复创建数据
• 回滚可靠性：回滚操作本身也可能失败（比如网络中断），这种极端情况可以考虑：
  • 增加限次数的重试机制
  • 后台定时任务扫描不一致的数据（比如Realtime DB有用户但Firestore没有对应列表，就自动删除用户数据和头像）
• 超时处理：给每个操作加上超时限制，避免长时间阻塞
• 错误日志：记录每一步的操作状态和错误信息，方便排查问题

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