Node .js | Redis缓存加载旧数据

Question

我正在尝试设置一个 mongo、node 和 redis 服务器，除了似乎加载较旧数据的 Redis 缓存之外，一切都运行良好。

取出 Redis 并使用纯 Mongo 会返回正确的数据，如果我再次单击提交，它将加载上次提交的数据，因此我知道缓存和 Mongo 正在正常更新。

这是我使用 Mongo 和 Redis 更新用户的当前代码...

updateUserById: (newUser, redis, id, callback) => {
    User.findByIdAndUpdate(id, {
        $set: {
            "firstName": newUser.firstName,
            "lastName": newUser.lastName,
            "email": newUser.email
        }
    }, (err, doc) => {
        if (err) { throw new Error(err); }
        else if (!doc) { callback('No user with that ID to update cache.') }
        else {
            redis.set(id, JSON.stringify(doc), (err) => {
                console.log('Caching updated user ' + id);
                if (err) { callback(err); throw new Error(err); }
                else {
                    const result = {
                        "success": "true",
                        "message": "User updated successfully"
                    };

                    callback(result);
                }
            })
        }
    });
}

这就是返回用户信息的redis和mongo...

userById: async (redis, id, callback) => {
    redis.get(id, async (err, reply) => {
        if (err) {
            callback(null); throw new Error(err);
        } else if (reply) {
            callback(JSON.parse(reply));
        } else {
            await User.findById(id, (err, doc) => {
                if (err || !doc) { callback(null); throw new Error(err); }
                else {
                    redis.set(id, JSON.stringify(doc), () => {
                        callback(doc);
                    })
                }
            })
        }
    })
}

我发现这与包含 updateUserById 中的旧信息的 doc 有关

Answer 1

问题出在更新方法中。

当文档被传递时，传递的是旧数据而不是新数据。为了解决这个问题，我使用了传递给方法的 newUser。

这是更新后的代码:

updateUserById: (newUser, redis, id, callback) => {
    User.findByIdAndUpdate(id, newUser, (err) => {

        if (err) { throw new Error(err); }
        else {
            redis.set(id, JSON.stringify(newUser), (err) => {
                console.log('Caching updated user ' + id);
                if (err) { callback(err); throw new Error(err); }
                else {
                    const result = {
                        "success": "true",
                        "message": "User updated successfully"
                    };

                    callback(result);
                }
            })
        }
    });
}