Redis-分布式锁
在Redis中实现分布式锁通常使用SETNX
命令(或在Redis 2.6.12以上版本中使用SET key value EX max-lock-time NX
命令,这样可以一次性设置并加锁,避免了两条命令之间客户端可能挂掉的问题),然后使用EXPIRE
命令来给锁设置一个过期时间,以防服务器崩溃导致锁未被释放。
以下是一个使用SET
命令实现分布式锁的Python示例,使用redis-py
库:
import redis
import time
import uuid
def acquire_lock(conn, lock_name, acquire_timeout=10, lock_timeout=10):
identifier = str(uuid.uuid4()) # 生成一个唯一的ID
end = time.time() + acquire_timeout
while time.time() < end:
if conn.set(lock_name, identifier, ex=lock_timeout, nx=True):
return identifier # 加锁成功
time.sleep(0.001)
return False # 在规定时间内未能获得锁
def release_lock(conn, lock_name, identifier):
pipe = conn.pipeline(True)
while True:
try:
pipe.watch(lock_name)
if pipe.get(lock_name) == identifier:
pipe.multi()
pipe.delete(lock_name)
pipe.execute()
return True
pipe.unwatch()
break
except redis.exceptions.WatchError:
pass
return False # 释放锁失败,可能因为锁已被其他客户端修改
# 使用示例
client = redis.StrictRedis(host='localhost', port=6379, db=0)
lock_name = "my_lock"
lock_identifier = acquire_lock(client, lock_name)
if lock_identifier:
try:
# 在这个区块内执行需要互斥的操作
finally:
if not release_lock(client, lock_name, lock_identifier):
print("Failed to release lock")
else:
print("Failed to acquire lock")
在这个示例中,acquire_lock
函数尝试获取锁,如果在指定时间内未能获得锁,则返回False
。release_lock
函数尝试释放锁,如果锁不属于指定的ID或者因为WATCH失败,则返回False
。这个实现使用了Redis的事务和watch命令来保证锁的安全性。
评论已关闭