事务:
事务提供了一种将多个命令请求打包,然后一次性按照顺序的执行多个命令的机制.并且在事务执行期间,服务器不会中断事务而改去执行其他客户端的命令请求.它会将事务中的所有命令都执行完毕,然后才去处理其他客户端的命令请求.
事务的实现:
1 事务开始
MULTI命令的执行标志着事务的开始.该命令可以将所在的客户端从非事务状态切换至事务状态,这一切换是通过redisCLient的flags属性中打开REDIS_MULTI标识完成的.
2 命令入队
1 事务状态开启,如果是EXEC, DISCARD, WATCH, MULTI四个命令则立即执行,如果不是,将命令加入到事务队列.
2 每个redis客户端都有自己的事务状态,这个事务状态保存在redisClient的mstate属性中
3 事务状态包含一个事务队列,以及一个已入队命令的计数器,记录事务队列的长度
4 事务队列是一个multiCmd结构体类型的数组.数组中的每一个multiCmd结构都报错了一个已入队命令的相关信息,包含指向命令实现的函数的指针,命令的参数,以及参数的数量
5 事务队列已先进先出(FIFO)的方式保存了入队的命令.先入队的放到数组的前面,后入队的放到数组的后面.
3 事务执行
1 当处于事务状态的客户端向服务器发送EXEC命令时,服务器会遍历这个客户端的事务队列,执行事务队列中保存的所有命令,最后将执行的命令结果全部返回给客户端
WATCH命令的实现:
WATCH命令是一个乐观锁.它可以在EXEC命令执行之前,监视任意数量的数据库键,并在EXEC命令执行时,检查被监视的键是否有至少一个被修改.如果是的话,服务器将拒绝执行事务,并向客户端返回代表事务执行失败的nil回复.
ps: 客户端A:WATCH "name"->MULTI->set "name" "小二逼"->EXEC->服务端返回nil 原因:在事务提交EXEC命令之前,客户端B执行了set "name" "二狗子",导致事务执行失败.
WATCH命令的原理:
1 每个redis数据库reidsDB都保存着一个watched_keys字典,这个字典的key是某个被WATCH命令监视的数据库键,而字段的值是一个链表,链表中记录了所有监视相应数据库键的客户端.
2 所有对数据库命令的写操作,在执行之后都会调用touchWatchKey函数对watched_keys字典进行检查.查看是否有客户端正在监视刚刚被命令修改过的数据库键. 如果有的话,就会将监视的客户端的REDIS_DIRTY_CAS标识打开,表示该客户端的事务安全性被破坏.(只要有一个键被修改,标识都会改变)
3 当一个客户端发来EXEC命令时,服务器会根据这个客户端是否打开了REDIS_DIRTY_CAS标识来决定是否执行事务,
事务的ACID性质:
1 原子性:一段命令要不都不执行,要不都执行.区别在于,redis不支持事务回滚机制,即使事务队列中的某个命令在执行期间出现错误,整个事务也会继续执行下去.直到将事务队列中的所有命令都执行完毕.
2 一致性:数据库在执行事务之前是一致的,那么在事务执行之后,无论事务是否执行成功,数据库也应该是一致的.
3 隔离性:单线程执行.不会在事务执行期间对事务进行中断.
4 在AOF模式下,appendfsync选项的值为always时,程序总会在执行命令之后调用同步函数,所以具有耐久性
