| | |
|---|
| | | # 心跳信息 |
|---|
| | | from huaxin_client import socket_util |
|---|
| | | from huaxin_client.client_network import SendResponseSkManager |
|---|
| | | from log_module.log import logger_debug |
|---|
| | | from utils import middle_api_protocol |
|---|
| | | |
|---|
| | | MSG_TYPE_HEART = "heart" |
|---|
| | |
|---|
| | | @classmethod |
|---|
| | | def __create_client(cls, client_type, rid): |
|---|
| | | client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 生成socket，连接server |
|---|
| | | client.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, True) |
|---|
| | | # client.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, True) |
|---|
| | | # client.ioctl(socket.SIO_KEEPALIVE_VALS, (1, 60 * 1000, 30 * 1000)) |
|---|
| | | client.connect(cls.ip_port) |
|---|
| | | client.send(SendResponseSkManager.format_response( |
|---|
| | |
|---|
| | | def __heart_beats(cls, _type, client_id, sk): |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | sk.send(SendResponseSkManager.format_response( |
|---|
| | | json.dumps({"type": "heart", "client_id": client_id}).encode('utf-8'))) |
|---|
| | | sk.send(socket_util.load_header(json.dumps({"type": "heart", "client_id": client_id}).encode('utf-8'))) |
|---|
| | | logger_debug.debug("心跳信息发送：{}",client_id) |
|---|
| | | # print("心跳信息发送成功", client_id) |
|---|
| | | except Exception as e: |
|---|
| | | logging.error("错误") |
|---|
| | | print("心跳信息发送失败", _type, client_id) |
|---|
| | | logging.exception(e) |
|---|
| | | if _type == CLIENT_TYPE_TRADE: |
|---|
