"""
|
redis管理器
|
"""
|
import redis
|
|
import constant
|
|
config = constant.REDIS_CONFIG
|
|
pool_cache = {}
|
|
|
class RedisManager:
|
|
def __init__(self, db=config["db"]):
|
pool = None
|
if db in pool_cache:
|
pool = pool_cache[db]
|
else:
|
pool = redis.ConnectionPool(host=config["host"], port=config["port"], password=config["pwd"],
|
db=db, decode_responses=True, max_connections=200)
|
pool_cache[db] = pool
|
self.pool = pool
|
|
def getRedis(self):
|
return redis.Redis(connection_pool=self.pool)
|
|
|
class RedisUtils:
|
|
@classmethod
|
def get(cls, redis_, key):
|
return redis_.get(key)
|
|
@classmethod
|
def delete(cls, redis_, key):
|
return redis_.delete(key)
|
|
@classmethod
|
def keys(cls, redis_, key):
|
return redis_.keys(key)
|
|
@classmethod
|
def set(cls, redis_, key, val):
|
return redis_.set(key, val)
|
|
@classmethod
|
def setex(cls, redis_, key, expire, val):
|
return redis_.setex(key, expire, val)
|
|
@classmethod
|
def expire(cls, redis_, key, expire):
|
return redis_.expire(key, expire)
|
|
@classmethod
|
def sadd(cls, redis_, key, val):
|
return redis_.sadd(key, val)
|
|
@classmethod
|
def smembers(cls, redis_, key):
|
return redis_.smembers(key)
|
|
|
if __name__ == "__main__":
|
pass
|
