import multiprocessing
|
import threading
|
|
import constant
|
import data_server
|
import middle_api_server
|
import middle_cb_api_server
|
import middle_server
|
from log_module import async_log_util
|
|
if __name__ == "__main__":
|
t1 = threading.Thread(target=lambda: middle_api_server.run(), daemon=True)
|
t1.start()
|
t1 = threading.Thread(target=lambda: data_server.run("0.0.0.0", constant.DATA_SERVER_PORT), daemon=True)
|
t1.start()
|
t1 = threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True)
|
t1.start()
|
t1 = threading.Thread(target=lambda: middle_server.run(12880), daemon=True)
|
t1.start()
|
# 可转债API端口为13008
|
t1 = threading.Thread(target=lambda: middle_cb_api_server.run(13008), daemon=True)
|
t1.start()
|
# t1 = threading.Thread(target=lambda: middle_l1_data_server.run(12881), daemon=True)
|
# t1.start()
|
|
middle_server.run()
|
