Qt+Mosquitto多设备同主题MQTT消息重叠，无法识别发送端求助

核心问题本质 #

你遇到的两个现象是连锁的：

• 单设备消息被拆分成多段，是因为设备端本身分多次发送消息片段，而非将完整JSON作为单个MQTT消息发送；
• 多设备消息重叠，是因为你的缓冲区是全局的，没有按设备隔离不同的消息片段流；
• mosquitto_sub也出现同样问题，进一步验证了问题根源在设备发送逻辑或消息格式设计，而非Qt客户端或Mosquitto Broker的异常。

解决方案 #

1. 优先修正设备端发送逻辑（最优解） #

MQTT是基于完整消息的协议，每个MQTT消息应当承载完整的业务数据。你需要让设备端：

• 将完整的JSON数据作为单个MQTT消息发送，而非分块发送片段；
• 移除不必要的\x03结束符，因为完整的MQTT消息本身就是边界。
  这样客户端收到的每个messageReceived信号都对应一条完整的设备消息，无需拼接，自然也不会有设备消息重叠的问题。

如果设备端无法修改，再考虑以下应用层兼容方案：

2. 按设备ID隔离消息缓冲区 #

利用消息中已有的Device ID字段，为每个设备维护独立的缓冲区，避免不同设备的消息片段混在一起：

修改你的MqttSubscriptionManager类，增加按设备ID分组的缓冲区：

#include <QHash>

class MqttSubscriptionManager : public QObject
{
    Q_OBJECT
private:
    QString topicName;
    quint8 qos;
    QMqttSubscription *sub;
    QHash<QString, QByteArray> deviceBuffers; // 设备ID -> 对应缓冲区

    // 从消息片段中提取Device ID（可根据实际JSON结构优化）
    QString extractDeviceId(const QByteArray &payload) {
        int start = payload.indexOf("\"Device ID\":");
        if (start == -1) return QString();
        start += QString("\"Device ID\":").length();
        int end = payload.indexOf(',', start);
        if (end == -1) end = payload.indexOf('}', start);
        if (end == -1) return QString();
        return payload.mid(start, end - start).trimmed();
    }

public:
    explicit MqttSubscriptionManager(QMqttSubscription *sub, QString topic, quint8 qos, QObject *parent = nullptr);
    // ...
};

修改消息处理逻辑：

void MqttSubscriptionManager::handleReceivedMessage(QByteArray payload)
{
    QString deviceId = extractDeviceId(payload);
    
    // 如果当前片段无法提取Device ID，可暂存到临时缓冲区（需额外处理超时逻辑）
    if (deviceId.isEmpty()) {
        // 示例简化处理，实际可维护临时缓冲区等待后续片段补全ID
        return;
    }

    // 获取对应设备的缓冲区并追加片段
    QByteArray &buffer = deviceBuffers[deviceId];
    buffer.append(payload);

    // 检查是否到达结束符
    if (buffer.endsWith('\x03')) {
        buffer.chop(1); // 移除结束符
        qDebug() << "完整消息（设备" << deviceId << "）:" << buffer;
        
        // 执行JSON解析逻辑...
        
        buffer.clear(); // 清空该设备的缓冲区
    }
}

3. 优化Mosquitto Broker配置（辅助） #

• 检查mosquitto.conf中的message_size_limit参数，确保其大于设备发送的完整JSON消息大小，避免Broker截断消息；
• 考虑升级Mosquitto到2.x版本，1.5.8是较旧版本，新版本在消息处理稳定性上有提升。

内容的提问来源于stack exchange，提问作者Enrico Razzaboni