StackExchange.Redis支持ZPOP？

Question

我想使用ZPOP为我的应用程序使用StackExchange.Redis。根据监视部分中的Redis文件，可以使用以下命令实现ZPOP：

WATCH zset
element = ZRANGE zset 0 0
MULTI
ZREM zset element
EXEC

在StackExchange Redis中，这类似于：

var connection = GetMultiplexer();
var db = connection.GetDatabase();
var trans = db.CreateTransaction();

var elements = await trans.SortedSetRangeByScoreAsync(key, 0, 0);  // THIS WILL BLOCK INDEFINITELY
var element = elemenets.FirstOrDefault();
trans.SortedSetRemoveAsync(key, element);
await trans.ExecuteAsync();

我的问题是，如何从事务中获得和使用结果？如何实现ZPOP

Answer 1

考虑使用LUA脚本。Redis保证lua脚本是事务性的，因为在运行eval脚本时，其他任何脚本都不能并发运行。所以你可以使用埃瓦尔。

这里是如何使用LUA脚本执行ZPOP的一个示例：

local val = redis.call('zrange', KEYS[1], 0, 0)
if val then redis.call('zremrangebyrank', KEYS[1], 0, 0) end
return val

此外，还提供了一个ZREVPOP。

使用StackExchange.Redis，您可以使用IServer.ScriptLoad和IDatabase.ScriptEvaluate加载和执行LUA脚本。

https://github.com/StackExchange/StackExchange.Redis/blob/master/Docs/Transactions.md

注意这不是阻塞。在ConnectionMultiplexer中设置阻塞代码也不是一个好主意。

来自Stackexchange.Redis 文档

...the只提供StackExchange.Redis不提供(也永远不会提供的)“阻塞pops”(BLPOP、BRPOP和BRPOPLPUSH)的功能--因为这将允许单个呼叫者拖住整个复用器。