书写一个redis分布式锁
时间: 2023-02-10 10:00:08 浏览: 75
好的,下面是一个示例代码(使用 Python 语言):
```
import redis
import time
# 连接 Redis 数据库
r = redis.Redis(host='localhost', port=6379, db=0)
def acquire_lock(lock_name, acquire_time=10):
"""获取 Redis 分布式锁"""
# 尝试获取锁,设置锁的过期时间为 10 秒
result = r.setnx(lock_name, 1)
if result:
# 获取锁成功,设置锁的过期时间
r.expire(lock_name, acquire_time)
return True
else:
# 获取锁失败,返回 False
return False
def release_lock(lock_name):
"""释放 Redis 分布式锁"""
r.delete(lock_name)
# 尝试获取锁
if acquire_lock('mylock'):
# 模拟处理业务逻辑的时间
time.sleep(5)
# 释放锁
release_lock('mylock')
```
上面的代码实现了一个 Redis 分布式锁的简单示例,你可以在你的代码中使用它来保证同一时间只有一个进程/线程在执行某段关键代码。
在调用 `acquire_lock` 函数时,如果获取锁成功,就会返回 `True`,否则返回 `False`。可以通过传入不同的参数来调整锁的有效时间。获取锁成功后,可以执行关键代码,最后调用 `release_lock` 函数释放锁。
希望这些信息对你有帮助。
阅读全文