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/client_manager.py | 13 ++++---------
1 files changed, 4 insertions(+), 9 deletions(-)
diff --git a/ths/client_manager.py b/ths/client_manager.py
index b74d874..c45c64f 100644
--- a/ths/client_manager.py
+++ b/ths/client_manager.py
@@ -12,8 +12,7 @@
def getValidL2Clients():
- redis = __redisManager.getRedis()
- keys = RedisUtils.keys(redis, "client-active-*")
+ keys = RedisUtils.keys(__redisManager.getRedis(), "client-active-*")
client_ids = []
for k in keys:
_id = k.split("client-active-")[1]
@@ -27,8 +26,7 @@
# 鑾峰彇瀹㈡埛绔疘P
def getActiveClientIP(client_id):
- redis = __redisManager.getRedis()
- val = RedisUtils.get(redis, "client-active-{}".format(client_id))
+ val = RedisUtils.get(__redisManager.getRedis(), "client-active-{}".format(client_id))
if val is None:
return None
val = json.loads(val)
@@ -38,17 +36,14 @@
def saveClientActive(client_id, host, thsDead):
if client_id <= 0:
return
-
- redis = __redisManager.getRedis()
- RedisUtils.setex(redis,"client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
+ RedisUtils.setex( __redisManager.getRedis(),"client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
if ths_util:
ths_util.set_ths_dead_state(client_id, thsDead)
# 鑾峰彇瀹㈡埛绔悓鑺遍『鐘舵��
def getTHSState(client_id):
- redis = __redisManager.getRedis()
- val = RedisUtils.get(redis, "client-active-{}".format(client_id))
+ val = RedisUtils.get(__redisManager.getRedis(), "client-active-{}".format(client_id))
if val is None:
return None
val = json.loads(val)
--
Gitblit v1.8.0