Redis缓存数据库进阶——Redis与分布式锁

在分布式系统中，控制对共享资源的并发访问是非常重要的。为了解决这个问题，可以使用分布式锁。Redis是一种流行的内存数据库，可以用作分布式锁的解决方案。

以下是使用Redis实现分布式锁的一个简单示例：

import redis
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.set(lock_name, identifier, ex=lock_timeout, nx=True):
            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_id = acquire_lock(redis_conn, lock_name)
if lock_id:
    try:
        # 在这里执行需要互斥访问的代码
        print("Lock acquired")
    finally:
        # 释放锁
        if release_lock(redis_conn, lock_name, lock_id):
            print("Lock released")
else:
    print("Failed to acquire lock")

这段代码定义了两个函数：acquire_lock和release_lock。acquire_lock尝试获取一个锁，如果在指定时间内成功，它会返回一个唯一的标识符；否则，它会返回False。release_lock尝试释放由特定标识符持有的锁。

在实际应用中，你需要确保锁的超时时间足够短，以防止锁的过度占用，同时也要确保它们不会过早释放，这样其他等待获取锁的线程才有机会获取到锁。此外，uuid.uuid4()生成的标识符可以保证每个锁的唯一性，避免因为标识符相同而释放了错误的锁。