redisssion分布式锁
在Redis中实现一个分布式锁通常使用SETNX
命令(只在键不存在时,设置键的值)或使用SET
命令结合NX
和PX
选项(只在键不存在时设置,并设置一个过期时间)。以下是使用SET
命令实现分布式锁的示例代码:
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, nx=True, px=lock_timeout * 1000):
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
# 使用示例
redis_conn = redis.StrictRedis(host='localhost', port=6379, db=0)
lock_name = "my_lock"
lock_identifier = acquire_lock(redis_conn, lock_name)
if lock_identifier:
try:
# 在这里执行需要互斥访问的代码
print("Lock acquired")
finally:
if release_lock(redis_conn, lock_name, lock_identifier):
print("Lock released")
else:
print("Unable to release lock")
else:
print("Unable to acquire lock")
这段代码定义了两个函数:acquire_lock
和 release_lock
。acquire_lock
尝试获取锁,如果在指定时间内成功,它会返回一个唯一的标识符;否则,它会返回 False
。release_lock
尝试释放锁,如果标识符匹配并且释放成功,它会返回 True
;否则,它会返回 False
。在使用这个锁时,你需要确保在执行完必须互斥的操作后释放锁。
评论已关闭