redis封装

Administrator

2023-08-02 a3c05bddc4c61d63b804ee541cf6dd01717ba94d

 ths/client_manager.py

@@ -1,6 +1,7 @@
# 客户端管理器
import json

from db.redis_manager import RedisUtils
from user import authority
from db import redis_manager
from utils import import_util
@@ -12,7 +13,7 @@

def getValidL2Clients():
    redis = __redisManager.getRedis()
    keys = redis.keys("client-active-*")
    keys = RedisUtils.keys(redis, "client-active-*")
    client_ids = []
    for k in keys:
        _id = k.split("client-active-")[1]
@@ -27,7 +28,7 @@
# 获取客户端IP
def getActiveClientIP(client_id):
    redis = __redisManager.getRedis()
    val = redis.get("client-active-{}".format(client_id))
    val = RedisUtils.get(redis, "client-active-{}".format(client_id))
    if val is None:
        return None
    val = json.loads(val)
@@ -39,7 +40,7 @@
        return

    redis = __redisManager.getRedis()
    redis.setex("client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
    RedisUtils.setex(redis,"client-active-{}".format(client_id), 10, json.dumps((host, thsDead)))
    if ths_util:
        ths_util.set_ths_dead_state(client_id, thsDead)

@@ -47,7 +48,7 @@
# 获取客户端同花顺状态
def getTHSState(client_id):
    redis = __redisManager.getRedis()
    val = redis.get("client-active-{}".format(client_id))
    val = RedisUtils.get(redis, "client-active-{}".format(client_id))
    if val is None:
        return None
    val = json.loads(val)