Redis分布式锁的python实现
Posted chengege
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Redis分布式锁的python实现相关的知识,希望对你有一定的参考价值。
#!/usr/bin/env python # coding=utf-8 import time import redis class RedisLock(object): def __init__(self, key): self.rdcon = redis.Redis(host=‘‘, port=6379, password="", db=1) self._lock = 0 self.lock_key = "%s_dynamic_test" % key @staticmethod def get_lock(cls, timeout=10): while cls._lock != 1: timestamp = time.time() + timeout + 1 cls._lock = cls.rdcon.setnx(cls.lock_key, timestamp) # 注意下方括号的范围 if cls._lock == 1 or (time.time() > cls.rdcon.get(cls.lock_key) and time.time() > cls.rdcon.getset(cls.lock_key, timestamp)): print "get lock" break else: time.sleep(0.3) @staticmethod def release(cls): if time.time() < cls.rdcon.get(cls.lock_key): print "release lock" cls.rdcon.delete(cls.lock_key) def deco(cls): def _deco(func): def __deco(*args, **kwargs): print "before %s called [%s]."%(func.__name__, cls) cls.get_lock(cls) try: return func(*args, **kwargs) finally: cls.release(cls) return __deco return _deco @deco(RedisLock("112233")) def myfunc(): print "myfunc() called." time.sleep(20) if __name__ == "__main__": myfunc()
案例二:
import redis import time, datetime def acquire_lock(conn, lockname, identifier, expire=10): if conn.setnx(lockname, identifier): conn.expire(lockname, expire) return identifier elif not conn.ttl(lockname): conn.expire(lockname, expire) return False def release_lock(conn, lockname, identifier): pipe = conn.pipeline(True) while True: try: pipe.watch(lockname) if pipe.get(lockname) == identifier: pipe.multi() pipe.delete(lockname) pipe.execute() return True pipe.unwatch() break except redis.exceptions.WatchError: pass # we lost the lock return False conn = redis.Redis(host=‘localhost‘, port=6379, db=0) # 1 identifier # 2 False # 11 True # 22 False # 33 barx2 # 44 True ret = acquire_lock(conn, "lockname", "identifier", 3) print "1", ret ret = acquire_lock(conn, "lockname", "identifier", 3) print "2", ret ret = release_lock(conn, "lockname", "identifier") print "11", ret ret = release_lock(conn, "lockname", "identifier") print "22", ret ret = acquire_lock(conn, "footest", "bartest", 10) print "33", ret
以上是关于Redis分布式锁的python实现的主要内容,如果未能解决你的问题,请参考以下文章