优化H撤/融入网页看盘页面/开盘啦数据应用

Administrator

2023-04-26 d1bf04791ad095b17660a1f383b7a12f0a59b1d1

 gui.py

@@ -22,6 +22,7 @@
from trade import l2_trade_util
from trade.l2_trade_factor import L2TradeFactorUtil
from ocr import ocr_server
from third_data import  data_server

from server import *
import l2.l2_data_util
@@ -60,6 +61,13 @@
    t1.setDaemon(True)
    t1.start()

    t1 = threading.Thread(target=createDataServer)
    # 后台运行
    t1.setDaemon(True)
    t1.start()



    laddr = "", 9001
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_juejin=pipe_juejin)  # 注意：参数是MyBaseRequestHandle
    # tcpserver.handle_request()  # 只接受一个客户端连接
@@ -71,6 +79,10 @@
    tcpserver = ocr_server.run("", 9002)
    tcpserver.serve_forever()

def createDataServer():
    print("create OCRServer")
    tcpserver = data_server.run("", 9004)
    tcpserver.serve_forever()

def startJueJin(pipe):
    juejin.JueJinManager(pipe).start()
@@ -85,6 +97,7 @@
        self.serverProcess = multiprocessing.Process(target=createServer, args=(p1, gs_server_pipe,))
        self.jueJinProcess = multiprocessing.Process(target=startJueJin, args=(p2,))
        self.ocrServerProcess = multiprocessing.Process(target=createOCRServer)


        self.p1 = p1
        self.p2 = p2
@@ -120,6 +133,7 @@
        self.jueJinProcess.start()
        self.serverProcess.start()
        self.ocrServerProcess.start()

        L2CodeOperate.get_instance()
        # 客户端队列操作
        process = multiprocessing.Process(target=L2CodeOperate.run())