Redis BRPOP 和 ZADD 的原子化操作

我需要使用 BRPOP,然后将弹出的值通过 ZADD 添加到一个有序集合中。我看到了两种解决方案(我正在使用 Ruby):

  1. 编写一个 Lua 脚本来执行这两个操作。然而,Lua 脚本不能阻塞,因为它们会在此期间阻止整个服务器。因此,这个解决方案不起作用;
  2. 使用 redis-rbmulti { ... } 块。然而,在这里,我不能在 ZADD 命令中使用弹出的值,因为这不是 redis-rb 实现此块的方式。

在这些情况下,我只能使用非原子化方法来实现这一点,即使用 redis-rb 依次触发这些命令。然而,我确实需要原子性操作。有什么方法可以实现这一点吗?

点赞
用户5384363
用户5384363

你可以将 RPOPZADD 包裹在一个 Lua 脚本中(如 RPOPZADD)以原子方式运行它们,并在客户端上执行一些工作来模拟阻塞行为。

以下是伪代码:

while (true) {
    bool ret = redis.eval(RPOPZADD);    // 立即返回
    if (!ret) {
        // 队列中没有项目,等待一段时间
        sleep(1);
    }
}
2018-04-20 11:30:26
用户1537042
用户1537042

你没有说明你需要有序集合的原因,如果你可以绕过它并使用列表,你可以使用 BRPOPLPUSH 原子地将元素移动到另一个列表中,并稍后以非原子方式进行排序。

另一个选择是编写一个 Redis 模块来为你完成这个操作 - 模块阻塞操作

2018-04-20 19:52:55
用户3160475
用户3160475

TL;DR 不可能是可能的。

你可以查看我的新模块和 Redis 核心的闪亮新拉取请求,如果你不被弹出列表所困扰的话。

  1. Ze POP 模块:https://github.com/itamarhaber/zpop
  2. 拉取请求 #4879 "实现了 [B]Z[REV]POP 和相应的单元测试":https://github.com/antirez/redis/pull/4879
2018-05-02 21:33:34