From 39a3f1dbe0ee66c6cc1b680f7d0b5024d247373b Mon Sep 17 00:00:00 2001
From: chakcy <947105045@qq.com>
Date: Mon, 10 Aug 2026 10:15:47 +0800
Subject: [PATCH] =?UTF-8?q?modify:=20mqtt=20=E6=8F=92=E4=BB=B6=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9E=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 workers/aibox_sophon_adapter/config.toml | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/workers/aibox_sophon_adapter/config.toml b/workers/aibox_sophon_adapter/config.toml
index ff8be5e..5550f10 100644
--- a/workers/aibox_sophon_adapter/config.toml
+++ b/workers/aibox_sophon_adapter/config.toml
@@ -42,7 +42,7 @@ check_interval = 10   # 服务端检查离线设备的间隔（秒）
 [workers.config.mqtt_forward]
 enabled = true
 uri = "mqtt://admin:Mixc%402021@dg.datagoo.cn:48081"   # %40 是 @ 的 URL 编码
-topic = "/board_ping"                                    # 转发目标主题
+topic = "/internal/aibox_sophon_adapter/board_ping"                                    # 转发目标主题
 
 # ====== 外部 MQTT 订阅（本插件直接订阅外部 Broker，不走网关 Bridge） ======
 # enabled: 是否启用外部订阅
@@ -77,9 +77,17 @@ uri = "mqtt://admin:Mixc%402021@dg.datagoo.cn:48081"
 #       timeout=30,
 #   )
 [workers.config.internal_mqtt]
-enabled = false
+enabled = true
 uri = "mqtt://127.0.0.1:1883"
 
+  # 内部请求-响应主题（edge_app_controller 的 alg_media_fetch 命令使用）。
+  # 注意：不要使用 chongming/{插件}/{操作} 保留命名空间——网关 MQTT Bridge
+  # 订阅了 chongming/+/+，会拦截该命名空间下的主题并按 Worker RPC 路由，
+  # 而 edge_app_controller 不是 @rpc_method（Worker 无对应 Queryable），
+  # 会导致 worker_manager 报 "Worker ... 无回复，尝试重试"。请与对端应用（设备）约定一致。
+  request_topic = "/internal/aibox_sophon_adapter/edge_app_controller"
+  response_topic = "/internal/aibox_sophon_adapter/edge_app_controller_reply"
+
 [workers.config.alarm_retention]
 max_records = 100    # 最多保留的告警记录数，设为 0 表示不限制