From c20c3c10635ce78db4a86ce9c0bb1d02e90f525d Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期二, 08 八月 2023 17:40:42 +0800 Subject: [PATCH] 单例+缓存优化 --- code_attribute/big_money_num_manager.py | 39 +++++++++++++++++++++++++++------------ 1 files changed, 27 insertions(+), 12 deletions(-) diff --git a/code_attribute/big_money_num_manager.py b/code_attribute/big_money_num_manager.py index 39c8af4..89af6f9 100644 --- a/code_attribute/big_money_num_manager.py +++ b/code_attribute/big_money_num_manager.py @@ -7,7 +7,8 @@ from db.redis_manager import RedisUtils from utils import tool -__redisManager = redis_manager.RedisManager(0) +__db = 0 +__redisManager = redis_manager.RedisManager(__db) # 鏄惁涓哄ぇ鍗� @@ -18,35 +19,49 @@ return False +__big_money_cache = {} + + def add_num(code, num): - redis = __redisManager.getRedis() - redis.incrby("big_money-{}".format(code), num) + if code not in __big_money_cache: + __big_money_cache[code] = 0 + __big_money_cache[code] += num + RedisUtils.incrby_async(__db, "big_money-{}".format(code), num) # 璁剧疆杩囨湡鏃堕棿 def expire(code): - redis = __redisManager.getRedis() - RedisUtils.expire(redis, "big_money-{}".format(code), tool.get_expire()) + RedisUtils.expire(__redisManager.getRedis(), "big_money-{}".format(code), tool.get_expire()) def reset(code): - redis = __redisManager.getRedis() - redis.set("big_money-{}".format(code), 0) + __big_money_cache[code] = 0 + RedisUtils.set(__redisManager.getRedis(), "big_money-{}".format(code), 0) def get_num(code): - redis = __redisManager.getRedis() - num = redis.get("big_money-{}".format(code)) + num = RedisUtils.get(__redisManager.getRedis(), "big_money-{}".format(code)) if num is None: return 0 return round(int(num) / 1000 / 4) +def get_num_cache(code): + if code in __big_money_cache: + return __big_money_cache[code] + num = get_num(code) + __big_money_cache[code] = num + return num + + def reset_all(): redis = __redisManager.getRedis() - keys = RedisUtils.keys(redis, "big_money-*") - for k in keys: - RedisUtils.setex(redis, k, tool.get_expire(), 0) + try: + keys = RedisUtils.keys(redis, "big_money-*", auto_free=False) + for k in keys: + RedisUtils.setex(redis, k, tool.get_expire(), 0, auto_free=False) + finally: + RedisUtils.realse(redis) if __name__ == "__main__": -- Gitblit v1.8.0