标签：style art start 重试 als lock 生成 ide 序列化
什么是分布式锁？
分布式锁是控制分布式系统之间同步访问共享资源的一种方式。
什么实用分布式锁？
什么场景下使用分布式锁？
数据重要且要保证一致性
2.一个事务中的所有命令都会序列化，按顺序串行化的执行而不会被其他命令插入
作用：一个队列中，一次性、顺序性、排他性的执行一系列命令
下面指令演示了一个完整的事物过程，所有指令在exec前不执行，而是缓存在服务器的一个事物队列中
服务器一旦收到exec指令才开始执行事物队列，执行完毕后一次性返回所有结果
因为redis是单线程的，所以不必担心自己在执行队列是被打断，可以保证这样的“原子性”
注：redis事物在遇到指令失败后，后面的指令会继续执行
# Multi 命令用于标记一个事务块的开始事务块内的多条命令会按照先后顺序被放进一个队列当中，最后由 EXEC 命令原子性( atomic )地执行 > multi（开始一个redis事物） incr books incr books > exec （执行事物） > discard （丢弃事物）
注：mysql的rollback与redis的discard的区别
mysql回滚为sql全部成功才执行,一条sql失败则全部失败,执行rollback后所有语句造成的影响消失
redis的discard只是结束本次事务,正确命令造成的影响仍然还在.
1）redis如果在一个事务中的命令出现错误，那么所有的命令都不会执行； 2）redis如果在一个事务中出现运行错误，那么正确的命令会被执行。
实质：WATCH 只会在数据被其他客户端抢先修改了的情况下通知执行命令的这个客户端（通过 WatchError 异常）但不会阻止其他客户端对数据的修改
watch其实就是redis提供的一种乐观锁，可以解决并发修改问题
watch会在事物开始前盯住一个或多个关键变量，当服务器收到exec指令要顺序执行缓存中的事物队列时，redis会检查关键变量自watch后是否被修改
WATCH 只会在数据被其他客户端抢先修改了的情况下通知执行命令的这个客户端（通过 WatchError 异常）但不会阻止其他客户端对数据的修改
1、分布式锁
分布式锁本质是占一个坑，当别的进程也要来占坑时发现已经被占，就会放弃或者稍后重试
先来先占，用完了在调用del指令释放坑
> setnx lock:codehole true .... do something critical .... > del lock:codehole
6. 这样又有一个问题，setnx和expire是两条指令而不是原子指令，如果两条指令之间进程挂掉依然会出现死锁
7.为了治理上面乱象，在redis 2.8中加入了set指令的扩展参数，使setnx和expire指令可以一起执行
> set lock:codehole true ex 5 nx ‘‘‘ do something ‘‘‘ > del lock:codehole
#! /usr/bin/env python # -*- coding: utf-8 -*- import redis def sale(rs): while True: with rs.pipeline() as p: try: p.watch(‘apple‘) # 监听key值为apple的数据数量改变 count = int(rs.get(‘apple‘)) print(‘拿取到了苹果的数量: %d‘ % count) p.multi() # 事务开始 if count> 0 : # 如果此时还有库存 p.set(‘apple‘, count - 1) p.execute() # 执行事务 p.unwatch() break # 当库存成功减一或没有库存时跳出执行循环 except Exception as e: # 当出现watch监听值出现修改时，WatchError异常抛出 print(‘[Error]: %s‘ % e) continue # 继续尝试执行 rs = redis.Redis(host=‘127.0.0.1‘, port=6379) # 连接redis rs.set(‘apple‘,1000) # # 首先在redis中设置某商品apple 对应数量value值为1000 sale(rs)
2、使用reids的 watch + multi + setnx指令实现
1）为什么要自己构建锁
然有类似的 SETNX 命令可以实现 Redis 中的锁的功能，但他锁提供的机制并不完整
. 并且setnx也不具备分布式锁的一些高级特性，还是得通过我们手动构建
2）创建一个redis锁
在 Redis 中，可以通过使用 SETNX 命令来构建锁：rs.setnx(lock_name, uuid值)
. 而锁要做的事情就是将一个随机生成的 128 位 UUID 设置位键的值，防止该锁被其他进程获取
3）释放锁
锁的删除操作很简单，只需要将对应锁的 key 值获取到的 uuid 结果进行判断验证
. 符合条件（判断uuid值）通过 delete 在 redis 中删除即可，pipe.delete(lockname)
3. 此外当其他用户持有同名锁时，由于 uuid 的不同，经过验证后不会错误释放掉别人的锁
4）解决锁无法释放问题
在之前的锁中，还出现这样的问题，比如某个进程持有锁之后突然程序崩溃，那么会导致锁无法释放
#! /usr/bin/env python # -*- coding: utf-8 -*- import redis import uuid import time # 1.初始化连接函数 def get_conn(host,port=6379): rs = redis.Redis(host=host, port=port) return rs # 2. 构建redis锁 def acquire_lock(rs, lock_name, expire_time=10): ‘‘‘ rs: 连接对象 lock_name: 锁标识 acquire_time: 过期超时时间 return -> False 获锁失败 or True 获锁成功 ‘‘‘ identifier = str(uuid.uuid4()) end = time.time() + expire_time while time.time() < end: # 当获取锁的行为超过有效时间，则退出循环，本次取锁失败，返回False if rs.setnx(lock_name, identifier): # 尝试取得锁 return identifier time.sleep(.001) return False # 3. 释放锁 def release_lock(rs, lockname, identifier): ‘‘‘ rs: 连接对象 lockname: 锁标识 identifier: 锁的value值，用来校验 ‘‘‘ pipe = rs.pipeline(True) try: pipe.watch(lockname) if rs.get(lockname).decode() == identifier: # 防止其他进程同名锁被误删 pipe.multi() # 开启事务 pipe.delete(lockname) pipe.execute() return True # 删除锁 pipe.unwatch() # 取消事务 except Exception as e: pass return False # 删除失败 ‘‘‘在业务函数中使用上面的锁‘‘‘ def sale(rs): start = time.time() # 程序启动时间 with rs.pipeline() as p: ‘‘‘ 通过管道方式进行连接 多条命令执行结束，一次性获取结果 ‘‘‘ while True: lock = acquire_lock(rs, ‘lock‘) if not lock: # 持锁失败 continue try: count = int(rs.get(‘apple‘)) # 取量 p.set(‘apple‘, count-1) # 减量 p.execute() print(‘当前库存量: %s‘ % count) break finally: release_lock(rs, ‘lock‘, lock) print(‘[time]: %.2f‘ % (time.time() - start)) rs = redis.Redis(host=‘127.0.0.1‘, port=6379) # 连接redis rs.set(‘apple‘,1000) # # 首先在redis中设置某商品apple 对应数量value值为1000 sale(rs)
def acquire_expire_lock(rs, lock_name, expire_time=10, locked_time=10): ‘‘‘ rs: 连接对象 lock_name: 锁标识 acquire_time: 过期超时时间 locked_time: 锁的有效时间 return -> False 获锁失败 or True 获锁成功 ‘‘‘ identifier = str(uuid.uuid4()) end = time.time() + expire_time while time.time() < end: # 当获取锁的行为超过有效时间，则退出循环，本次取锁失败，返回False if rs.setnx(lock_name, identifier): # 尝试取得锁 # print(‘锁已设置: %s‘ % identifier) rs.expire(lock_name, locked_time) return identifier time.sleep(.001) return False
标签：style art start 重试 als lock 生成 ide 序列化
原文地址：https://www.cnblogs.com/liudaya/p/12850360.html
