一次讲清楚Redis的分布式事务和分布式锁

Redis 本身不直接支持分布式事务，但是可以通过 Redis 的 Lua 脚本以及分布式锁机制来实现类似事务的行为。

以下是一个使用 Redis 分布式锁和 Lua 脚本实现分布式事务的简单例子：

-- 使用分布式锁来保证事务的原子性
local lock_key = "my_lock"
local lock_value = "unique_value"
local unlock_script = redis.call("GET", lock_key)
if lock_value == unlock_key then
    -- 执行事务操作
    redis.call("DEL", lock_key)
    return true
else
    return false
end

在实际应用中，你需要先尝试获取锁，然后执行 Lua 脚本：

import redis
 
# 连接 Redis
r = redis.Redis(host='localhost', port=6379, db=0)
 
# 尝试获取锁
lock_key = "my_lock"
lock_value = "unique_value"
result = r.set(lock_key, lock_value, ex=5, nx=True)  # 设置锁，有效期5秒，如果锁不存在才设置
 
if result:
    try:
        # 执行事务
        # ...
 
        # 执行 Lua 脚本
        unlock_script = """
            if redis.call("GET", KEYS[1]) == ARGV[1] then
                return redis.call("DEL", KEYS[1])
            else
                return 0
            end
        """
        res = r.eval(unlock_script, 1, lock_key, lock_value)
 
        # 检查解锁是否成功
        if res == 1:
            print("事务和解锁成功")
        else:
            print("解锁失败")
    except Exception as e:
        print("事务执行异常:", e)
        # 如果发生异常，可以考虑不释放锁，避免其他线程获取到锁后产生数据不一致
    finally:
        # 不在 finally 中释放锁，避免业务异常时解锁失败
        pass
else:
    print("无法获取锁")

请注意，这个例子仅用于演示目的，实际应用中需要考虑更多的边界情况，例如锁的自动续期、异常处理、锁的可重入性等。