import threading
|
|
from log_module.log import logger_system
|
from servers import data_server
|
from utils import tool, socket_util
|
|
DATA_SERVER_PORT = 9004
|
|
|
def run_data_server():
|
logger_system.info("create DataServer")
|
logger_system.info(f"createDataServer 线程ID:{tool.get_thread_id()}")
|
tcpserver = data_server.run("", DATA_SERVER_PORT)
|
tcpserver.serve_forever()
|
try:
|
tcpserver.serve_forever()
|
except Exception as e:
|
logger_system.exception(e)
|
logger_system.error(f"端口服务器：{DATA_SERVER_PORT} 启动失败")
|
|
|
def repaire_data_server():
|
if not socket_util.is_port_bind(DATA_SERVER_PORT):
|
threading.Thread(target=run_data_server, daemon=True).start()
|
