如何让Firebase云函数按事务方式串行执行？

你的需求是让两个不同触发类型的Firebase云函数在并发场景下依次执行，避免冲突。Firebase云函数本身没有内置的跨函数事务机制，但可以通过分布式锁来实现互斥逻辑，以下是具体方案：

核心思路 #

借助Firebase实时数据库的事务特性，创建一个全局锁节点。两个函数在执行核心业务逻辑前，都必须先获取这个锁；只有获取到锁的函数才能执行逻辑，执行完成后释放锁，确保同一时间只有一个函数在运行。

具体实现代码 #

1. 为HTTP函数（readProducts）添加锁逻辑 #

exports.readProducts = functions.https.onRequest(async (req, res) => {
  const admin = require('firebase-admin');
  const lockRef = admin.database().ref('/locks/functionMutex');
  let lockAcquired = false;

  try {
    // 原子性获取锁：只有锁节点为空或已超时，才设置锁标记
    await lockRef.transaction(current => {
      const now = Date.now();
      // 5分钟超时，避免函数崩溃导致死锁
      if (current === null || (current.timestamp && now - current.timestamp > 300000)) {
        lockAcquired = true;
        return { locked: true, timestamp: now };
      }
      return current;
    });

    if (!lockAcquired) {
      return res.status(503).send('系统繁忙，请稍后重试');
    }

    // --------------------------
    // 这里写你原来的业务逻辑（SOME CODE）
    // 比如读取产品数据、关联count的操作等
    // --------------------------

    res.status(200).send('操作完成');
  } catch (err) {
    res.status(500).send('执行出错');
  } finally {
    // 无论成功失败，只要获取到锁就释放
    if (lockAcquired) {
      await lockRef.remove();
    }
  }
});

2. 为数据库触发器函数（onCountChange）添加锁逻辑 #

exports.onCountChange = functions.database.ref('/ANALYTICS/count').onWrite(async (change, context) => {
  const admin = require('firebase-admin');
  const lockRef = admin.database().ref('/locks/functionMutex');
  let lockAcquired = false;

  try {
    await lockRef.transaction(current => {
      const now = Date.now();
      if (current === null || (current.timestamp && now - current.timestamp > 300000)) {
        lockAcquired = true;
        return { locked: true, timestamp: now };
      }
      return current;
    });

    if (!lockAcquired) {
      // 获取锁失败，抛出错误让Firebase自动重试
      throw new Error('未获取到执行锁，触发重试');
    }

    // --------------------------
    // 这里写你原来的业务逻辑（SOME CODE）
    // 比如处理count变化后的统计、关联操作等
    // --------------------------

  } catch (err) {
    console.error('函数执行出错:', err);
    // 抛出错误确保Firebase重试
    throw err;
  } finally {
    if (lockAcquired) {
      await lockRef.remove();
    }
  }
});

关键注意事项 #

• 锁超时机制：必须添加超时判断，防止函数崩溃、超时等异常情况导致锁一直占用，造成死锁。示例中设置了5分钟超时，可根据业务调整。
• 重试策略：数据库触发器函数获取锁失败时，通过抛出错误让Firebase自动重试；HTTP函数则直接返回繁忙提示，让客户端重试。
• 业务原子性：如果函数内的数据库操作本身需要原子性（比如读写count），建议结合Firebase数据库的事务或原子更新操作（如increment()），进一步避免数据不一致。

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