redis 连接池

import redis
db = 0
#连接redis,password不简写(否则或报错)，db若不写，则默认操作db0
conn_redis = redis.Redis(host='127.0.0.1', port=6379, password='123456', db=db)
#给redis添加值，传值方式是key-value，key不可重复，value的形式尽量是string，也可以传list、字典，redis内存放的是字节res = conn_redis.set('name', 'testredis')
#print(res)    #返回值是布尔类型，set成功，则返回true
conn_redis.set('days', '[10,4,5,12,44]')

#set key值到redis内，且可以设置过期时间，10s
result = conn_redis.setex('session', 'abcder1233@sdfrr', 10)   #单位是s
print(result)   #返回值是布尔类型，set成功，则返回true
#批量插入redis，可以写入多个key-valye
conn_redis.mset(a='xiaohei', b='xiaobai', c='xiaohuang') 
#设置key时，可以设置文件夹，user文件夹，key:test,value:haha
conn_redis.set('user:test','haha')

def getcoon():
      pool = redis.ConnectionPool(host='192.168.1.112', port=6379, password='123456', db=0)
      coon = redis.Redis(connection_pool=pool)
      coon.set('key', 'value')
      res = coon.get('key')
      return res

class OPRedis(object):

    def __init__(self):
        if not hasattr(OPRedis, 'pool'):
            OPRedis.getRedisCoon()  #创建redis连接
        self.coon = redis.Redis(connection_pool=OPRedis.pool)

    @staticmethod
    def getRedisCoon():
        OPRedis.pool = redis.ConnectionPool(host=redisInfo['host'], password=redisInfo['password'], port=redisInfo['port'], db=redisInfo['db'])

    """
    string类型 {'key':'value'} redis操作
    """

    def setredis(self, key, value, time=None):
        #非空即真非0即真
        if time:
            res = self.coon.setex(key, value, time)
        else:
            res = self.coon.set(key, value)
        return res

    def getRedis(self, key):
        res = self.coon.get(key).decode()
        return res

    def delRedis(self, key):
        res = self.coon.delete(key)
        return res

    """
    hash类型，{'name':{'key':'value'}} redis操作
    """
    def setHashRedis(self, name, key, value):
        res = self.coon.hset(name, key, value)
        return res


    def getHashRedis(self, name, key=None):
        # 判断key是否我为空，不为空，获取指定name内的某个key的value; 为空则获取name对应的所有value
        if key:
            res = self.coon.hget(name, key)
        else:
            res = self.coon.hgetall(name)
        return res


    def delHashRedis(self, name, key=None):
        if key:
            res = self.coon.hdel(name, key)
        else:
            res = self.coon.delete(name)
        return res

redisInfo = {
    "host": '192.168.1.112',
    "password": '123456',
    "port": 6379,
    "db": 0
}

if __name__ == '__main__':
    opr = OPRedis()
    res = opr.setredis('two', '哈哈')
    res = opr.getRedis('two')
    print(res)