cxh/sweeper_video
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
cxh 2025-09-09 16:29:59 +08:00
parent cd20dce210
commit 509684090a
1 changed files with 15 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/mqtt_client_wrapper.cpp
View File

@ -9,9 +9,6 @@ extern std::atomic<bool> g_running;
std::string g_dispatch_id; std::string g_dispatch_id;
std::mutex g_dispatch_id_mutex; std::mutex g_dispatch_id_mutex;
auto last_heartbeat = std::chrono::steady_clock::now();
auto heartbeat_interval = std::chrono::milliseconds(static_cast<int>(g_app_config.mqtt.keep_alive * 0.9));
static void send_heartbeat() static void send_heartbeat()
{ {
if (!mqtt_client || !mqtt_client->isConnected()) if (!mqtt_client || !mqtt_client->isConnected())
@ -29,14 +26,9 @@ static void send_heartbeat()
} }
nlohmann::json hb_data; nlohmann::json hb_data;
hb_data["time"] = Logger::get_current_time_utc8(); hb_data["time"] = Logger::get_current_time_utc8(); // UTC+8
if (!g_dispatch_id.empty())
{ hb_data["dispatchId"] = g_dispatch_id;
std::lock_guard<std::mutex> lock(g_dispatch_id_mutex);
if (!g_dispatch_id.empty())
hb_data["dispatchId"] = g_dispatch_id;
}
hb_data["status"] = status; hb_data["status"] = status;
nlohmann::json msg; nlohmann::json msg;
@ -209,6 +201,7 @@ static void on_mqtt_message_received(const std::string &topic, const std::string
void mqtt_client_thread_func() void mqtt_client_thread_func()
{ {
const auto &cfg = g_app_config.mqtt; const auto &cfg = g_app_config.mqtt;
auto heartbeat_interval = std::chrono::milliseconds(static_cast<int>(cfg.mqtt.keep_alive * 0.9));
while (g_running) while (g_running)
{ {
@ -222,20 +215,18 @@ void mqtt_client_thread_func()
while (!mqtt_restart_required && g_running) while (!mqtt_restart_required && g_running)
{ {
auto now = std::chrono::steady_clock::now(); auto now = std::chrono::steady_clock::now();
if (now - last_heartbeat >= heartbeat_interval)
{
try
{
send_heartbeat();
}
catch (const std::exception &e)
{
LOG_ERROR(std::string("[MQTT] Heartbeat error: ") + e.what());
}
last_heartbeat = now;
}
std::this_thread::sleep_for(std::chrono::milliseconds(50)); // 轻量轮询 try
{
send_heartbeat();
}
catch (const std::exception &e)
{
LOG_ERROR(std::string("[MQTT] Heartbeat error: ") + e.what());
}
last_heartbeat = now;
std::this_thread::sleep_for(heartbeat_interval); // 固定周期
} }
// 需要重启或退出 // 需要重启或退出