
本文详解如何正确解析多行 json 格式的日志文件(如服务器逐行写入的传感器数据),避免双重序列化导致的嵌套字符串问题,并通过 tkinter 实现毫秒级刷新的实时数据显示。
本文详解如何正确解析多行 json 格式的日志文件(如服务器逐行写入的传感器数据),避免双重序列化导致的嵌套字符串问题,并通过 tkinter 实现毫秒级刷新的实时数据显示。
在构建客户端-服务器硬件监控系统时,一个常见但易被忽视的问题是:JSON 数据在传输与持久化过程中被重复序列化(json.dumps()),导致最终写入文件的内容并非标准 JSON 对象,而是被转义的 JSON 字符串(例如 ""{\"Name\":...}"")。这使得后续用 json.load() 或 json.loads() 直接解析失败,tkinter GUI 无法提取 CPU Load、Temperature 等关键字段。
? 问题根源:双重序列化陷阱
观察你的 Export.json 示例:
""{\"Name\": \"CPU Total\", \"Sensor Type\": \"Load\", \"Value\": 39.75}""
这并非合法 JSON 对象,而是一个 被双引号包裹、且内部所有引号均被反斜杠转义的字符串。其本质是:
- 服务端先 json.dumps(dict) → 得到字符串 s1;
- 客户端从 socket 接收后,又对 s1 再次 json.dumps(s1) → 得到 s2(即嵌套转义字符串);
- 写入文件时存的是 s2,而非原始字典。
因此,load_dict() 中直接 json.loads(last_line) 会抛出 JSONDecodeError —— 因为 last_line 是字符串,不是 JSON。
✅ 正确做法:严格区分序列化与反序列化
1. 服务端:只序列化一次,直接发送原始 JSON 字符串
# ✅ 正确:生成 JSON 字符串后,直接放入队列(不二次处理)
load_dict = {
"Name": self.sens_name,
"Sensor Type": self.sens_type,
"Value": self.cpu_temps, # 注意:原代码此处误用了 self.cpu_temps,应为 self.cpu_load
"Timestamp": time.strftime("%H:%M:%S")
}
json_str = json.dumps(load_dict) # ← 唯一一次 dumps
queue_2.put(json_str) # ← 直接存字符串
2. 客户端发送线程:接收后反序列化,再写入文件
# ✅ 正确:从 socket 接收的是 JSON 字符串,需 loads() 还原为 dict
class ReceiveData(threading.Thread):
def run(self):
while True:
data, addr = self.sock.recvfrom(4096)
json_str = data.decode("utf-8")
try:
# 将接收到的 JSON 字符串还原为 Python 字典
parsed_dict = json.loads(json_str)
queue_2.put(parsed_dict) # ← 存 dict,非字符串!
except json.JSONDecodeError as e:
print(f"Invalid JSON received: {json_str}, error: {e}")
3. 导出线程:以标准 JSON 格式追加写入(每行一个对象)
class Export(threading.Thread):
def run(self):
while True:
try:
data_dict = queue_2.get() # ← 此处是 dict 类型
with open("Export.json", 'a', encoding='utf-8') as f:
json.dump(data_dict, f, indent=2, ensure_ascii=False)
f.write("
") # 每条记录独占一行(JSON Lines 格式)
except Exception as e:
print(f"Export error: {e}")
4. GUI 更新逻辑:安全读取最后一行并解析
def load_dict(self):
try:
with open('Export.json', 'r', encoding='utf-8') as f:
lines = [line.strip() for line in f if line.strip()]
if not lines:
return {"Name": "N/A", "Value": 0.0}
# 取最后一行(最新数据),并确保是有效 JSON
last_line = lines[-1]
return json.loads(last_line) # ← 此处 loads() 才是正确的
except FileNotFoundError:
return {"Name": "File Missing", "Value": 0.0}
except json.JSONDecodeError as e:
print(f"Corrupted line in Export.json: {last_line}, error: {e}")
return {"Name": "Parse Error", "Value": 0.0}
def update_text(self):
data = self.load_dict()
# 安全提取字段,避免 KeyError
name = data.get("Name", "Unknown")
value = data.get("Value", "N/A")
sensor_type = data.get("Sensor Type", "N/A")
display_text = f"{sensor_type} - {name}: {value}"
self.txt_cpu.delete("1.0", tk.END)
self.txt_cpu.insert("1.0", display_text)
# ✅ 使用 after 而非 after() —— 后者会立即执行!
self.txt_cpu.after(1000, self.update_text) # ← 修正:去掉括号
⚠️ 关键注意事项
- 编码统一:所有文件操作务必指定 encoding='utf-8',避免 Windows 下中文乱码。
- 异常防御:json.loads() 必须包裹在 try/except 中,因文件可能为空、损坏或正在被写入。
- 线程安全:tkinter 组件只能在主线程更新。当前 ClientGUI 继承 threading.Thread 并在子线程中调用 self.txt_cpu.insert() 是危险的!正确做法是:GUI 在主线程运行,用 queue.Queue 传递数据,或使用 root.after() 触发安全更新。
- 性能优化:若数据高频写入,避免每次 update_text() 都重读整个文件 —— 改为监听文件变更或维护内存缓存。
✅ 最终效果
修复后,Export.json 将呈现标准 JSON Lines 格式:
{"Name": "CPU Total", "Sensor Type": "Load", "Value": 39.75, "Timestamp": "14:22:05"}
{"Name": "CPU Package", "Sensor Type": "Temperature", "Value": 52.3, "Timestamp": "14:22:06"}
GUI 即可稳定提取 data["Value"] 并实时刷新显示,彻底解决“无法读取 JSON”的核心问题。










