在使用Redis实现分布式锁时，可以使用SETNX命令来尝试获取锁，并通过EXPIRE命令为锁设置一个过期时间，以防止死锁。以下是一个简单的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())
end = time.time() + acquire_timeout
while time.time() < end:
if conn.setnx(lock_name, identifier):
conn.expire(lock_name, lock_timeout)
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函数尝试使用SETNX命令获取锁，并通过一个唯一标识符和EXPIRE命令来设置锁的过期时间。如果获取锁失败，它会在一个循环中不断尝试，直到超时。release_lock函数则会检查锁是否属于当前标识符，并且是否存在，然后删除它。在实际应用中，请确保处理异常情况，例如Redis服务器不可用或网络问题，以保证锁的正确释放。