| | |
|---|
| | | |
|---|
| | | |
|---|
| | | from trade.huaxin import trade_server |
|---|
| | | import ocr |
|---|
| | | from third_data import data_server |
|---|
| | | |
|---|
| | | from server import * |
|---|
| | |
|---|
| | | tcpserver.serve_forever() # 永久循环执行,可以接受多个客户端连接 |
|---|
| | | |
|---|
| | | |
|---|
| | | # 识别服务 |
|---|
| | | def createOCRServer(): |
|---|
| | | print("create OCRServer") |
|---|
| | | tcpserver = ocr.ocr_server.run("", 9002) |
|---|
| | | tcpserver.serve_forever() |
|---|
| | | |
|---|
| | | |
|---|
| | | def createDataServer(): |
|---|
| | | print("create DataServer") |
|---|
| | | tcpserver = data_server.run("", 9004) |
|---|
| | |
|---|
| | | #tradeServerProcess = multiprocessing.Process(target=createTradeServer) |
|---|
| | | serverProcess = multiprocessing.Process(target=createServer, args=(None, None,)) |
|---|
| | | jueJinTradeProcess = multiprocessing.Process(target=trade_juejin.run) |
|---|
| | | ocrServerProcess = multiprocessing.Process(target=createOCRServer) |
|---|
| | | |
|---|
| | | #tradeServerProcess.start() |
|---|
| | | serverProcess.start() |
|---|
| | | ocrServerProcess.start() |
|---|
| | | jueJinTradeProcess.start() |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | createTradeServer() |
|---|
