Python分布式锁：redis-py分布式锁的使用

import redis
import time
import uuid
 
# 连接Redis
client = redis.StrictRedis(host='localhost', port=6379, db=0)
 
# 尝试获取分布式锁的函数
def acquire_lock(lock_key, acquire_timeout=10, lock_timeout=10):
    identifier = str(uuid.uuid4())  # 生成一个唯一的ID
    end = time.time() + acquire_timeout
 
    while time.time() < end:
        if client.set(lock_key, identifier, ex=lock_timeout, nx=True):
            # 如果设置成功，表示获取锁成功
            return identifier
        time.sleep(0.001)
 
    return False
 
# 释放分布式锁的函数
def release_lock(lock_key, identifier):
    pipe = client.pipeline(True)
    while True:
        try:
            # 检查锁是否是当前的ID
            pipe.get(lock_key)
            current_identifier = pipe.execute()[0]
            if current_identifier == identifier:
                # 释放锁
                pipe.delete(lock_key)
                pipe.execute()
                return True
            else:
                return False
        except redis.exceptions.WatchError:
            # 如果在检查过程中锁已经被其他客户端获取或释放，重试
            continue
 
# 使用示例
lock_key = "my_lock"
lock_identifier = acquire_lock(lock_key)
if lock_identifier:
    try:
        # 在这里执行需要互斥访问的代码
        print("Lock acquired. Exclusive access to the code block.")
    finally:
        # 确保释放锁
        if release_lock(lock_key, lock_identifier):
            print("Lock released.")
        else:
            print("Unable to release lock.")
else:
    print("Unable to acquire lock.")

这段代码展示了如何使用redis-py库来实现一个基本的分布式锁。它首先定义了连接到Redis服务器的客户端，然后定义了获取和释放锁的函数。在使用时，首先尝试获取锁，如果成功，则执行需要互斥访问的代码，并在最后确保释放锁。如果无法获取锁，则代码块将不会执行，并且打印相应的信息。