• Redis事务和锁机制


    Redis事务和锁机制

    1.Redis的事务定义

    Redis事务是一个单独的隔离操作:事务中的所有命令都会序列化、按顺序地执行。**事务在执行的过程中,不会被其他客户端发送来的命令请求所打断。**Redis事务的主要作用就是串联多个命令防止别的命令插队。

    2.Multi、Exec、discard

    从输入Multi命令开始,输入的命令都会依次进入命令队列中,但不会执行,直到输入Exec后,Redis会将之前的命令队列中的命令依次执行。

    组队的过程中可以通过discard来放弃组队。

    image-20220821185221774

    image-20220821211056766

    image-20220821211023671

    image-20220821211411561

    3.事务的错误处理

    组队中某个命令出现了报告错误(尚未执行exec执行指令,在执行组队的指令就报错了),执行时整个的所有队列都会被取消。

    image-20220821185332412

    127.0.0.1:6379> MULTI
    OK
    127.0.0.1:6379(TX)> set nickname zansan
    QUEUED
    127.0.0.1:6379(TX)> set age
    #在执行set age时没有指定key的值,执行set指令报错
    (error) ERR wrong number of arguments for 'set' command
    127.0.0.1:6379(TX)> exec
    #执行exec去执行事务,由于上一个指令的错误而被废弃了
    (error) EXECABORT Transaction discarded because of previous errors.
    127.0.0.1:6379> get nickname
    #由于事务执行失败,我们前面set的nickname也没有成功,因此返回nil
    (nil)
    127.0.0.1:6379> 
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14

    如果执行阶段(调用exec执行命令,执行时出现错误)某个命令报出了错误,则只有报错的命令不会被执行,而其他的命令都会执行,不会回滚。

    image-20220821185332412

    #开启事务
    127.0.0.1:6379> MULTI
    OK
    127.0.0.1:6379(TX)> set name gukong
    QUEUED
    127.0.0.1:6379(TX)> set age 21
    QUEUED
    127.0.0.1:6379(TX)> INCR age 
    QUEUED
    127.0.0.1:6379(TX)> set phone hahah
    QUEUED
    #incr  将key中储存的数字值增1只能对数字值操作,如果为空,新增值为1
    127.0.0.1:6379(TX)> INCR phone
    QUEUED
    127.0.0.1:6379(TX)> exec
    1) OK
    2) OK
    3) (integer) 22
    4) OK
    #调用exec执行第五条指令 incr phone时,由于我们设置的值为“hahah"无法将phone的值自增1
    5) (error) ERR value is not an integer or out of range
    127.0.0.1:6379> get phone
    "hahah"
    127.0.0.1:6379> get age
    "22"
    127.0.0.1:6379> get name
    "gukong"
    127.0.0.1:6379> 
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28

    4.Redis的锁机制

    1.事务冲突的问题

    个请求想给金额减8000

    一个请求想给金额减5000

    一个请求想给金额减1000

    image-20220821185643707

    2.悲观锁

    image-20220821185628501

    悲观锁(Pessimistic Lock), 顾名思义,就是很悲观,每次去拿数据的时候都认为别人会修改,所以每次在拿数据的时候都会上锁,这样别人想拿这个数据就会block直到它拿到锁。传统的关系型数据库里边就用到了很多这种锁机制,比如行锁,表锁等,读锁,写锁等,都是在做操作之前先上锁。

    3.乐观锁

    image-20220821185823301

    乐观锁(Optimistic Lock), 顾名思义,就是很乐观,每次去拿数据的时候都认为别人不会修改,所以不会上锁,但是在更新的时候会判断一下在此期间别人有没有去更新这个数据,可以使用版本号等机制。乐观锁适用于多读的应用类型,这样可以提高吞吐量。Redis就是利用这种check-and-set机制实现事务的。

    4.WATCH key [key …]

    在执行multi之前,先执行watch key1 [key2],可以监视一个(或多个) key ,如果在事务执行之前这个(或这些) key 被其他命令所改动,那么事务将被打断(前面所有的组队指令都不会被执行)。

    演示redis的乐观锁

    连接一

    127.0.0.1:6379> get name
    "kililin"
    #观察key为name的值的变化
    127.0.0.1:6379> watch name
    OK
    #开启事务
    127.0.0.1:6379> MULTI
    OK
    127.0.0.1:6379(TX)> set name tianjianfan
    QUEUED
    #这里我们在执行exec之前,先去连接二执行了set name gukong指令,此时name=gukong
    #由于前面我们watch了name的值的变化,当执行exec指令时发现 name!=kulilin(原来的值)则前面所有的组队指令都不会被执行,事务被打断。
    127.0.0.1:6379(TX)> exec
    (nil)
    127.0.0.1:6379> get name
    "gukong"
    127.0.0.1:6379> 
    
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18

    连接二

    127.0.0.1:6379> set name gukong
    OK
    127.0.0.1:6379> 
    
    • 1
    • 2
    • 3

    5.unwatch

    取消 WATCH 命令对所有 key 的监视。

    如果在执行 WATCH 命令之后,EXEC 命令或DISCARD 命令先被执行了的话,那么就不需要再执行UNWATCH 了。

    http://doc.redisfans.com/transaction/exec.html

    5.Redis事务三特性

    1.单独的隔离操作

    事务中的所有命令都会序列化、按顺序地执行。事务在执行的过程中,不会被其他客户端发送来的命令请求所打断。

    2.没有隔离级别的概念

    队列中的命令没有提交之前都不会实际被执行,因为事务提交前任何指令都不会被实际执行

    3.不保证原子性

    事务中如果有一条命令执行失败,其后的命令仍然会被执行,没有回滚

  • 相关阅读:
    golang数组和Slice地址
    Python01(安装环境以及开发工具PyCharm)
    VUE3中 reacitive源码理解
    springboot启动时如何自动执行代码以及如何提高吞吐量
    ssm+thymeleaf国际化
    Grafana Prometheus 监控JVM进程
    Meta Llama 3 RMSNorm(Root Mean Square Layer Normalization)
    目标检测回归损失函数(看情况补...)
    pgsql 创建自增ID , 指定自增ID起始值
    调用API接口获取淘宝商品数据:实践指南与代码解析
  • 原文地址:https://blog.csdn.net/qq_44981526/article/details/126456980