交易优化

admin

2023-08-04 ca310f014336d93eba73ed5010c1c5645424a1e0

 client_network.py

@@ -2,6 +2,7 @@
import socket

import constant
import socket_util


class SendResponseSkManager:
@@ -10,17 +11,22 @@
    @classmethod
    def get_send_response_sk(cls, type):
        if type not in cls.__send_response_sk_dict:
            client = cls.create_send_response_sk(type)
            client = cls.create_send_response_sk()
            cls.__send_response_sk_dict[type] = client
        return cls.__send_response_sk_dict[type]

    @classmethod
    def del_send_response_sk(cls, type):
        if type in cls.__send_response_sk_dict:
            cls.__send_response_sk_dict.pop(type)
    def del_send_response_sk(cls, type_):
        if type_ in cls.__send_response_sk_dict:
            sk = cls.__send_response_sk_dict[type_]
            cls.__send_response_sk_dict.pop(type_)
            try:
                sk.close()
            except:
                pass

    @classmethod
    def create_send_response_sk(cls, type):
    def create_send_response_sk(cls):
        addr, port = constant.SERVER_IP, constant.SERVER_PORT
        client = socket.socket()  # 生成socket，连接server
        client.connect((addr, port))
@@ -35,10 +41,9 @@
        # 添加内容长度头
        msg = cls.format_response(msg)
        sk.send(msg)
        result = sk.recv(1024)
        result, header_str = socket_util.recv_data(sk)
        # print("响应", result)
        if result:
            result = result.decode("utf-8")
            result_json = json.loads(result)
            if result_json.get("code") == 0:
                return True