From 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 03 八月 2023 18:25:33 +0800
Subject: [PATCH] redis连接池归还
---
ths/ths_util.py | 18 ++++++++++--------
1 files changed, 10 insertions(+), 8 deletions(-)
diff --git a/ths/ths_util.py b/ths/ths_util.py
index bc2c600..7013f12 100644
--- a/ths/ths_util.py
+++ b/ths/ths_util.py
@@ -178,19 +178,21 @@
def set_ths_dead_state(client_id, dead):
redis = __redisManager.getRedis()
- key = "ths_state_dead_count-{}".format(client_id)
- if not dead:
- RedisUtils.setex(redis, key, tool.get_expire(), 0)
- else:
- RedisUtils.incrby(redis, key, 1)
- RedisUtils.expire(redis, key, tool.get_expire())
+ try:
+ key = "ths_state_dead_count-{}".format(client_id)
+ if not dead:
+ RedisUtils.setex(redis, key, tool.get_expire(), 0, auto_free=False)
+ else:
+ RedisUtils.incrby(redis, key, 1, auto_free=False)
+ RedisUtils.expire(redis, key, tool.get_expire(), auto_free=False)
+ finally:
+ redis.connection_pool.disconnect()
# 鍚岃姳椤烘槸鍚﹀崱姝�
def is_ths_dead(client_id):
key = "ths_state_dead_count-{}".format(client_id)
- redis = __redisManager.getRedis()
- val = RedisUtils.get(redis, key)
+ val = RedisUtils.get( __redisManager.getRedis(), key)
if val is not None and int(val) >= 5:
return True
else:
--
Gitblit v1.8.0