redis连接池归还

Administrator

2023-08-04 1474ce3b3a4c3a17d537ab60413def471c226e6e

redis连接池归还

 db/redis_manager.py

@@ -16,10 +16,15 @@

    def __init__(self, db=config["db"]):
        self.pool = pool_caches[db]
        self.db = db

    def getRedis(self):
        return redis.Redis(connection_pool=self.pool)

    def getRedisNoPool(self):
        return redis.Redis(host=config["host"], port=config["port"], password=config["pwd"], db=self.db,
                           decode_responses=True)


class RedisUtils:
    @classmethod

 output/kp_client_msg_manager.py

@@ -29,7 +29,10 @@
    # 读取消息
    def read_msg(self, client_id):
        if client_id in self.__queue_dict:
            return self.__queue_dict[client_id].get(block=False)
            try:
                return self.__queue_dict[client_id].get(block=False)
            except:
                pass
        return None



 trade/huaxin/trade_api_server.py

@@ -350,7 +350,7 @@
                        return_str = json.dumps(
                            {"code": 0, "data": fdata, "msg": ""})
                    elif type_ == 'test_redis':
                        redis = redis_manager.RedisManager(5).getRedis()
                        redis = redis_manager.RedisManager(5).getRedisNoPool()
                        try:
                            _start_time = time.time()
                            times = []
@@ -364,7 +364,8 @@
                            return_str = json.dumps(
                                {"code": 0, "data": times, "msg": ""})
                        finally:
                            RedisUtils.realse(redis)
                            redis.close()
                            # RedisUtils.realse(redis)

                    # 查询委托列表
                    elif type_ == 'test':