我想在Redis中实现一个并发优先级队列,在不同的机器上使用多个进程添加项(有分数),多个其他进程弹出这些项,得分最低。
可以用LPUSH和RPOP实现一个简单的队列。
使用ZSET,我可以使用ZADD添加项目,并使用ZRANGE和ZREM弹出它们,只要只有一个阅读器。
对于多个读者,我想我需要像ZPOP这样的东西,它将ZRANGE和ZREM结合在一个原子操作中。否则,在ZREM之前,两个读者可能会从ZRANGE获得相同的项目。如果ZREM返回0,则重试将有效,但不可取。
有什么方法可以用当前的Redis命令来完成吗?有什么原因没有把这个添加到Redis中吗?它似乎是一个非常简单的命令来实现。
发布于 2014-10-14 23:08:25
如果使用执行ZRANGE & ZREM的Lua脚本或使用MULTI/EXEC块,则可以保证原子性。这将防止多个工人互相干扰。
我假设ZPOP不是放在首位的,因为它不是一个常见的用例,而且在需要时可以轻松地编写脚本。
发布于 2015-07-11 10:44:53
您可以使用redis命令:
WATCH zset
element = ZRANGE zset 0 0
MULTI
ZREM zset element
EXEC
如果exec失败(返回空应答),只需重复这些命令即可。
发布于 2019-11-29 12:33:00
在Redis5.0.0中,您可以使用https://redis.io/commands/zpopmin和https://redis.io/commands/zpopmax (以及它们的阻塞对应的https://redis.io/commands/bzpopmin和https://redis.io/commands/bzpopmax)。
https://stackoverflow.com/questions/26369304
复制相似问题