android - MqttException (0) - AndroidThings の java.net.NoRouteToHostException

Question

私はまだプレビューモードにある Android Things を試しています。
コードを介したローカルネットワークだけでなく、wifi との通信で多くの課題に直面しています。
そのような機会の 1 つは、MQTT ブローカーとして RPi3 で Android Thing を作成することです。
問題が MQTT コードにあるのか、Android Things にあるのかはわかりません。

ここで問題を特定するのを手伝ってくれる人はいますか?
これが私のコードです：

package com.example.androidthings.myproject;

import android.app.Activity;
import android.os.Bundle;
import android.util.Log;

import com.google.android.things.pio.Gpio;
import com.google.android.things.pio.PeripheralManagerService;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import java.io.IOException;

    public class MainActivity extends Activity implements MqttCallback{
    private static final String TAG = MainActivity.class.getSimpleName();

    public static final String MOTOR_A_PIN_1 = "BCM21"; //physical pin #40
    public static final String MOTOR_A_PIN_2 = "BCM20"; //physical pin #38
    public static final String MOTOR_B_PIN_1 = "BCM24"; //physical pin #18
    public static final String MOTOR_B_PIN_2 = "BCM23"; //physical pin #16

    private Gpio motorAPin1;
    private Gpio motorAPin2;
    private Gpio motorBPin1;
    private Gpio motorBPin2;

    private MqttClient client;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        Log.d(TAG, "onCreate.....Motor MQTT");

        try {
            MemoryPersistence persistance = new MemoryPersistence();
            client = new MqttClient("tcp://127.0.0.1:1883", "AndroidThingBroker", persistance);
            client.connect();

            String topic = "topic/androidthings";
            int qos = 1;
            client.subscribe(topic, qos);

        } catch (MqttException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }

        PeripheralManagerService service = new PeripheralManagerService();
        try {

            // Create GPIO connection for L293D (Motor will run through L293D).
            motorAPin1 = service.openGpio(MOTOR_A_PIN_1);
            // Configure as an output.
            motorAPin1.setDirection(Gpio.DIRECTION_OUT_INITIALLY_LOW);

            // Create GPIO connection for L293D (Motor will run through L293D).
            motorAPin2 = service.openGpio(MOTOR_A_PIN_2);
            // Configure as an output.
            motorAPin2.setDirection(Gpio.DIRECTION_OUT_INITIALLY_LOW);

            // Create GPIO connection for L293D (Motor will run through L293D).
            motorBPin1 = service.openGpio(MOTOR_B_PIN_1);
            // Configure as an output.
            motorBPin1.setDirection(Gpio.DIRECTION_OUT_INITIALLY_LOW);

            // Create GPIO connection for L293D (Motor will run through L293D).
            motorBPin2 = service.openGpio(MOTOR_B_PIN_2);
            // Configure as an output.
            motorBPin2.setDirection(Gpio.DIRECTION_OUT_INITIALLY_LOW);

        } catch (IOException e) {
            Log.e(TAG, "Error on PeripheralIO API", e);
        }


    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        Log.d(TAG, "onDestroy");

        if (motorAPin1 != null) {
            try {
                motorAPin1.close();
            } catch (IOException e) {
                Log.e(TAG, "Error on PeripheralIO API", e);
            }
        }

        if (motorAPin2 != null) {
            try {
                motorAPin2.close();
            } catch (IOException e) {
                Log.e(TAG, "Error on PeripheralIO API", e);
            }
        }

        if (motorBPin1 != null) {
            try {
                motorBPin1.close();
            } catch (IOException e) {
                Log.e(TAG, "Error on PeripheralIO API", e);
            }
        }

        if (motorBPin2 != null) {
            try {
                motorBPin2.close();
            } catch (IOException e) {
                Log.e(TAG, "Error on PeripheralIO API", e);
            }
        }
    }

    @Override
    public void connectionLost(Throwable cause) {
        Log.d(TAG, "connectionLost....");
    }

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        String payload = new String(message.getPayload());
        Log.d(TAG, payload);
        // do stuff
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        Log.d(TAG, "deliveryComplete....");
    }
}

エラー：

12-27 15:03:58.898 2245-2245/com.example.androidthings.myproject W/System.err: 
Unable to connect to server (32103) - java.net.ConnectException: Connection refused
12-27 15:03:58.898 2245-2245/com.example.androidthings.myproject W/System.err:     at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:79)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at org.eclipse.paho.client.mqttv3.internal.ClientComms$ConnectBG.run(ClientComms.java:590)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at java.lang.Thread.run(Thread.java:761)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err: Caused by: java.net.ConnectException: Connection refused
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at java.net.PlainSocketImpl.socketConnect(Native Method)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:334)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:196)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:178)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:356)
12-27 15:03:58.899 2245-2245/com.example.androidthings.myproject W/System.err:     at java.net.Socket.connect(Socket.java:586)
12-27 15:03:58.900 2245-2245/com.example.androidthings.myproject W/System.err:     at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:70)
12-27 15:03:58.900 2245-2245/com.example.androidthings.myproject W/System.err:  ... 2 more

** 編集 **
IP アドレスを 127.0.0.1 に変更すると、別のエラースタックが表示されるようになりました。上記のエラーログを更新しました。

悪いが... MQTT Broker がダウンしていた。デバイス自体にブローカーを作成できると思いました。その後、サーバー上で実行する必要があることに気付きましたが、最初のテスト中に開始したサーバーがダウンしていました。
Mosquitto を使用してブローカーサーバーを起動したので、Android から接続できるようになりました:D

score 0 · Accepted Answer

adb shellそれが機能している場合pingは、Android Things ボードにインターネット接続があり、問題ではない可能性が高いことを意味します。

スタックトレースを見る

 client = new MqttClient("tcp://192.168.1.4:1883", "AndroidThingBroker", persistance);
 client.connect();

エラーをスローしているコードです。問題を絞り込むために、単純な Android アプリを作成するか、コンピューターに Java メインメソッドを作成して、ルートの問題を解決することができます。おそらくIPが間違っているなどですが、Android Thingsの問題ではないようです（または、少なくとも可能性を最小限に抑えるために、コードを事前にJavaアプリとして機能させてください）。

このコードも削除します。

 catch (Exception e) {
        e.printStackTrace();
    }

例外をキャッチしないように - 元のエラーの副作用ではなく、ルートエラーを確認できるように、アプリをできるだけ早く中断する必要があります。

android - MqttException (0) - AndroidThings の java.net.NoRouteToHostException

1 に答える 1

Related

Reference