lyq/sweeper_200
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mqtt断线重连

Browse Source
This commit is contained in:
lyq 2025-11-03 09:26:39 +08:00
parent 1ea853111f
commit 0fbded215d
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/mqtt_report/include/mqtt_report/mqtt_client.hpp
View File

@ -38,7 +38,6 @@ public:
} }
} }
// 连接服务器，支持最大重试次数
bool connect(int max_retries = 5) bool connect(int max_retries = 5)
{ {
std::lock_guard<std::mutex> lock(mtx_); std::lock_guard<std::mutex> lock(mtx_);
@ -48,7 +47,7 @@ public:
MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer; MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
conn_opts.keepAliveInterval = 20; conn_opts.keepAliveInterval = 20;
conn_opts.cleansession = 1; conn_opts.cleansession = 1;
conn_opts.connectTimeout = 5; // ✅ 限制阻塞时间 conn_opts.connectTimeout = 5;
if (!username_.empty()) if (!username_.empty())
{ {