JavaでのMQTTとデバイスの接続方法は何ですか？

1年 ago
芽依, 雨夜
1 minute

Javaを使うと、Eclipse Paho MQTTクライアントライブラリを使用してデバイスをMQTTブローカーに接続できます。以下はデバイスをMQTTブローカーに接続するための基本的な手順です。

  1. Paho MQTTクライアントライブラリをインポートする：Paho MQTTクライアントライブラリをJavaプロジェクトの依存関係に追加します。MavenやGradleを使用してライブラリをインポートすることができます。
  2. org.eclipse.paho
    org.eclipse.paho.client.mqttv3
    1.2.5
    依存関係：
    org.eclipse.paho
    org.eclipse.paho.client.mqttv3
    1.2.5
  3. MQTTクライアントを作成する：MqttClientクラスを使用して、MQTTクライアントオブジェクトを作成します。
  4. brokerという文字列には “tcp://mqtt.example.com:1883” が入り、clientIdという文字列には “myDevice” が入り、MqttClientクラスのインスタンスclientがbrokerとclientIdを引数にして生成されます。
  5. MqttConnectOptionsクラスを使用して、接続オプションオブジェクトを作成し、ユーザー名、パスワード、遺言メッセージなどの必要なパラメータを設定します。
  6. MqttConnectOptionsオブジェクトを作成し、そのオプションには以下を設定する：
    – ユーザー名を「myUsername」とし、
    – パスワードを「myPassword」とし、
    – メッセージトピックを「myTopic」、メッセージをバイト配列化して「myMessage」を設定し、未接続時にメッセージを送信する設定とする。
  7. MQTTエージェントに接続する：MqttClientのconnectメソッドを使用して、MQTTエージェントに接続します。
  8. クライアントはオプションを指定して接続する。
  9. 購読やメッセージの投稿：subscribeメソッドを使用してトピックを購読し、publishメソッドを使用してメッセージを投稿します。
  10. ストリングのトピック = “myTopic”;
    整数のqos = 1;
    クライアント.サブスクライブ(ストリングのトピック, qos);
    クライアント.パブリッシュ(ストリングのトピック, “こんにちは、MQTT！”.getBytes(), qos, false);
  11. メッセージ処理：受信したメッセージを処理するためには、MqttCallbackインターフェースを実装することができます。
  12. client.setCallback(new MqttCallback() {
    @Override
    public void connectionLost(Throwable cause) {
    // 接続が失われた際の処理
    }@Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
    // 受信したメッセージの処理
    String payload = new String(message.getPayload());
    System.out.println(“受信したメッセージ: ” + payload);
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
    // メッセージの発行が完了した際の処理
    }
    });

  13. MQTTエージェントとの接続を切断するには、disconnectメソッドを使用してください。
  14. クライアントが接続を切断する。

MQTTエージェントへのデバイスの接続方法は、上記の基本手順です。特定の要件に応じて、必要に応じて調整や拡張を行うことがあります。

bannerAds