多个redis客户端访问同一个redis服务端,控制并发。
github:https://pypi.org/project/python-redis-lock/
在使用这个库之前,需要安装如下:
pip install python-redis-lock
使用锁的示例:
1
2
3
4
5
6
|
lock = redis_lock.Lock(conn, "name-of-the-lock" )
if lock.acquire(blocking = False ):
print ( "Got the lock." )
lock.release()
else :
print ( "Someone else has the lock." )
|
上面是单独设置锁的方式,还可以单独设置所有redis的操作加入锁。
# On application start/restart
import redis_lock
redis_lock.reset_all(redis_client)
快速使用
1. 首先导入redis_lock
import redis_lock
2.将redis连接的客户端传入lock中,并设置lock的名称
1
2
3
4
|
# 设置redis连接
# 设置redis锁
lock = redis_lock.Lock(conn, "redis-lock" )
|
3.业务操作
1
2
3
4
5
6
7
|
if lock.acquire(blocking = False ):
print ( "Got the lock." )
# 获取lock,执行业务处理
# 释放lock
self .lock.release()
else :
print ( "Someone else has the lock." )
|
简单方式:
1
2
3
|
with redis_lock.Lock(conn, "name-of-the-lock" ):
print ( "Got the lock. Doing some work ..." )
time.sleep( 5 )
|
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://www.cnblogs.com/-wenli/p/13740433.html