交易通道备用

Administrator

2023-08-25 d6da023297772c9df90c93c50a327786f5ae782d

 huaxin_client/trade_client_server.py

@@ -5,6 +5,8 @@
from huaxin_client.command_manager import TradeCommandManager
from utils import socket_util

SERVER_PORT = 10088


class MyTCPServer(socketserver.TCPServer):
    def __init__(self, server_address, RequestHandlerClass):
@@ -21,7 +23,6 @@
        pass

    def handle(self):
        host = self.client_address[0]
        super().handle()
        sk: socket.socket = self.request
        while True:
@@ -29,9 +30,14 @@
                # data = sk.recv(1024*1024, socket.MSG_WAITALL)
                data, header = socket_util.recv_data(sk)
                if data:
                    # TODO 处理数据
                    data_json = json.loads(data)
                    type_ = data_json['type']
                    TradeCommandManager.process_command(type_, None, data_json)
                    TradeCommandManager.process_command(type_, None, data_json, sk)
            finally:
                pass


def run():
    laddr = "0.0.0.0", SERVER_PORT
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle)  # 注意：参数是MyBaseRequestHandle
    tcpserver.serve_forever()