"""
|
GUI管理
|
"""
|
|
import multiprocessing
|
|
from log_module.log import logger_l2_process_time
|
|
from server import *
|
|
# 交易服务
|
from third_data import data_server
|
from trade.huaxin import trade_server, trade_api_server
|
|
|
def createTradeServer(pipe):
|
# 初始化参数
|
global_data_loader.init()
|
|
# 数据服务
|
t1 = threading.Thread(target=createDataServer, daemon=True)
|
t1.start()
|
|
# 交易接口服务
|
t1 = threading.Thread(target=trade_api_server.run, args=(pipe,), daemon=True)
|
t1.start()
|
|
# 交易服务
|
trade_server.run()
|
|
|
# 主服务
|
def createServer(pipe):
|
print("create Server")
|
laddr = "", 9001
|
tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_trade=pipe) # 注意：参数是MyBaseRequestHandle
|
# tcpserver.handle_request() # 只接受一个客户端连接
|
tcpserver.serve_forever() # 永久循环执行,可以接受多个客户端连接
|
|
|
def createDataServer():
|
print("create DataServer")
|
tcpserver = data_server.run("", 9004)
|
tcpserver.serve_forever()
|
|
|
if __name__ == '__main__':
|
pipe_server, pipe_trade = multiprocessing.Pipe()
|
logger_l2_process_time.info("测试123")
|
serverProcess = multiprocessing.Process(target=createServer, args=(pipe_server,))
|
serverProcess.start()
|
# 将tradeServer作为主进程
|
createTradeServer(pipe_trade)
|
