如何解決使用Eclipse Paho的MqttAsyncClient連接本地EMQX時用戶名密碼認證失敗的問題？

eclipse Paho MQTTAsyncClient連接本地EMQX用戶名密碼認證失敗的解決方法

本文檔闡述了使用Java和Eclipse Paho的MQTTAsyncClient庫連接本地EMQX MQTT Broker時，用戶名密碼認證失敗問題的解決方法。

問題描述

在使用org.eclipse.paho.client.mqttv3庫連接本地EMQX（配置為內置數據庫密碼認證，密碼加密方式為plain，加鹽禁用）時，即使用戶名“emqx_test”和密碼“emqx_test_password”正確，連接仍會失敗，并拋出MqttSecurityException: 錯誤的用戶名或密碼異常。 MQTTX客戶端測試連接成功。 Java代碼如下：

String brokerUrl = "tcp://127.0.0.1:1883"; MqttAsyncClient mqttClient = new MqttAsyncClient(brokerUrl, "test");  MqttConnectOptions connOpts = new MqttConnectOptions(); connOpts.setUserName("emqx_test"); connOpts.setPassword("emqx_test_password".toCharArray()); connOpts.setServerURIs(new String[] { brokerUrl }); connOpts.setCleanSession(true);  mqttClient.connect(connOpts, connStatus); // 問題所在

回調函數onFailure返回reason_code_failed_authentication錯誤碼。 當禁用EMQX的內置數據庫認證后，連接成功，但EMQX控制臺顯示缺少用戶名。

解決方案

問題在于mqttClient.connect(connOpts, connStatus);這行代碼。 為了正確進行用戶名密碼認證，需要修改為：

mqttClient.connect(connOpts, NULL, connStatus);

將第二個參數設為null，即可解決認證失敗問題。 修改后，連接成功，并且用戶名認證生效。

通過以上調整，即可解決Eclipse Paho MQTTAsyncClient連接本地EMQX時用戶名密碼認證失敗的問題。