bug修改

admin

2023-08-22 c057275036cd3e28f2de146e5993c6f97016ffdb

 middle_api_server.py

@@ -6,6 +6,7 @@
import threading
import time

import socket_manager
import trade_manager
from db import mysql_data, redis_manager
from db.redis_manager import RedisUtils
@@ -238,6 +239,9 @@
                                {"code": 0, "data": times, "msg": ""})
                        finally:
                            redis.close()
                    elif type_ == "trade_server_channels":
                        channels = socket_manager.ClientSocketManager.list_client()
                        return_str = json.dumps({"code": 0, "data": channels})

                break
                # sk.close()
@@ -395,6 +399,7 @@
def run():
    print("create middle_api_server")
    laddr = "0.0.0.0", 10009
    print("middle_api_server is at: http://%s:%d/" % (laddr))
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle)  # 注意：参数是MyBaseRequestHandle
    tcpserver.serve_forever()