node.js - 从redis key nodejs弹出值的原子操作

Question

我有一个 nodejs 应用程序和 redis 服务器。该应用程序正在使用 redis client.lpush 进行推送，而我实际需要的是一种从 redis 中弹出对象范围并以原子方式迭代它弹出的对象的方法。有多个客户端针对集群运行，我希望它们读取更新的 key 。

Answer 1

从redis 3.2开始你可以检查

• POP 和 SRANDMEMBER [ https://redis.io/commands/spop#count-argument-extension]
• 将 LRANGE 与管道一起使用 [ https://redis.io/topics/pipelining] (管道将作为一个原子事务运行)

最终解决方案:

通过在多操作中使用 lrange 和 ltrim，应该确保两者以原子方式执行，并且两者之间没有中断。在下面的示例中，有一个在给定键上使用 multi 的用法，而 count 表示要迭代的对象数。它返回第一个(最旧的)n 个对象(通过使用 lrange 和给定的计数)，然后将它们从 redis 中删除(根据给定的计数使用 trim)。

static multiExecutionRedis (key, count){
        return new Promise((resolve, reject) => {
            console.log("running multi execution in the client");
            let client = Reporter.cache;
            let multi = client.multi();
            multi.lrange(key, (count * -1), -1)
                .ltrim(key, 0, (++count) * -1)
                .exec((error, data) => {
                    if (error) {
                        console.log(error);
                        reject(error);
                    } else {
                        console.log("returning valid data");
                        resolve(data[0]);
                    }
                });
        });

对于redis > 4.0，你可以在这里查看https://github.com/RedisLabsModules/redex#rxlists