| | |
| | | addr, port = "127.0.0.1", 9001 |
| | | sk = socket.socket() # 生成socket,连接server |
| | | sk.connect((addr, port)) |
| | | sk.sendall(socket_util.load_header(json.dumps(fdata).encode('utf-8'))) |
| | | print("发送成功") |
| | | result, header = socket_util.recv_data(sk) |
| | | print("接受到数据", result) |
| | | sk.close() |
| | | if result: |
| | | result = json.loads(result) |
| | | if result["code"] != 0: |
| | | raise Exception(result["msg"]) |
| | | try: |
| | | sk.sendall(socket_util.load_header(json.dumps(fdata).encode('utf-8'))) |
| | | print("发送成功") |
| | | result, header = socket_util.recv_data(sk) |
| | | print("接受到数据", result) |
| | | if result: |
| | | result = json.loads(result) |
| | | if result["code"] != 0: |
| | | raise Exception(result["msg"]) |
| | | finally: |
| | | sk.close() |
| | | |