Redis做分布式锁如何处理超时时间？

在使用Redis做分布式锁时，为了处理可能出现的锁超时问题，可以在获取锁之前设置一个合理的超时时间，并在释放锁时进行检查。以下是一个简单的示例：

import redis
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.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
 
# 使用示例
r = redis.Redis()
lock_name = "my_lock"
identifier = acquire_lock(r, lock_name)
if identifier:
    try:
        # 处理业务逻辑
        pass
    finally:
        release_lock(r, lock_name, identifier)
else:
    # 无法获取锁，执行其他操作或者等待重试
    pass

在这个示例中，acquire_lock 函数尝试获取锁，如果在指定时间内未能获取锁，则返回False。release_lock 函数则尝试释放锁，并检查是否是锁的拥有者再进行释放。这里使用了Redis的SETNX命令来实现非阻塞的锁获取，并设置了锁的过期时间来防止死锁。在释放锁时，使用了Redis的事务机制来保证操作的原子性。