如何通过SCRAM认证连接EMQX？Spring Integration MQTT配置问题

你的核心问题是手动硬编码了AuthData，并且错误干预了SCRAM的认证流程，导致EMQX收到不符合规范的认证请求而拒绝连接。以下是修正方案和关键说明：

错误分析 #

SCRAM是交互式多轮认证机制，要求客户端生成包含随机nonce的client-first-message，而非固定字符串。你手动设置setAuthData("client-first-message".getBytes())会破坏认证流程，EMQX无法解析无效请求，因此返回未授权。

同时，Spring Integration底层依赖的Paho MQTTv5客户端已经内置了SCRAM的完整实现，不需要手动指定AuthMethod和AuthData，客户端会自动处理多轮交互流程。

修正后的代码 #

修改SCRAM分支的配置逻辑，移除错误的setAuthMethod和setAuthData，改用客户端内置的Sasl机制配置：

@Bean
public ClientManager<IMqttAsyncClient, MqttConnectionOptions> mqttClientManager() {
    MqttConnectionOptions connectionOptions = new MqttConnectionOptions();
    if (mqttProperties.getAuthMethod() != null) {
        switch (mqttProperties.getAuthMethod()) {
            case USERNAME:
                connectionOptions.setUserName(mqttProperties.getUsername());
                connectionOptions.setPassword(mqttProperties.getPassword().getBytes());
                break;
            case SCRAM_SHA_256:
                log.debug("mqtt authentication with scram-sha-256");
                // 指定SCRAM-SHA-256作为Sasl认证机制
                connectionOptions.setSaslMechanisms("SCRAM-SHA-256");
                connectionOptions.setUserName(mqttProperties.getUsername());
                connectionOptions.setPassword(mqttProperties.getPassword().getBytes());
                // 移除手动设置AuthMethod和AuthData的代码
                break;
        }
    }
    connectionOptions.setServerURIs(new String[]{mqttProperties.getHost()});
    connectionOptions.setKeepAliveInterval(mqttProperties.getKeepalive());
    connectionOptions.setAutomaticReconnect(true);
    connectionOptions.setAutomaticReconnectDelay(1, 5);
    connectionOptions.setConnectionTimeout(mqttProperties.getTimeout());
    connectionOptions.setCleanStart(false);
    String clientId = getClientId();
    Mqttv5ClientManager clientManager = new Mqttv5ClientManager(connectionOptions, clientId);
    log.info("mqtt url: {}, clientId: {}", mqttProperties.getHost(), clientId);
    return clientManager;
}

额外检查项 #

1. EMQX账号配置验证：确保SCRAM账号是通过SCRAM算法创建的，比如使用EMQX命令行：

   emqx_ctl users add --scram-sha-256 your_username your_password
   

   或在EMQX Dashboard中创建账号时，选择SCRAM-SHA-256作为认证算法。
2. 依赖版本确认：确保使用的Paho MQTTv5客户端版本≥1.2.5，该版本开始完整支持SCRAM认证。
3. EMQX认证规则检查：确认EMQX中已启用SCRAM认证器，且优先级配置正确（避免被其他认证器拦截）。

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