redis连接池归还

Administrator

2023-08-03 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a

 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 @@

# 获取客户端IP
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)