Administrator
2023-08-04 b79f40afbe849f56f7c2db94e9bcebf3f5e92ec6
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
"""
redis管理器
"""
import redis
 
import constant
from log_module.log import logger_redis_debug
 
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=50)
            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, auto_free=True):
        try:
            logger_redis_debug.info("get:{}",key)
            return redis_.get(key)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def scard(cls, redis_, key, auto_free=True):
        try:
            return redis_.scard(key)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def delete(cls, redis_, key, auto_free=True):
        try:
            logger_redis_debug.info("delete:{}", key)
            return redis_.delete(key)
 
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def keys(cls, redis_, key, auto_free=True):
        try:
            logger_redis_debug.info("keys:{}", key)
            return redis_.keys(key)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def set(cls, redis_, key, val, auto_free=True):
        try:
            logger_redis_debug.info("set:{}", key)
            return redis_.set(key, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def setex(cls, redis_, key, expire, val, auto_free=True):
        logger_redis_debug.info("setex:{}", key)
        try:
            return redis_.setex(key, expire, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def setnx(cls, redis_, key, val, auto_free=True):
        try:
            logger_redis_debug.info("setnx:{}", key)
            return redis_.setnx(key, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def expire(cls, redis_, key, expire, auto_free=True):
        try:
            logger_redis_debug.info("expire:{}", key)
            return redis_.expire(key, expire)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def sadd(cls, redis_, key, val, auto_free=True):
        try:
            logger_redis_debug.info("sadd:{}", key)
            return redis_.sadd(key, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def sismember(cls, redis_, key, val, auto_free=True):
        try:
            logger_redis_debug.info("sismember:{}", key)
            return redis_.sismember(key, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def smembers(cls, redis_, key, auto_free=True):
        try:
            logger_redis_debug.info("smembers:{}", key)
            return redis_.smembers(key)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def srem(cls, redis_, key, val, auto_free=True):
        try:
            logger_redis_debug.info("srem:{}", key)
            return redis_.srem(key, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def incrby(cls, redis_, key, num, auto_free=True):
        try:
            logger_redis_debug.info("incrby:{}", key)
            return redis_.incrby(key, num)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def lpush(cls, redis_, key, val, auto_free=True):
        try:
            logger_redis_debug.info("lpush:{}", key)
            return redis_.lpush(key, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def lpop(cls, redis_, key, auto_free=True):
        try:
            logger_redis_debug.info("lpop:{}", key)
            return redis_.lpop(key)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
    @classmethod
    def rpush(cls, redis_, key, val, auto_free=True):
        try:
            logger_redis_debug.info("rpush:{}", key)
            return redis_.rpush(key, val)
        finally:
            if auto_free:
                redis_.connection_pool.disconnect()
 
 
 
 
 
if __name__ == "__main__":
    pass