如何防范Firebase云函数中全局变量计数的竞态条件？

嘿，这个问题我太熟了——用全局变量在云函数里统计计数简直是踩了无服务器架构的典型坑啊！先给你把问题根儿说清楚，再给你上靠谱的解决方案：

首先得明确：云函数里的全局变量绝对不能用来存储需要持久化、并发安全的状态，原因有三：

• 云函数是无服务器架构，会根据请求量自动扩容，多个请求可能落在不同的函数实例上，每个实例都有独立的answers变量副本，更新根本不会同步；
• 函数实例闲置一段时间会被销毁，全局变量里的数据直接丢失，重启后又回到初始值；
• 就算是同一个实例处理并发请求，JavaScript的异步特性也可能导致计数混乱（更别说实例隔离的核心问题了）。

正确的解决方案：用Firebase数据库做原子更新 #

Firebase的Firestore和Realtime Database都支持原子递增操作，能完美解决并发下的计数问题，同时数据持久化。下面给你两种常用方案的代码示例：

方案1：使用Firestore实现原子计数

先确保你已经初始化了Firebase Admin SDK，然后修改你的函数：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

const db = admin.firestore();

exports.tryGetCount = functions.https.onRequest(async (req, res) => {
    try {
        const userAnswer = req.body.answer;
        const userId = req.body.userInfo.userId; // 用来做去重，防止重复提交

        // 1. 先检查用户是否已经提交过（可选，避免重复投票）
        const userSubmissionRef = db.collection('user_submissions').doc(userId);
        const userDoc = await userSubmissionRef.get();
        if (userDoc.exists) {
            return res.status(400).json({ message: '你已经提交过答案啦' });
        }

        // 2. 原子递增对应答案的计数（核心操作，完全避免竞态）
        const countRef = db.collection('answer_counts').doc('global');
        await countRef.update({
            [userAnswer]: admin.firestore.FieldValue.increment(1)
        });

        // 3. 记录用户提交记录，防止重复操作
        await userSubmissionRef.set({
            answer: userAnswer,
            timestamp: admin.firestore.FieldValue.serverTimestamp()
        });

        // 4. 返回最新的计数（可选）
        const updatedCountDoc = await countRef.get();
        res.status(200).json({ counts: updatedCountDoc.data() });
    } catch (error) {
        console.error(error);
        res.status(500).json({ message: '提交失败' });
    }
});

方案2：使用Realtime Database实现原子计数

如果用的是Realtime Database，代码逻辑类似，利用事务实现原子递增：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

const db = admin.database();

exports.tryGetCount = functions.https.onRequest(async (req, res) => {
    try {
        const userAnswer = req.body.answer;
        const userId = req.body.userInfo.userId;

        // 检查用户是否已提交
        const userSubmissionRef = db.ref(`user_submissions/${userId}`);
        const userSnapshot = await userSubmissionRef.once('value');
        if (userSnapshot.exists()) {
            return res.status(400).json({ message: '你已经提交过答案啦' });
        }

        // 原子递增计数，事务确保并发安全
        const countRef = db.ref('answer_counts').child(userAnswer);
        await countRef.transaction(currentCount => {
            return (currentCount || 0) + 1;
        });

        // 记录用户提交
        await userSubmissionRef.set({
            answer: userAnswer,
            timestamp: admin.database.ServerValue.TIMESTAMP
        });

        // 返回最新计数
        const countSnapshot = await db.ref('answer_counts').once('value');
        res.status(200).json({ counts: countSnapshot.val() });
    } catch (error) {
        console.error(error);
        res.status(500).json({ message: '提交失败' });
    }
});

关键要点总结 #

• 永远不要依赖云函数的全局变量存储业务数据，它只适合存储初始化配置（比如SDK实例）；
• Firebase数据库的原子操作是解决并发计数问题的标准方案，不需要自己实现复杂的锁机制；
• 加上用户提交记录的检查，可以防止重复投票，让统计结果更准确。

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