first commit

src/main.cpp

@@ -52,15 +52,18 @@ int main()
     // 先在主线程初始化 GStreamer
     RTSPManager::init();
 
+    std::thread rtsp_thread = nullptr;
+    std::thread mqtt_thread = nullptr;
+
     std::thread rtsp_thread([&]()
                             {
         RTSPManager::start(g_app_config.cameras);
         rtsp_thread_exited.store(true, std::memory_order_relaxed); });
 
-    // std::thread mqtt_thread([&]()
-    //                         {
-    //     mqtt_client_thread_func();
-    //     mqtt_thread_exited.store(true, std::memory_order_relaxed); });
+    std::thread mqtt_thread([&]()
+                            {
+        mqtt_client_thread_func();
+        mqtt_thread_exited.store(true, std::memory_order_relaxed); });
 
     // 等待退出信号
     while (g_running.load(std::memory_order_relaxed))