Node.js + Redis：基于旧值事务性修改键值的正确方法及问题排查

我一眼就看出问题所在啦——你的代码里犯了一个Node.js异步编程和Redis事务结合的典型错误，咱们一步步拆解：

你的代码核心问题 #

1. 异步时机错误：Redis客户端的multi是用来批量添加命令到事务队列的，并不是立即执行这些命令。当你写.get('a', (err, result) => { prevValue = result })的时候，这个回调不会立刻触发——要等到你调用exec()之后，Redis才会执行队列里的所有命令，这时候回调才会运行。但你紧接着写的.set('a', prevValue + "*")是在添加set命令到队列，这时候prevValue还没被赋值（还是undefined），所以最终设置的是undefined*，完全不是你想要的基于旧值修改的结果。
2. multi命令的回调用法错误：multi链式调用里的命令回调并不是用来获取执行结果的正确方式，exec()的回调才会返回所有命令的执行结果数组。

正确的写法（回调风格） #

我们需要先单独获取旧值，再开启事务设置新值，同时用watch保证事务的原子性：

redisClient.watch("a", (err) => {
  if (err) throw err;

  // 先单独获取旧值，拿到结果再往下走
  redisClient.get('a', (err, prevValue) => {
    if (err) throw err;

    // 开启事务，设置新值
    const multi = redisClient.multi();
    multi.set('a', prevValue + "*");

    // 执行事务
    multi.exec((err, results) => {
      if (err) throw err;

      if (results === null) {
        // 事务失败：期间有其他客户端修改了键"a"，需要重试
        console.log("事务冲突，重试中...");
        // 这里可以递归调用整个逻辑或者做其他处理
      } else {
        console.log("值修改成功，新值为:", prevValue + "*");
      }
    });
  });
});

更简洁的Async/Await风格（推荐） #

如果你的Redis客户端支持Promise（大部分现代版本都支持），用async/await会让代码更易读：

async function updateKeyAtomically() {
  try {
    // 监听键"a"
    await redisClient.watch("a");

    // 获取旧值
    const prevValue = await redisClient.get("a");
    if (!prevValue) {
      console.log("键'a'不存在");
      redisClient.unwatch(); // 取消监听
      return;
    }

    // 开启事务并设置新值
    const multi = redisClient.multi();
    multi.set("a", prevValue + "*");

    // 执行事务
    const results = await multi.exec();

    if (results === null) {
      // 事务冲突，重试
      console.log("事务冲突，重试中...");
      await updateKeyAtomically(); // 递归重试
    } else {
      console.log("值修改成功，新值为:", prevValue + "*");
    }
  } catch (err) {
    console.error("操作失败:", err);
    redisClient.unwatch(); // 出错时取消监听
  }
}

// 调用函数
updateKeyAtomically();

关键原理说明 #

• watch命令会监听指定键，只要在exec()执行前，有其他客户端修改了这个键，事务就会失败（exec()返回null），这保证了我们是基于最新的旧值修改的。
• 必须先获取旧值，再开启事务设置新值——这样才能确保prevValue是正确的、未被修改的旧值，然后把正确的新值添加到事务队列中。

内容的提问来源于stack exchange，提问作者Dubon Ya'ar