исключение java.io.EOFException (32109) при запуске симулятора Eclipse Paho с примером клиента Hono

ProgramBox

исключение java.io.EOFException (32109) при запуске симулятора Eclipse Paho с примером клиента Hono

Post author:admin
Запись опубликована:9 апреля, 2023
Post category:Вопросы по программированию

#java #mqtt #paho #eclipse-hono

Вопрос:

Я использую скрипт симулятора MQTT, который использует библиотеку Java Eclipse Paho. Я выполнил регистрацию устройства, установил идентификатор устройства, идентификатор арендатора вручную с помощью терминала git bash в соответствии с инструкциями в руководстве по началу работы с Hono, запустил пример hono client также с инструкциями из руководства по началу работы, а затем запустил этот код симулятора.

 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 находится в локальном мини-кубе, и это результат работы службы получения kubectl.

 c:UsersHP>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

Пожалуйста, сообщите, как это исправить.

1. можете ли вы также опубликовать журнал адаптера MQTT во время взаимодействия с вашим клиентом? Вы можете распечатать журнал адаптера на консоль, используя, kubectl logs -f $MQTT_ADAPTER_POD_NAME -n hono где $MQTT_ADAPTER_POD_NAME — имя модуля адаптера MQTT в качестве выходных данных kubectl get pod -n hono .

2. Вот журнал — docdro.id/iJffFZe

3. Вы опубликовали только очень маленький фрагмент журнала. Интересная информация не содержится… Можете ли вы убедиться, что вы записываете все выходные данные журнала с момента запуска модуля до завершения взаимодействия вашего клиента MQTT с адаптером?

4. вот полный вывод с терминала, на котором была запущена команда logs — docdro.id/mkq0Wts . Ошибки являются… неверный идентификатор клиента: …. и ….. Исключение ClientErrorException: неверно сформированные учетные данные… не уверен, что нужно изменить. программа использует настройки, зарегистрированные в терминале

5. о, похоже, что весь текстовый журнал не был загружен в docdruid. вот новая ссылка — docdro.id/BOljVej

Ответ №1:

Как я понял, пароль должен быть в форме 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;

Помещаю его здесь на всякий случай, если кто-то еще может столкнуться с этим.