标签：Redlock python lock worker key ttl 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()

标签：Redlock,python,lock,worker,key,ttl,Redis,分布式
来源： https://www.cnblogs.com/ExMan/p/12189762.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。