Redis7-分布式锁

在Redis 7中，分布式锁可以通过使用SET命令的NX（唯一性）和PX（过期时间）选项来实现。这里是一个使用Redis 7的分布式锁的Python示例，使用redis-py库：

import redis
import uuid
import time
 
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, 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.Redis()
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("Failed to release lock")
else:
    print("Failed to acquire lock")

在这个示例中，acquire_lock函数尝试获取锁，如果在指定时间内成功，它会返回一个唯一的标识符。release_lock函数尝试释放锁，它会检查锁是否仍然是由指定的标识符所拥有，然后释放它。这里使用了Redis的事务来确保锁的释放是安全的。