使用org.eclipse.paho.client.mqttv3:1.2.5建立MQTT连接失败求助

异常原因分析 #

这个异常说明客户端通过WebSocket协议连接MQTT Broker时，握手阶段未收到正确的Upgrade响应，通常和以下场景有关：

• 连接URL格式不符合WebSocket模式要求
• Broker未正确启用WebSocket服务或配置不匹配
• 客户端连接参数设置有误

具体解决步骤 #

1. 修正MQTT连接URL格式 #

使用WebSocket连接时，URL必须遵循规范格式：

• 非加密WebSocket：ws://<Broker地址>:<WS端口>/<MQTT路径>（示例：ws://localhost:8083/mqtt）
• 加密WebSocket：wss://<Broker地址>:<WSS端口>/<MQTT路径>

如果你的URL是普通TCP协议格式（tcp://xxx）但实际要走WebSocket，或者Broker只支持TCP却用了ws/wss格式，都会触发该异常。

2. 确认Broker的WebSocket配置 #

确保你的MQTT Broker（如EMQX、Mosquitto）已启用WebSocket服务，且端口、路径与客户端URL匹配：

• Mosquitto：需在配置文件中添加listener 8083并开启protocol websockets
• EMQX：默认启用WebSocket，端口为8083（ws）、8084（wss），默认路径为/mqtt

3. 调整客户端连接参数 #

针对你的代码，重点检查以下参数：

• ConnectionTimeout设置：原代码设为0会导致客户端无限等待连接，建议改为合理值（如10秒）
• KeepAliveInterval单位：该方法参数单位是秒，原代码传入15000会导致心跳间隔长达4小时，需修正为15
• 启用SkipPortDuringHandshake：若Broker或反向代理握手时不需要携带端口，取消注释options.setSkipPortDuringHandshake(true);

修正后的示例代码 #

private MqttClient instantiateNewMqttConnection()  {
    logger.info("Intantiate new MQTT connection....");
    logger.info("Connecting to MQTT Broker: " + this.params.url);
    MqttClient client = null;
    try {
        client = new MqttClient(this.params.url, this.params.clientId, new MemoryPersistence());

        client.setCallback(new MqttConnectionCallBack(this.params.clientId));
        MqttConnectOptions options = new MqttConnectOptions();
        options.setCleanSession(true);
        options.setAutomaticReconnect(true);
        options.setConnectionTimeout(10); // 设置合理超时时间
        options.setKeepAliveInterval(15); // 修正为秒级单位
        options.setSkipPortDuringHandshake(true); // 根据实际场景启用
        IMqttToken token = client.connectWithResult(options);
        token.waitForCompletion();
    } catch (MqttException e) {
        logger.error("MQTT Connection Failed", e); // 打印完整异常栈轨迹便于排查
        Assert.fail("Failed due to MQTT connection could not be made");
    }
    return client;
}

4. 排查网络代理问题 #

若客户端与Broker之间存在反向代理（如Nginx），需确保代理正确转发WebSocket请求：

• 代理需支持Upgrade协议，保留Upgrade、Connection等握手头部
• 避免代理拦截WebSocket相关请求头

内容的提问来源于stack exchange，提问作者Harish Algat