import json
|
import socket
|
|
import requests
|
|
from code_attribute.code_price_manager import CodesLimitRateManager
|
from utils import tool, socket_util
|
from utils.block_web_api import THSBlocksApi
|
from utils.history_k_data_util import HistoryKDatasUtils
|
|
if __name__ == "__main__":
|
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 生成socket，连接server
|
# client.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, True)
|
# client.ioctl(socket.SIO_KEEPALIVE_VALS, (1, 60 * 1000, 30 * 1000))
|
client.connect(("192.168.3.122", 10009))
|
client.sendall(socket_util.load_header(
|
json.dumps({"type": "push_msg", "data": {"type": "update_position"}}).encode("utf-8")))
|
