Firebase云函数onCreate与onDelete触发器竞态条件问题

这是个很典型的Firebase实时数据库触发器并发问题，我之前处理过类似的场景，给你分享下靠谱的解决方案：

问题根源 #

当用户快速点赞又取消时，onCreate和onDelete两个触发器几乎同时执行。它们各自会先读取当前的计数，然后分别做加1和减1操作——但因为读取和写入不是原子性的，两个操作会基于同一个初始值计算，最终导致计数结果错误（比如初始为0，最终可能变成-1或者1，而不是回到0）。

核心解决方案：使用Firebase事务（Transaction） #

Firebase Realtime Database的事务操作是原子性的，它会确保在更新数据时，先读取最新值，基于这个值计算新值，并且只有当读取的值没有被其他并发操作修改时才会提交。如果检测到值已被修改，事务会自动重试，直到成功或者达到重试上限。

重构你的触发器代码 #

把原来直接加减计数的逻辑，替换成事务操作：

点赞触发的increaseCount触发器

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

exports.increaseCount = functions.database.ref('/likes/{postId}/{userId}')
.onCreate((snapshot, context) => {
  const postId = context.params.postId;
  // 指向对应帖子的计数节点
  const countRef = admin.database().ref(`/postCounts/${postId}`);

  // 执行事务更新计数
  return countRef.transaction(currentCount => {
    // 如果计数节点还不存在，默认初始为0
    return (currentCount || 0) + 1;
  });
});

取消点赞触发的decreaseCount触发器

exports.decreaseCount = functions.database.ref('/likes/{postId}/{userId}')
.onDelete((snapshot, context) => {
  const postId = context.params.postId;
  const countRef = admin.database().ref(`/postCounts/${postId}`);

  return countRef.transaction(currentCount => {
    // 避免计数变成负数（根据你的业务需求可选）
    if (currentCount === null) return 0;
    return Math.max(currentCount - 1, 0);
  });
});

为什么这个方案有效 #

当两个触发器并发执行时，第一个事务会成功更新计数，第二个事务在读取时会发现当前值已经被修改，于是会重新读取最新的计数，再执行减1操作，最终得到正确的结果（比如点赞后计数为1，取消点赞后回到0）。

额外优化建议 #

• 如果你的项目用的是Firestore而不是Realtime Database，可以考虑使用Firestore的分布式计数器方案，适合超高并发的场景，但Realtime Database用事务完全足够解决这个问题。
• 可以在触发器中添加日志，比如console.log记录事务的执行情况，方便调试并发场景下的执行流程。
• 避免在触发器中做“先读取再写入”的非原子操作，这种模式天生就容易引发竞态问题。

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