| | |
|---|
| | | # 发送心跳 |
|---|
| | | cls.__heartbeats_thread(type, key, sk) |
|---|
| | | cls.__listen_command_thread(type, key, sk) |
|---|
| | | print("create_and_run_client success", type, key) |
|---|
| | | # print("create_and_run_client success", type, key) |
|---|
| | | return key, sk |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | |
|---|
| | | if result: |
|---|
| | | start_time = time.time() |
|---|
| | | try: |
|---|
| | | print("接收数据", _type, result) |
|---|
| | | # print("接收数据", _type, result) |
|---|
| | | result_json = json.loads(result) |
|---|
| | | if result_json["type"] == MSG_TYPE_HEART: |
|---|
| | | # 返回内容 |
|---|
| | |
|---|
| | | |
|---|
| | | data = result_json["data"] |
|---|
| | | content_type = data["type"] |
|---|
| | | print("接收内容", data) |
|---|
| | | # print("接收内容", data) |
|---|
| | | request_id = result_json.get('request_id') |
|---|
| | | if not socket_util.is_client_params_sign_right(result_json): |
|---|
| | | print("签名错误") |
|---|
| | | # print("签名错误") |
|---|
| | | # 签名出错 |
|---|
| | | SendResponseSkManager.send_error_response(_type, request_id, client_id, |
|---|
| | | {"code": -1, "msg": "签名错误"}) |
|---|
