StackExchange.Redis 系列 5:事务

  • 本系列博文是“伪”官方文档翻译,并非完全将官方文档进行翻译,而是我在查阅、测试原始文档并转换为自己东西后进行的“准”翻译。
  • 原始文档见此:https://stackexchange.github.io/StackExchange.Redis/
  • 本系列本博文基于 redis 5.0.6,系列中部分博文跟官方文档有出入,有不同见解 / 说明不当的地方,还请大家不吝拍砖。

Redis 中的事务说明

  • Redis 中的事务跟我们常说的数据库事务不同:
    • 数据库事务必须保证全部成功,否则就回滚。
    • 而 Redis 中的事务更偏向于“一组打包的批量执行脚本”,其中任何一条命令的执行失败,不会导致已经执行的命令回滚,也不会中断后续的命令执行。
  • 在使用数据库事务的时候,你可以在事务中使用条件判断。但在 Redis 事务中,你无法使用条件判断。(条件见下方说明)

如何使用事务?

  • 在 Redis 原生命令中使用 MULTI 来开启事务,EXEC 来执行事务(或者 DISCARD 来取消事务)
  • 一旦使用 MULTI,在 MULTI 之后的命令不会立即执行,它们会排队,直到接收到 EXEC命令。如果接收到的时 DISCARD 命令,则所有已传输的命令会全部抛弃。
    • 因为 Redis 命令会排队执行,所以无法在 Redis 中使用条件判断。

是否有方法可以在 redis 事务中使用条件判断?

答案是肯定的,可以通过使用 WATCH 和 UNWATCH 命令来实现 redis 中使用条件判断。

  • WATCH :监听一个 key,当这个 key 有任何变动,都会导致事务的回滚

使用 Redis 原生命令来使用事务

WATCH {custKey}
HEXISTS {custKey} "UniqueId"
(check the reply, then either:)
MULTI
HSET {custKey} "UniqueId" {newId}
EXEC
(or, if we find there was already an unique-id:)
UNWATCH #取消所有 key 被监听。

使用 StackExchange.Redis 来使用事务。

  • StackExchange.Redis 通过 Multiplexer 方法来实现事务。

    var newId = CreateNewId();
    var tran = db.CreateTransaction();
    tran.AddCondition(Condition.HashNotExists(custKey, "UniqueID"));
    tran.HashSetAsync(custKey, "UniqueID", newId);
    bool committed = tran.Execute();
    
  • 当所有限制条件都通过的时候,才会执行 EXEC,否则会使用 DISCARD 进行回滚。
  • 需要注意的是只有在异步方法中才能调用 “db.CreateTransaction()”方法,同步方法中无法点出该方法。
  • 当事务成功执行,则正常获取结果,否则,所有 Tasks 都将会 cancelled。

    内置命令 When 说明

  • 判断是否存在一个对象/不存在一个对象,这样的使用场景还是比较普遍的,因此 StackExchange.Redis 内置了一个 When 枚举参数来简化这种操作。
  • 使用 When 来简化上方的业务代码:

var newId = CreateNewId();
bool wasSet = db.HashSet(custKey, "UniqueID", newId, When.NotExists);
  • 这里的 When.NotExists 会触发 SETNX 命令而非 HSET 命令。

LUA

  • Redis 2.6 版本开始,提供了 LUA 脚本。因为 LUA 脚本在执行的时候会独占服务器,所以通过 LUA 脚本,可以更加语义化的实现”事务”。
  • 相对的,在执行 LUA 脚本的时候,整个服务器会被独占,导致其他请求等待。

EVAL "if redis.call('hexists', KEYS[1], 'UniqueId') then return redis.call('hset', KEYS[1], 'UniqueId', ARGV[1]) else return 0 end" 1 {custKey} {newId}

上述 Redis 原生命令可以用以下 StackExchange.Redis 代码来实现:

var wasSet = (bool) db.ScriptEvaluate(@"if redis.call('hexists', KEYS[1], 'UniqueId') then return redis.call('hset', KEYS[1], 'UniqueId', ARGV[1]) else return 0 end", new RedisKey[] { custKey }, new RedisValue[] { newId });
  • 需要注意的是,返回数据取决于你的脚本内容,你需要对结果按需进行转换。如上方例子,返回结果是 Boolean 类型

常言道:学然后知不足,教然后知困。

我知道你的焦虑,一起共进加油:P

关不关注都无所谓,会根据生活节奏紧凑度定期分享些开发经验、搬砖生涯、痛点、感悟。

欢迎关注我的订阅号:P