python中,用Redis构建分布式锁

Posted ExplorerMan

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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构建分布式锁的主要内容,如果未能解决你的问题,请参考以下文章

《Redis官方文档》用Redis构建分布式锁

用redis构建分布式锁

Redis实现分布式锁(设计模式应用实战)

Redis实现分布式锁(设计模式应用实战)

Redis(三十二)-用Redis做分布式锁

Redis(三十二)-用Redis做分布式锁