| | |
|---|
| | | """ |
|---|
| | | |
|---|
| | | import multiprocessing |
|---|
| | | import threading |
|---|
| | | |
|---|
| | | from trade.huaxin import trade_server |
|---|
| | | from third_data import data_server |
|---|
| | | import log_module |
|---|
| | | from log_module.log import logger_l2_process_time |
|---|
| | | |
|---|
| | | from server import * |
|---|
| | | import l2.l2_data_util |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 交易服务 |
|---|
| | | from third_data import data_server |
|---|
| | | from trade.huaxin import trade_server |
|---|
| | | |
|---|
| | | |
|---|
| | | def createTradeServer(): |
|---|
| | | print("create TradeServer") |
|---|
| | | # 初始化参数 |
|---|
| | |
|---|
| | | |
|---|
| | | t1 = threading.Thread(target=createDataServer, daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | trade_server.run() |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | log_module.log.logger_l2_process_time.info("测试123") |
|---|
| | | logger_l2_process_time.info("测试123") |
|---|
| | | serverProcess = multiprocessing.Process(target=createServer) |
|---|
| | | serverProcess.start() |
|---|
| | | # 将tradeServer作为主进程 |
|---|
