增加外部端口

admin

2024-03-22 b874fdb322d0740838f73e5ed260f800bf43ad1a

 middle_server.py

@@ -97,7 +97,7 @@
                            encoding='utf-8')))
                        continue
                    type_ = data_json["type"]
                    log.request_info("middle_server", f"请求开始：{type_}")
                    __start_time = time.time()
                    try:
                        if data_json["type"] == 'register':
                            client_type = data_json["data"]["client_type"]
@@ -285,14 +285,17 @@
                            push_msg_manager.push_msg(_type, data)
                            result_str = json.dumps({"code": 0, "data": {}})
                            sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8')))
                    except Exception as e:
                        log.logger_tuoguan_request_debug.exception(e)
                    finally:
                        log.request_info("middle_server", f"请求结束")

                        if time.time() - __start_time > 2:
                            log.logger_tuoguan_request_debug.info(f"耗时：{int(time.time() - __start_time)}s  数据：{data_json}")
                else:
                    # 断开连接
                    break
                # sk.close()
            except Exception as e:
                # log.logger_tuoguan_request_debug.exception(e)
                logging.exception(e)
                break

@@ -323,12 +326,12 @@
                pass


def run():
def run(port =  constant.MIDDLE_SERVER_PORT):
    print("create MiddleServer")
    t1 = threading.Thread(target=lambda: clear_invalid_client(), daemon=True)
    t1.start()

    laddr = "0.0.0.0", constant.MIDDLE_SERVER_PORT
    laddr = "0.0.0.0", port
    print("MiddleServer is at: http://%s:%d/" % (laddr))
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle)  # 注意：参数是MyBaseRequestHandle
    tcpserver.serve_forever()