Redis06_Redis事务和乐观锁的实现

傷城~ 2022-12-02 10:49 195阅读 0赞

**Redis06\_事务和乐观锁的实现**

--------------------

**Redis 事务**

**Redis 事务的本质：一组命令的集合！**

**一个事务中的所有命令都会被序列化，在事务执行过程中会按顺序执行**

**Redis 单条命令保证原子性，但是事务不保证原子性**

**Redis 事务没有隔离级别的概念，所有的命令在事务中并没有直接被执行，只有发起执行命令的时候才会执行**

**multi 开启事务**  
**exec 提交执行事务**

127.0.0.1:6379> multi
    OK
    127.0.0.1:6379> set k1 v1
    QUEUED
    127.0.0.1:6379> set k2 v2
    QUEUED
    127.0.0.1:6379> get k2
    QUEUED
    127.0.0.1:6379> set key3 v3
    QUEUED
    127.0.0.1:6379> exec
    1) OK
    2) OK
    3) "v2"
    4) OK

**discard 取消事务**

127.0.0.1:6379> multi
    OK
    127.0.0.1:6379> set k1 v1
    QUEUED
    127.0.0.1:6379> set k2 v2
    QUEUED
    127.0.0.1:6379> set k4 v4
    QUEUED
    127.0.0.1:6379> discard
    OK

**事务编译型异常，所有的命令都不会执行**

127.0.0.1:6379> multi
    OK
    127.0.0.1:6379> set k1 v1
    QUEUED
    127.0.0.1:6379> set k2 v2
    QUEUED
    127.0.0.1:6379> set k3 v3
    QUEUED
    127.0.0.1:6379> getset k3
    (error) ERR wrong number of arguments for 'getset' command
    127.0.0.1:6379> set k4 v4
    QUEUED
    127.0.0.1:6379> exec
    (error) EXECABORT Transaction discarded because of previous errors.
    127.0.0.1:6379> get k1
    (nil)

**事务运行时异常，错误命令不会执行，但其他命令成功执行（不保证原子性）**

127.0.0.1:6379> set k1 'BLU'
    OK
    127.0.0.1:6379> multi
    OK
    127.0.0.1:6379> incr k1
    QUEUED
    127.0.0.1:6379> set k2 v2
    QUEUED
    127.0.0.1:6379> set k3 v3
    QUEUED
    127.0.0.1:6379> get k3
    QUEUED
    127.0.0.1:6379> exec
    1) (error) ERR value is not an integer or out of range
    2) OK
    3) OK
    4) "v3"

--------------------

**Redis使用 watch 实现乐观锁操作**

悲观锁：很悲观，认为什么时候都会出问题，无论做什么都加锁，影响性能
    
    乐观锁：很乐观，认为什么时候都不会出现问题，所以不会加锁，更新数据的时候判断在此期间是否有人改动过这个数据，比如使用version字段判断

**数据期间没有发生变动，事务正常执行成功：**

127.0.0.1:6379> set money 100
    OK
    127.0.0.1:6379> set out 0
    OK
    127.0.0.1:6379> watch money
    OK
    127.0.0.1:6379> multi
    OK
    127.0.0.1:6379> decrby money 20
    QUEUED
    127.0.0.1:6379> incrby out 20
    QUEUED
    127.0.0.1:6379> exec
    1) (integer) 80
    2) (integer) 20

**线程1监控money并开启事务：**

watch money
    OK
    127.0.0.1:6379> multi
    OK
    127.0.0.1:6379> decrby money 10
    QUEUED
    127.0.0.1:6379> incrby out 10
    QUEUED

**线程2修改money：**

127.0.0.1:6379> get money
    "80"
    127.0.0.1:6379> set money 10000
    OK

**线程1提交执行事务（监视的money被线程2修改了，导致线程1事务执行失败）**  
**此时线程1可以 unwatch 先解锁，再重新加锁，然后重新执行事务：**

127.0.0.1:6379> exec
    (nil)
    127.0.0.1:6379> unwatch
    OK
    127.0.0.1:6379> watch money
    OK
    127.0.0.1:6379> multi
    OK
    127.0.0.1:6379> decrby money 20
    QUEUED
    127.0.0.1:6379> incrby out 20
    QUEUED
    127.0.0.1:6379> exec
    1) (integer) 9980
    2) (integer) 40