事务
-
操作
# ex，过期时间（秒） # px，过期时间（毫秒） # nx，如果设置为True，则只有name不存在时，当前set操作才执行 # xx，如果设置为True，则只有name存在时，当前set操作才执行 redis_client.set('name', 'zs', ex=10)
-
事务：
-
语法：
MULTI (multi)：开启事务，后续的命令会被加入同一个事务中。 事务中的操作会发送给服务端，但是不会立即执行， 而是放到了该事务的对应的一个队列中，服务端返回QUEUED
EXEC (exec)：python文件引用中是execute，执行EXEC后，事务中的命令才会被执行，事务中的命令出现错误时，不会回滚也不会停止事务， 而是继续执行。
DISCARD（discard）：取消事务，事务队列会清空，客户端退出事务状态
-
ACID：
原子性：不支持。不会回滚并且继续执行
隔离性：支持。事务中命令顺序执行，并且不会被其他客户端打断（先EXEC的先执行）。单机redis读写操作使用 单进程单线程
持久性：不支持，因为redis数据容易丢失
一致性：不支持。 强一致性要求，可以通过乐观锁（watch）来实现
-
WATCH：
- redis机制的乐观锁
- 机制：事务开启前，设置对数的监听，EXEC时，如果发现数据发生过修改，事务会自动取消（DISCARD）。事务EXEC后，无论成败，监听会被移除。
-
setnx和悲观锁
- setnx键不存在，才会设置成功
-
非事务性管道
- redis实现了管道机制，可以将多个操作打包发给redis服务器
- 可以单独使用管道，不需要开启事务 对于没有事务要求的多个操作，可以直接使用非事务性管道进行处理，减少事务产生的性能消耗。
- 创建非事务性管道，通过transaction=False参数设置
-
redis乐观锁实现秒杀超卖需求
from redis import StrictRedis, WatchError
# 创建redis连接
# decode_responses = True 是指定数据是字符串的格式，host是连接地址，port是连接端口，db是连接的数据库。
redis_client = StrictRedis(host='127.0.0.1', port=6379, db=0, decode_responses=True)
# 1. 创建管道 默认会开启事务
pipeline = redis_client.pipeline()
while True:
try:
# 2. 设置数据的监听 一旦设置了监听 就不会自动开启事务 后续操作都会变成立即执行
pipeline.watch('count')
# 3. 获取数据 可以立即得到结果
count = pipeline.get('count')
# 判断库存满足，满足减少库存并生成订单
if int(count) > 0:
# 4. 手动开启事务 开启后 后续的操作会加入到事务中
pipeline.multi()
# 减少库存
pipeline.decr('count')
# 提交事务 如果监听的数据中途被修改，会抛出WatchErrou错误，可以捕获异常，
pipeline.execute() # 无论成功失败， 监听都会移除
print('生成订单')
else:
# 没有库存，手动移除监听
pipeline.reset()
print("已售罄")
break
except WatchError as e:
# 监听的数据被修改，重试。
print("重试")
continue
# 在redis 终端设计一个库存数据
在redis 终端设计一个库存数据
1562764435772.png
redis悲观锁实现秒杀超卖需求
from redis import StrictRedis
# 创建redis连接
# decode_responses = True 是指定数据是字符串的格式，host是连接地址，port是连接端口，db是连接的数据库。
redis_client = StrictRedis(decode_responses=True)
while True:
# 设置个字段 a 并且等于1 setnx 键不存在,才会设置成功
order_lock = redis_client.setnx('a', 1)
if order_lock:
reserver_count = redis_client.get('count')
if int(reserver_count) > 0:
redis_client.decr('count')
print('生成订单')
else:
print('已售罄')
# 完成处理，移除锁
redis_client.delete('a')
break
非事务管道
from redis import StrictRedis
redis_client = StrictRedis(decode_responses=True)
# 创建非事务型管道 通过teansaction = False 设置
pipeline = redis_client.pipeline(transaction = False)
# 这些操作不会添加到事务中
a = pipeline.set('name','zs')
# 只是将管道中的操作一起发送给redis服务器， 不会进行watch遍历和检查
c = pip.execute()
print(a)
print(c)
