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-08 16:06:50 +08:00
parent 0e8ced1624
commit 15433a861e
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mqtt_client.cpp
View File

@ -37,7 +37,14 @@ void MQTTClient::connect()
.password(config_.password)
.finalize();
client_->connect(connOpts)->wait();
auto tok = client_->connect(connOpts); // 异步连接
if (!tok->wait_for(std::chrono::seconds(2))) // 设置超时
{
LOG_WARN("[MQTTClient] Connect timed out to broker: " + config_.server_ip);
startReconnect();
return;
}
connected_ = true;
reconnect_active_ = false;