《Redis实战篇》分布式锁

在分布式系统中，实现互斥访问是非常重要的。Redis 提供了一种解决方案，即使用 SETNX 命令（或在 Redis 2.6.12 版本之后使用 SET 命令配合选项）来创建一个锁。以下是一个使用 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
 
# 使用示例
client = redis.StrictRedis(host='localhost', port=6379, db=0)
lock_name = "my_lock"
lock_identifier = acquire_lock(client, lock_name)
if lock_identifier:
    try:
        # 在这里执行需要互斥访问的代码
        print("Lock acquired")
    finally:
        if release_lock(client, 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。

在使用示例中，我们尝试获取一个锁，如果成功，我们执行需要互斥访问的代码，并在最后确保释放了锁。如果未能获得锁，我们则不执行任何操作。