这篇文章给大家分享的是有关python使用Redis构建分布式锁的示例的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
在实际应用场景中,我们可能有多个worker,可能在一台机器,也可能分布在不同的机器,但只有一个worker可以同时持有一把锁,这个时候我们就需要用到分布式锁了。
这里推荐python的实现库,Redlock-py (Python 实现).
正常情况下,worker获得锁后,处理自己的任务,完成后自动释放持有的锁,是不是感觉有点熟悉,很容易想到我们的上下文管理器,这里我们简单的用装饰器实现 with...as... 语法。
安装Redlock-py
$ pip install redlock-py
使用python自带的 contextmanager 装饰器试下上下文管理
from contextlib import contextmanager
from redlock import Redlock
@contextmanager
def worker_lock_manager(key, ttl, **kwargs):
"""
分布式锁
:param key: 分布式锁ID
:param ttl: 分布式锁生存时间
:param kwargs: 可选参数字典
:return: None
"""
redis_servers = [{
'host': '127.0.0.1',
'port': 6379,
'db': 0,
'password': 'pwd'
}]
rlk= Redlock(redis_servers)
# 获取锁
lock = rlk.lock(key, ttl)
yield lock
# 释放锁
rlk.unlock(lock)
如何使用呢
with worker_lock_manager('unique_key', 1000) as w_lock:
if w_lock is False:
return
do_something()
感谢各位的阅读!关于“python使用Redis构建分布式锁的示例”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。