从paho JS客户端它工作，但从Java客户端它没有。 我有这样的代码

MqttConnectOptions conOpt = new MqttConnectOptions();

conOpt.setCleanSession(false);

conOpt.setUserName("test5");

conOpt.setPassword("123".toCharArray());

MqttDefaultFilePersistence filePersistence = new MqttDefaultFilePersistence("/home/manish/Downloads/mqttPersist");

client = new MqttAsyncClient(appProps.getProperty("mqtt.broker"),

appProps.getProperty("mqtt.clientId"), filePersistence);

client.setCallback(this);

client.connect(conOpt, new IMqttActionListener() {

@Override

public void onSuccess(IMqttToken imt) {

try {

client.subscribe(Constants.INTERNAL_TOPICS, Constants.INTERNAL_TOPIC_QOS);

} catch (MqttException ex) {

ex.printStackTrace();

}

}

@Override

public void onFailure(IMqttToken imt, Throwable thrwbl) {

thrwbl.printStackTrace();

}

});

我得到这个例外

Bad user name or password (4)

at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:28)

at org.eclipse.paho.client.mqttv3.internal.ClientState.notifyReceivedAck(ClientState.java:885)

at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:118)

at java.lang.Thread.run(Thread.java:745)

emqt console

06:47:36.456 [error] Client([email protected]:50741): Username 'undefined' login failed for username_or_password_undefined

06:47:36.463 [error] Client([email protected]:50742): Username 'undefined' login failed for username_or_password_undefined

据泛美卫生组织文档公共无效setPassword(的char []密码)，所以我在这里路过的char []作为paasword

我正在使用emqttd经纪商

2017-04-10

manish