Flutter中实现基于Firebase Firestore的全局自增INT值需求

要实现跨用户的全局连续自增INT值，核心是通过Firestore事务维护一个全局计数器文档，确保每次自增操作的原子性，避免并发冲突。以下是具体实现步骤：

1. 准备全局计数器文档 #

在Firestore中创建一个专门的集合（比如命名为counters），并在其中添加一个文档（比如global_sequence），初始字段current_value设为0（或根据业务需求设为起始值）。

2. 通过事务实现原子自增 #

使用Firestore的事务机制来读取并更新计数器，确保同一时间只有一个操作能修改值，彻底避免重复或跳号问题。

Flutter代码实现 #

import 'package:cloud_firestore/cloud_firestore.dart';

// 获取下一个全局自增值
Future<int> fetchNextGlobalSequence() async {
  final firestore = FirebaseFirestore.instance;
  final counterDocRef = firestore.collection('counters').doc('global_sequence');

  return firestore.runTransaction((transaction) async {
    final docSnapshot = await transaction.get(counterDocRef);
    
    // 若文档不存在，初始化并返回第一个值
    if (!docSnapshot.exists) {
      const initialValue = 1;
      transaction.set(counterDocRef, {'current_value': initialValue});
      return initialValue;
    }

    // 读取当前值并计算下一个值
    final currentVal = docSnapshot.data()!['current_value'] as int;
    final nextVal = currentVal + 1;
    
    // 更新计数器文档
    transaction.update(counterDocRef, {'current_value': nextVal});
    return nextVal;
  });
}

3. 将自增值关联到用户文档 #

调用上述函数获取最新值后，即可将其写入当前用户的文档中：

// 为当前用户分配全局自增值
Future<void> setUserGlobalSequence(String userId) async {
  final nextSeq = await fetchNextGlobalSequence();
  await FirebaseFirestore.instance.collection('users').doc(userId).update({
    'global_sequence': nextSeq,
  });
}

关键注意事项 #

• 事务的必要性：必须使用runTransaction而非直接更新文档，否则高并发场景下会出现多个用户获取到相同值的情况。
• 并发重试机制：Firestore事务在遇到冲突时会自动重试，无需额外处理，自增逻辑本身具备幂等性，重试不会导致异常。
• 安全规则配置：确保Firestore安全规则允许授权用户读写counters/global_sequence文档，例如限制仅认证用户可更新，避免恶意篡改。

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