From 7f31591b228f4778f3bac8519f26205dd1e35ee3 Mon Sep 17 00:00:00 2001
From: chakcy <947105045@qq.com>
Date: Fri, 7 Aug 2026 18:26:01 +0800
Subject: [PATCH] =?UTF-8?q?modify:=20mqtt=20=E5=90=AF=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/chongming/app/__init__.py            | 3 +++
 src/chongming/app/core/lifespan_setup.py | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/chongming/app/__init__.py b/src/chongming/app/__init__.py
index bf139cd..071d4c0 100644
--- a/src/chongming/app/__init__.py
+++ b/src/chongming/app/__init__.py
@@ -40,6 +40,9 @@ async def lifespan(app: FastAPI):
     # 2. Zenoh
     session = lifespan_setup.setup_zenoh(app)
 
+    # 3. mqtt broker
+    lifespan_setup.setup_mqtt_broker(app, host=config[env]["mqtt"]["host"], port=config[env]["mqtt"]["port"])
+
     # 4. WorkerManager
     manager = lifespan_setup.setup_worker_manager(app, session)
 
diff --git a/src/chongming/app/core/lifespan_setup.py b/src/chongming/app/core/lifespan_setup.py
index 5d66ad0..6ff62d6 100644
--- a/src/chongming/app/core/lifespan_setup.py
+++ b/src/chongming/app/core/lifespan_setup.py
@@ -438,7 +438,7 @@ async def setup_mqtt(app: FastAPI, worker_manager: WorkerManager) -> MQTTBridge
     custom_topics += list(getattr(app.state, "plugin_mqtt_topics", []) or [])
 
     # 1. 启动 Broker 子进程（文件锁已确保只有一个）
-    setup_mqtt_broker(app, host, port)
+    # setup_mqtt_broker(app, host, port)
 
     # 2. 原子锁确保只有一个 worker 启动 MQTT Bridge
     if not _acquire_singleton_lock("mqtt_bridge"):