问题描述
我正在使用使用Java Eclipse Paho库的MQTT模拟器脚本。我进行了设备注册，按照Hono getting started guide中的说明使用git bash终端手动设置了设备ID，租户ID，还使用入门指南中的说明启动了示例hono客户端，然后运行该模拟器代码。
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class MqttPublishHeartRate {
public static void main(String[] args) {
String topic = "telemetry";
String content;
// int qos = 2;
String mqttAdaptorIp = "tcp://10.103.102.133:1883";
String tenantId = "f9ea5afe-2c11-4ab8-aa72-f2dd5df028a9";
String deviceid = "713af6cc-f06c-4b1d-bfd2-2a2e0811a35e";
String password = "password";
MemoryPersistence persistence = new MemoryPersistence();
try {
while (true) {
wait(10000);
content = "{\"heartrate\":" + heartRaterandom() + "}";
MqttClient sampleClient = new MqttClient(mqttAdaptorIp,tenantId,persistence);
MqttConnectOptions connopts = new MqttConnectOptions();
connopts.setUserName(deviceid);
connopts.setPassword(password.tochararray());
connopts.setKeepAliveInterval(15);
connopts.setConnectionTimeout(30);
System.out.println("Connecting to broker: " + mqttAdaptorIp);
sampleClient.connect(connopts);
System.out.println("Connected");
System.out.println("Publishing message: " + content);
MqttMessage message = new MqttMessage(content.getBytes());
// message.setQos(qos);
sampleClient.publish(topic,message);
System.out.println("Message published");
sampleClient.disconnect();
System.out.println("disconnected");
}
} catch (MqttException me) {
System.out.println("reason " + me.getReasonCode());
System.out.println("msg " + me.getMessage());
System.out.println("loc " + me.getLocalizedMessage());
System.out.println("cause " + me.getCause());
System.out.println("excep " + me);
me.printstacktrace();
}
}
public static void wait(int ms) {
try {
Thread.sleep(ms);
} catch (InterruptedException ex) {
Thread.currentThread().interrupt();
}
}
public static int heartRaterandom() {
int heartRate = (int) Math.floor(Math.random() * 40) + 60;
return heartRate;
}
}
但是我得到了这个例外：
Connecting to broker: tcp://10.103.102.133:1883
reason 32109
msg Connection lost
loc Connection lost
cause java.io.EOFException
excep Connection lost (32109) - java.io.EOFException
Connection lost (32109) - java.io.EOFException
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:181)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.io.EOFException
at java.base/java.io.DataInputStream.readByte(DataInputStream.java:272)
at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:133)
... 6 more
我的Hono设置在本地minikube中，这是kubectl get服务的输出。
c:\Users\HP>kubectl get service -n hono
NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
eclipse-hono-adapter-amqp-vertx LoadBalancer 10.107.174.140 10.107.174.140 5672:32672/TCP,5671:32671/TCP 3d17h
eclipse-hono-adapter-amqp-vertx-headless ClusterIP None <none> <none> 3d17h
eclipse-hono-adapter-http-vertx LoadBalancer 10.101.233.249 10.101.233.249 8080:30080/TCP,8443:30443/TCP 3d17h
eclipse-hono-adapter-http-vertx-headless ClusterIP None <none> <none> 3d17h
eclipse-hono-adapter-mqtt-vertx LoadBalancer 10.103.102.133 10.103.102.133 1883:31883/TCP,8883:30883/TCP 3d17h
eclipse-hono-adapter-mqtt-vertx-headless ClusterIP None <none> <none> 3d17h
eclipse-hono-artemis ClusterIP 10.105.136.215 <none> 5671/TCP 3d17h
eclipse-hono-dispatch-router ClusterIP 10.103.15.52 <none> 5673/TCP 3d17h
eclipse-hono-dispatch-router-ext LoadBalancer 10.104.151.34 10.104.151.34 15671:30671/TCP,15672:30672/TCP 3d17h
eclipse-hono-grafana ClusterIP 10.110.248.10 <none> 3000/TCP 3d17h
eclipse-hono-prometheus-server ClusterIP 10.110.243.239 <none> 9090/TCP 3d17h
eclipse-hono-service-auth ClusterIP 10.105.228.68 <none> 5671/TCP 3d17h
eclipse-hono-service-auth-headless ClusterIP None <none> <none> 3d17h
eclipse-hono-service-device-registry ClusterIP 10.101.64.187 <none> 5671/TCP,8443/TCP 3d17h
eclipse-hono-service-device-registry-ext LoadBalancer 10.105.144.218 10.105.144.218 28080:31080/TCP,28443:31443/TCP 3d17h
eclipse-hono-service-device-registry-headless ClusterIP None <none> <none> 3d17h
请让我们知道如何解决此问题。
解决方法
弄清楚，密码应采用auth-id @ tenant的形式，例如sensor1 @ DEFAULT_TENANT（https://www.eclipse.org/hono/docs/user-guide/mqtt-adapter/） 因此将代码修改为：
String tenantId = "DEFAULT_TENANT";
String authId = "sensor1";
String username = authId+"@"+tenantId;
将其放在此处，以防其他人面临。