| | |
|---|
| | | |
|---|
| | | # 主服务 |
|---|
| | | def createServer(pipe): |
|---|
| | | print("create Server") |
|---|
| | | logger_system.info("create Server") |
|---|
| | | laddr = "", 9001 |
|---|
| | | tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_trade=pipe) # 注意：参数是MyBaseRequestHandle |
|---|
| | | try: |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def createDataServer(): |
|---|
| | | print("create DataServer") |
|---|
| | | logger_system.info("create DataServer") |
|---|
| | | tcpserver = data_server.run("", 9004) |
|---|
| | | tcpserver.serve_forever() |
|---|
| | | try: |
|---|
| | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | logger_l2_trade.info("启动程序") |
|---|
| | | logger_system.info("启动程序") |
|---|
| | | log.close_print() |
|---|
| | | # 策略与server间的通信 |
|---|
| | | pss_server, pss_strategy = multiprocessing.Pipe() |
|---|
