| | |
| | | import socket |
| | | |
| | | import constant |
| | | import socket_util |
| | | |
| | | |
| | | class SendResponseSkManager: |
| | |
| | | @classmethod |
| | | def del_send_response_sk(cls, type): |
| | | if type in cls.__send_response_sk_dict: |
| | | try: |
| | | cls.__send_response_sk_dict[type].close() |
| | | except: |
| | | pass |
| | | cls.__send_response_sk_dict.pop(type) |
| | | |
| | | @classmethod |
| | |
| | | # 添加内容长度头 |
| | | 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 |