Redis事务的应用

njsuntop

　　redis对事务的支持目前还比较简单。redis只能保证一个client发起的事务中的命令可以连续的执行，而中间不会插入其他client的命令。 由于redis是单线程来处理所有client的请求的所以做到这点是很容易的。一般情况下redis在接受到一个client发来的命令后会立即处理并 返回处理结果，但是当一个client在一个连接中发出multi命令有，这个连接会进入一个事务上下文，该连接后续的命令并不是立即执行，而是先放到一 个队列中。当从此连接受到exec命令后，redis会顺序的执行队列中的所有命令。并将所有命令的运行结果打包到一起返回给client.然后此连接就 结束事务上下文。
　　Redis与mysql事物
　　Mysql
　　Redis
　　开启
　　start transaction
　　muitl
　　语句
　　普通sql
　　普通命令
　　失败
　　rollback 回滚
　　discard 取消
　　成功
　　commit
　　exec
　　一、正常情况下，一个事物开启，语法检查没问题，并不是马上直接提交，而是放在一个队列里QUEUED
　　简单验证正常情况一个事物的过程：一个简单的银行转账，wang 有200元，zhao 有700元，wang转100给zhao的实现过程
　　127.0.0.1:6379> set  wang 200
　　OK
　　127.0.0.1:6379> set zhao 700
　　OK
　　127.0.0.1:6379> multi
　　OK
　　127.0.0.1:6379> decrby zhao 100  #decrby减去100
　　QUEUED
　　127.0.0.1:6379> incrby wang 100  #增加一百
　　QUEUED
　　127.0.0.1:6379> exec          #因为是开启事务，所以要”commit”才可以
　　1) (integer) 600
　　2) (integer) 300
　　127.0.0.1:6379> mget wang zhao
　　1) "300"
　　2) "600"    ##这里可以看到和设置的初始值不一样了~~！
　　二、当开启一个事务的时候，若有一个事务语法检查无法通过导致异常，开启的整个事务都会失败，直接被discard
　　127.0.0.1:6379> multi  #开启事务
　　OK
　　127.0.0.1:6379> decrby zhao 100 #减去了100，并且提示在队列里
　　QUEUED
　　127.0.0.1:6379> df  #输入一个错误
　　(error) ERR unknown command 'df'
　　127.0.0.1:6379> exec
　　(error) EXECABORT Transaction discarded because of previouserrors.
　　127.0.0.1:6379> mget zhao wang
　　1) "600"
　　2) "300" ##发现原来减去100没生效
　　三、Redis的简单事务，语法本身没错，但适用对象有问题，比如 zadd 操作list对象
　　Exec之后, 当事务在队列里，会执行正确的语句,并跳过有不适当的语句.
　　127.0.0.1:6379> mget zhao wang
　　1) "500"
　　2) "300"
　　127.0.0.1:6379> multi
　　OK
　　127.0.0.1:6379> decrby zhao 100
　　QUEUED
　　127.0.0.1:6379> sadd wang df
　　QUEUED
　　127.0.0.1:6379> exec
　　1) (integer) 400
　　2)(error) WRONGTYPE Operation against a key holding the wrong kind of value
　　127.0.0.1:6379> mget zhao wang
　　1) "400"
　　2) "300"
　　四、Redis的事务中,启用的是乐观锁，只负责监测key没有被改动，若KEY 被改动了事物取消，以买票为例：若没对key监控就会导致钱没了，票没买着钱被扣了,不加watch 自己验证……
　　实现过程：
　　窗口1
　　127.0.0.1:6379> mget zhao wang ticket
　　1) "600"
　　2) "600"
　　3) "1"
　　127.0.0.1:6379> watch ticket #监测ticket
　　OK
　　127.0.0.1:6379> multi #开启事务
　　OK
　　127.0.0.1:6379> decrby zhao 200 #减去200
　　QUEUED
　　127.0.0.1:6379> decr ticket #获取TICKET
　　QUEUED
　　窗口2：
　　127.0.0.1:6379> decr ticket #直接购买票了，动作比窗口1快
　　窗口1：
　　127.0.0.1:6379> exec
　　(nil)
　　127.0.0.1:6379> mget zhao wang ticket
　　1) "600"
　　2) "600"
　　3) "0"
　　Watch可以监控多个key，若多个key有一个发生变化，，则事务都取消
　　取消监听unwatch