def byte_str(object):
 if isinstance(object, str):
 return object.encode(encoding="utf-8")
 elif isinstance(object, bytes):
 return bytes.decode(object) # 假设所有字节都是 UTF-8
 else:
 print(type(object))

if data.find("You are connecting via") < 0:
 data = byte_str(s.recv(1024))
 print(data)
 monitorServer.clear()
 for i in data.split('\n'):
 if "monitor" in i and "type" in i and "{" in i and "}" in i:
 # 解析监控任务...

 Authentication successful. Access granted.
 You are connecting via: IPv4
 [{"name":"Google","host":"https://www.google.com","interval":600,"type":"https","monitor":0}]
 [{"name":"Baidu","host":"https://www.baidu.com","interval":600,"type":"https","monitor":1}]

jdata = json.loads(i[i.find("{"):i.find("}")+1])

def byte_str(object):
 if isinstance(object, str):
 return object.encode(encoding="utf-8")
 elif isinstance(object, bytes):
 # 尝试多种编码
 for encoding in ['utf-8', 'gbk', 'gb2312', 'latin-1']:
 try:
 return object.decode(encoding)
 except UnicodeDecodeError:
 continue
 # 最后手段:忽略错误
 return object.decode('utf-8', errors='ignore')
 else:
 return str(object)

# 移除错误的条件判断,直接解析当前数据
monitorServer.clear()
server_monitor_count = 0
# 详细解析每一行
for line in data.split('\n'):
 line = line.strip()
 if not line:
 continue
 # 宽松的JSON检查
 if '{' in line and '}' in line:
 try:
 # 提取JSON部分
 start = line.find('{')
 end = line.rfind('}') + 1
 json_str = line[start:end]
 task_data = json.loads(json_str)
 # 验证必需字段
 if all(key in task_data for key in ['name', 'host', 'type']):
 name = task_data['name']
 monitorServer[name] = {
 "type": task_data.get("type"),
 "host": task_data.get("host"),
 "latency": 0
 }
 # 启动监控线程...
 server_monitor_count += 1
 except Exception as e:
 print(f"解析监控任务失败: {e}")

def parse_monitor_task(line):
 """健壮的监控任务解析函数"""
 try:
 # 方法1: 直接解析
 return json.loads(line)
 except json.JSONDecodeError:
 try:
 # 方法2: 提取JSON对象
 start = line.find('{')
 end = line.rfind('}') + 1
 if start >= 0 and end > start:
 return json.loads(line[start:end])
 except:
 pass
 return None

print(f"完整认证响应: {data}")
print(f"解析服务端监控任务...")
print(f"服务端监控任务启动: {server_monitor_count} 个")

# 修复后的监控任务解析部分
monitorServer.clear()
server_monitor_count = 0
print("解析服务端监控任务...")
for line in data.split('\n'):
 line = line.strip()
 if not line:
 continue
 # 宽松的JSON检查
 if '{' in line and '}' in line:
 try:
 # 处理可能的方括号包裹
 if line.startswith('[') and line.endswith(']'):
 line = line[1:-1] # 移除方括号
 # 提取JSON部分
 start = line.find('{')
 end = line.rfind('}') + 1
 json_str = line[start:end]
 task_data = json.loads(json_str)
 # 验证必需字段
 if all(key in task_data for key in ['name', 'host', 'type']):
 name = task_data['name']
 monitorServer[name] = {
 "type": task_data.get("type"),
 "host": task_data.get("host"),
 "latency": 0
 }
 # 启动监控线程
 t = threading.Thread(
 target=_monitor_thread,
 kwargs={
 'name': name,
 'host': task_data.get("host"),
 'interval': task_data.get("interval", 600),
 'type': task_data.get("type")
 }
 )
 t.daemon = True
 t.start()
 server_monitor_count += 1
 print(f"启动监控: {name}")
 except Exception as e:
 print(f"解析监控任务失败: {e}, 行: {line}")
print(f"服务端监控任务启动: {server_monitor_count} 个")