From b84f90b1370ce5703a96a53f9d1834a5d0fc792b Mon Sep 17 00:00:00 2001
From: chakcy <947105045@qq.com>
Date: Sun, 23 Aug 2026 04:39:02 +0800
Subject: [PATCH] =?UTF-8?q?modify:=20=E6=80=A7=E8=83=BD=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/chongming_worker/routes_publisher.py | 6 +++---
 src/chongming_worker/runtime.py          | 5 ++---
 2 files changed, 5 insertions(+), 6 deletions(-)

diff --git a/src/chongming_worker/routes_publisher.py b/src/chongming_worker/routes_publisher.py
index 98e3100..fe74c2e 100644
--- a/src/chongming_worker/routes_publisher.py
+++ b/src/chongming_worker/routes_publisher.py
@@ -7,7 +7,7 @@
 网关 RouteRegistry 订阅同名空间并动态挂载 HTTP 路由。
 描述符 schema_version=1，字段与网关 RouteConfig 完全对位（TOML 兼容 dict）。
 """
-import json
+import orjson
 import logging
 from typing import Any, Dict, List, Optional
 
@@ -55,7 +55,7 @@ class RoutePublisher:
             descriptor["schema_version"] = SCHEMA_VERSION
             descriptor["type"] = self._worker_type
             key = f"{ROUTES_PREFIX}/{self._worker_type}/{route_id(subject, method)}"
-            self._session.put(key, json.dumps(descriptor, ensure_ascii=False).encode("utf-8"))
+            self._session.put(key, orjson.dumps(descriptor))
             self._keys.append(key)
             logger.info(
                 "已发布路由: %s %s (subject=%s)",
@@ -66,7 +66,7 @@ class RoutePublisher:
             meta_key = f"{ROUTES_PREFIX}/{self._worker_type}/{META_KEY}"
             meta = {"schema_version": SCHEMA_VERSION, "mqtt_topics": mqtt_topics}
             self._session.put(
-                meta_key, json.dumps(meta, ensure_ascii=False).encode("utf-8")
+                meta_key, orjson.dumps(meta)
             )
             self._keys.append(meta_key)
             logger.info("已发布插件元信息: %d 个自定义 MQTT 主题", len(mqtt_topics))
diff --git a/src/chongming_worker/runtime.py b/src/chongming_worker/runtime.py
index 975d8c7..153e370 100644
--- a/src/chongming_worker/runtime.py
+++ b/src/chongming_worker/runtime.py
@@ -6,7 +6,6 @@ Worker 运行时 — 通用的生命周期管理
 import os
 import asyncio
 import inspect
-import json
 import logging
 import orjson
 from typing import Any, Dict, List, Optional
@@ -143,7 +142,7 @@ async def create_worker(
                     matched = methods[0]  # 降级到第一个
                 if not matched:
                     query.reply_err(
-                        payload=json.dumps({"error": f"No method for {subject}"}).encode("utf-8")
+                        payload=orjson.dumps({"error": f"No method for {subject}"})
                     )
                     return
 
@@ -183,7 +182,7 @@ async def create_worker(
                     # 框架错误走 reply_err 通道：网关零解析判定失败（映射 503）；
                     # 载荷保持原错误信封结构，旧网关仍按普通回复透传（兼容）
                     query.reply_err(
-                        payload=json.dumps(error_response).encode("utf-8")
+                        payload=orjson.dumps(error_response)
                     )
                 logger.error("[Worker] %s 异常 %s: %s", worker_id, subject, e)