1 分布式系统中，为了保证数据的最终一致性
2 具备特性
在分布式系统环境下，一个方法在同一时间只能被一个机器的一个线程执行；
高可用的获取锁与释放锁；
高性能的获取锁与释放锁；
具备可重入特性；
具备锁失效机制，防止死锁；
具备非阻塞锁特性，即没有获取到锁将直接返回获取锁失败
3 分布式锁实现
基于数据库实现分布式锁----》悲观---》效率很低
基于缓存（Redis等）实现分布式锁---》效率高
基于Zookeeper实现分布式锁---》
4 源码安装第三方包
-下载
-执行 python3 setup.py install
import redis
import uuid
import time
from threading import Thread
#连接redis
redis_client = redis.Redis(host="localhost",
port=6379,
password='',
db=10)
#获取一个锁
# lock_name：锁定名称
# acquire_time: 客户端等待获取锁的时间
# time_out: 锁的超时时间
def acquire_lock(lock_name, acquire_time=10, time_out=10):
"""获取一个分布式锁"""
identifier = str(uuid.uuid4())
end = time.time() + acquire_time
lock = "string:lock:" + lock_name
while time.time() < end:
if redis_client.setnx(lock, identifier):
# 给锁设置超时时间, 防止进程崩溃导致其他进程无法获取锁
redis_client.expire(lock, time_out)
return identifier
elif not redis_client.ttl(lock):
redis_client.expire(lock, time_out)
time.sleep(0.001)
return False
#释放一个锁
def release_lock(lock_name, identifier):
"""通用的锁释放函数"""
lock = "string:lock:" + lock_name
pip = redis_client.pipeline(True)
while True:
try:
pip.watch(lock)
lock_value = redis_client.get(lock)
if not lock_value:
return True
if lock_value.decode() == identifier:
pip.multi()
pip.delete(lock)
pip.execute()
return True
pip.unwatch()
break
except redis.excetions.WacthcError:
pass
return False
# def seckill():
# identifier=acquire_lock('resource')
# print(Thread.getName(),"获得了锁")
# release_lock('resource',identifier)
#
# if __name__ == '__main__':
#
# for i in range(50):
# t = Thread(target=seckill)
# t.start()
from redlock import Redlock
dlm = Redlock([{"host": "localhost", "port": 6379, "db": 0}, ])
def seckill():
identifier=dlm.lock('order_01',1000)
print(Thread.getName(),"获得了锁")
dlm.