MQTT客户端每15秒与ThingsBoard断开连接问题求助

我正在开发一款基于C语言的MQTT客户端，作为传感器网络的数据集中器。传感器通过Zigbee通信，需将数据通过MQTT协议发布至ThingsBoard服务器。
该应用计划运行在资源受限的单板计算机上，因此选用Mosquitto库以C语言实现基础网关功能，而非ThingsBoard官方Python网关。

客户端可成功连接ThingsBoard MQTT Broker并发布消息，但约15秒后会持续断开连接，Mosquitto库返回错误：Connection Refused: unknown reason (error code 7)。断开后客户端自动重连，形成每15秒一次的连接/断开循环。

已尝试的排查方案 #

• 唯一Client ID：使用设备MAC地址生成唯一客户端ID，避免冲突。
• Access Token：将ThingsBoard设备的Access Token作为用户名传入mosquitto_username_pw_set()，密码设为NULL。
• 异步连接：采用mosquitto_connect_async()和mosquitto_loop_start()在独立线程处理连接，理论可自动管理保活心跳。
• 本地Broker测试：相同代码对接本地MQTT Broker无断连问题，说明问题可能出在ThingsBoard配置或交互上。

MQTT线程代码片段 #

void *mosquitto_thread(void *arg) {
    // ... context and variable initialization ...

    char mac_address[18];
    get_mac_address("eth0", mac_address, sizeof(mac_address));

    mosquitto_lib_init();
    
    mosq = mosquitto_new(mac_address, true, ctx);
    if(!mosq){
        // ... error handling ...
    }
    
    mosquitto_username_pw_set(mosq, ctx->configuration.token, NULL);
    mosquitto_connect_callback_set(mosq, on_connect);
    mosquitto_disconnect_callback_set(mosq, on_disconnect);
    
    // Set keep-alive to 60 seconds
    int rc = mosquitto_connect_async(mosq, ctx->configuration.hostname, ctx->configuration.port, 60);
    if(rc != MOSQ_ERR_SUCCESS) {
        // ... error handling ...
    }

    mosquitto_loop_start(mosq);

    while(1){
        // Main loop for publishing messages from a queue
        // I also tried a simple 'sleep' loop with no publishing, and the issue persists.
        
        if(queue_pop(&ctx->pub_queue, &msg, 0)) {
            mosquitto_publish(mosq, NULL, msg.topic, strlen(msg.payload), msg.payload, ctx->configuration.qos, false);
        } else {
            usleep(1000); // 1ms sleep to not burn CPU
        }
        
        // ... stop flag check ...
    }

    mosquitto_loop_stop(mosq, true);
    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();
    
    return NULL;
}

我确认mosquitto_loop_start()会处理keep-alive，但每15秒的断连暗示超时问题。请问这是ThingsBoard服务器配置问题、网络问题，还是我的Mosquitto实现中存在mosquitto_loop_start()未覆盖的细节？

核心原因判断 #

排除代码逻辑问题——对接本地Broker无异常，问题大概率出在ThingsBoard的连接规则或网络层特殊限制上。错误码7（Connection Refused: unknown reason）是Mosquitto对服务器返回未明确定义拒绝原因的封装，结合15秒断连规律，重点排查以下方向：

1. ThingsBoard会话与Keep-Alive不匹配 #

ThingsBoard默认会话超时逻辑可能和你设置的60秒Keep-Alive不兼容。虽然mosquitto_loop_start()会自动发送心跳，但如果服务器端会话超时阈值远低于60秒（比如15秒），会主动断开未满足心跳频率的连接：

• 检查ThingsBoard的mqtt.session.timeout配置项（通常在thingsboard.yml中），确保其值大于等于你设置的Keep-Alive时长的1.5倍（MQTT标准建议）。
• 尝试将客户端Keep-Alive调整为10秒，观察是否缓解断连问题。

2. 被动断开后的重连逻辑缺陷 #

依赖Mosquitto自动重连需确认：

• mosquitto_new()的第二个参数设为true（clean session），如果ThingsBoard保留旧会话，新连接可能被拒绝。可尝试改为false，让服务器复用会话，避免连接冲突。
• 确保重连时Client ID和Access Token完全一致，无线程上下文导致的变量篡改。

3. 网络层NAT/防火墙超时限制 #

资源受限单板机可能处于NAT网络环境，路由器或防火墙的会话超时设置可能为15秒，导致连接被强制断开：

• 检查单板机所在网络的防火墙规则，确保MQTT端口（默认1883/8883）的会话超时大于60秒。
• 尝试在代码中增加主动发布心跳消息的逻辑（比如每10秒发布空状态消息），维持网络会话。

4. ThingsBoard设备权限限制 #

虽使用正确Access Token，但需确认：

• 设备在ThingsBoard中处于活跃状态，未被禁用或删除。
• Access Token未过期（若ThingsBoard配置了Token有效期）。
• 客户端发布的主题符合ThingsBoard设备权限规则（比如是否允许发布自定义主题，而非仅v1/devices/me/telemetry）。

代码优化建议 #

在断开回调中增加错误详情打印，辅助定位问题：

void on_disconnect(struct mosquitto *mosq, void *obj, int rc) {
    fprintf(stderr, "Disconnected with code %d, message: %s\n", rc, mosquitto_strerror(rc));
    // 手动触发重连（若自动重连失效）
    mosquitto_reconnect(mosq);
}

同时确保mosquitto_lib_init()仅被调用一次，避免线程重复初始化的潜在问题。

内容的提问来源于stack exchange，提问作者Franco Fischer