Redis 实现分布式锁+执行lua脚本

在Redis中实现分布式锁通常使用SET命令的NX（唯一性）和PX（过期时间）选项。以下是一个使用Lua脚本来安全实现分布式锁的例子：

-- Lua脚本实现分布式锁
local key = KEYS[1]
local value = ARGV[1]
local expire_time = ARGV[2]
 
-- 使用Lua的if语句来实现分布式锁
if redis.call('SET', key, value, 'NX', 'PX', expire_time) then
    -- 锁被成功获取
    return 1
else
    -- 锁已被其他客户端获取
    return 0
end

在实际应用中，可以通过Redis客户端执行这个Lua脚本。以下是使用Python和redis-py客户端的例子：

import redis
 
# 连接到Redis
client = redis.StrictRedis(host='localhost', port=6379, db=0)
 
# Lua脚本
lock_script = """
local key = KEYS[1]
local value = ARGV[1]
local expire_time = ARGV[2]
if redis.call('SET', key, value, 'NX', 'PX', expire_time) then
    return 1
else
    return 0
end
"""
 
# 键和值
key = 'my_lock'
value = 'unique_value'
expire_time = 10000  # 锁的超时时间（以毫秒为单位）
 
# 执行Lua脚本
result = client.eval(lock_script, 1, key, value, expire_time)
 
# 根据返回值处理
if result == 1:
    print("锁被获取")
    try:
        # 这里执行需要互斥的操作
        pass
    finally:
        # 释放锁，可以通过执行DEL命令
        client.delete(key)
else:
    print("无法获取锁")

这个脚本尝试获取一个锁，如果成功，它会执行需要互斥访问的操作，并在完成后释放锁。如果获取锁失败，它会做别的事情或者重试。这个方法确保了在分布式系统中，只有一个客户端可以进入临界区执行代码。