如何使用 StackExchange.Redis 使多个操作原子化

Question

您好，我有以下问题：

我有一个包含字符串的散列。这个散列将被多个用户查询。

当用户自带Key 时，首先检查它是否存在于此哈希中，如果不存在，则添加它。

如何使操作“检查哈希是否存在”、“如果不存在则添加”原子操作？ 阅读redis文档似乎Watch是我需要的。基本上开始一个事务，如果变量发生变化就结束它。

我尝试使用Condition.HashNotExists 无济于事：

class Program {

        public static async Task<bool> LockFileForEditAsync(int fileId) {
            var database = ConnectionMultiplexer.Connect(CON).GetDatabase();
            var exists = await database.HashExistsAsync("files", fileId); //this line is for  shorting the transaction if hash exists 

            if (exists) {
                return false;
            }

            var tran = database.CreateTransaction();
            tran.AddCondition(Condition.HashNotExists("files", fileId));
            var setKey = tran.HashSetAsync("files", new HashEntry[] { new HashEntry(fileId, 1) });
            var existsTsc = tran.HashExistsAsync("files", fileId);

            if (!await tran.ExecuteAsync()) {
                return false;
            }

            var rezult = await existsTsc;
            return rezult;
        }

        public const string CON = "127.0.0.1:6379,ssl=False,allowAdmin=True,abortConnect=False,defaultDatabase=0";

        static async Task Main(string[] args) {
            int fid = 1;
            var locked = await LockFileForEditAsync(fid);
        }
    }

如果我通过redis-cli 连接并在cli 中发出：hset files {fileId} 1，对之前我发出ExecuteAsync（在调试器中）我预计此事务将失败，因为我放置了Condition。然而事实并非如此。

我怎样才能基本上使用redis命令在两个操作上放置类似锁的东西：

1. 检查hashentry是否存在
2. 添加哈希条目

Answer 1

坏消息，好消息，以及其他一切......

坏消息

这不起作用，因为 SE.Redis 管道传输事务。这意味着当调用ExecuteAsync() 时，所有事务命令都会同时发送到服务器。但是，首先评估条件。

tran.AddCondition(Condition.HashNotExists("files", fileId)); 转换为：

WATCH "files"
HEXISTS "files" "1"

当调用ExecuteAsync() 来评估条件时，首先发送这两个命令。如果条件成立 (HEXISTS "files" "1" = 0)，则发送其余事务命令。

这有效地确保没有误报，因为如果在两者之间修改了files 键（同时 SE.Redis 正在评估条件），WATCH 将使事务失败。

问题在于漏报。例如，如果在 SE.Redis 评估条件时设置了哈希的另一个字段，则事务也会失败。 WATCH "files" 做到了。

我通过在调用ExecuteAsync() 时运行redis-benchmark -c 5 HSET files 2 1 对此进行了测试。条件通过，但交易失败，虽然字段“1”不存在，因为字段“2”设置在两者之间。

我在单独的 redis-cli 窗口中使用 MONITOR 命令进行了验证。这对于排除未满足的期望或只是查看服务器的实际情况和时间非常方便。

WATCH 在您关心哈希的某个字段时没有帮助，因为它会在触及其他字段时产生误报。

对此的解决方案是使用常规密钥 (files:1)。

好消息

有一个命令可以做你想做的事：HSETNX。

这完全简化了您的 LockFileForEditAsync()：

    public static async Task<bool> LockFileForEditAsync(int fileId)
    {
        var database = ConnectionMultiplexer.Connect(CON).GetDatabase();
        var setKey = await database.HashSetAsync("files", fileId, 1, When.NotExists);
        return setKey;
    }

注意When.NotExists 参数。这会导致发送HSETNX "files" "1" "1" 命令。

其他一切......

您可以在这种情况下使用Lua scripts，在这种情况下，您希望以原子方式完成一些条件操作，例如how to use spop command with count if set have that much (count) element in set。

您似乎正在尝试执行分布式锁。有关您可能要考虑的其他方面，请参阅Distributed locks with Redis。请参阅What is distributed Atomic lock in caches drivers? 了解关于此的精彩故事。