分布式锁

在实际应用场景中，我们可能有多个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()