ApsaraMQ for MQTT SDK Demo の構築とテスト - ApsaraMQ for MQTT

Java 向け ApsaraMQ for MQTT クラウド SDK デモを使用して、テストプロジェクトを構築します。このデモでは、メッセージの送信、メッセージのサブスクライブ、クライアントステータス通知のサブスクライブという 3 つのタスクをカバーしています。

クラウド SDK は、ポート 5672 上で高度なメッセージキューイングプロトコル (AMQP) を使用し、バックエンドアプリケーションを ApsaraMQ for MQTT ブローカーに接続します。

前提条件

作業を開始する前に、以下の項目が準備されていることを確認してください。

IntelliJ IDEA Ultimate Edition または Eclipse がインストール済みであること
JDK 1.8 以降がインストール済みであること
ApsaraMQ for MQTT のインスタンス、トピック、およびグループがコンソール上で作成済みであること
Resource Access Management (RAM) ユーザーの AccessKey ペア（AccessKey ID および AccessKey Secret）を取得済みであること
ApsaraMQ for MQTT インスタンスのエンドポイント

サンプルクラス

デモプロジェクトには、以下の 3 つのクラスが含まれています。

クラス	目的
`MQTTProducerDemo`	ApsaraMQ for MQTT ブローカーにメッセージを送信します。
`MQTTConsumerDemo`	ApsaraMQ for MQTT ブローカーからメッセージをサブスクライブします。
`MQTTClientStatusNoticeProcessDemo`	クライアントのオンライン／オフラインステータス通知をサブスクライブします。

手順 1：デモのダウンロードとインポート

mqtt-server-sdk-demo からデモをクローンまたはダウンロードします。展開後、mqtt-server-sdk-demo-main フォルダ内に以下の場所にサンプルコードが格納されています。
```
   java-demo\src\main\java\com\aliyun\openservices\lmq\example
```
IntelliJ IDEA を起動し、mqtt-server-sdk-demo-main プロジェクトをインポートします。

手順 2：接続パラメーターの設定

サンプルクラスを開き、以下のパラメーターをご利用のリソース情報に置き換えます。

// ご利用の ApsaraMQ for MQTT インスタンスのエンドポイント。
// エンドポイントのフォーマットについては、「共通パラメーター」をご参照ください。
String domain = "<your-instance-endpoint>";

// クラウド SDK ポート。固定値：5672。
int port = 5672;

// ご利用の ApsaraMQ for MQTT インスタンスのインスタンス ID。
String instanceId = "<your-instance-id>";

// RAM ユーザーの AccessKey ID および AccessKey Secret。
String accessKey = "<your-access-key-id>";
String secretKey = "<your-access-key-secret>";

// メッセージング用にコンソールで作成した親トピック。
String firstTopic = "<your-parent-topic>";

// サブトピック。コンソールでの作成は不要です。
// 命名規則については、「用語」をご参照ください。
String secondTopic = "<your-subtopic>";

// メッセージング用にコンソールで作成したグループ ID。
String mqttGroupId = "<your-group-id>";

各パラメーターの説明は、以下の表のとおりです。

パラメーター	説明	例
`<your-instance-endpoint>`	ご利用の ApsaraMQ for MQTT インスタンスのエンドポイント。フォーマットについては、「共通パラメーター」をご参照ください。	mqtt-cn-xxx.mqtt.aliyuncs.com
`<your-instance-id>`	ApsaraMQ for MQTT コンソールからのインスタンス ID。	mqtt-cn-xxx
`<your-access-key-id>`	ご利用の RAM ユーザーの AccessKey ID。	LTAI5tXxx
`<your-access-key-secret>`	ご利用の RAM ユーザーの AccessKey Secret。	xXxXxXx
`<your-parent-topic>`	コンソールで作成された親トピック。	TestTopic
`<your-subtopic>`	サブトピック名。コンソールで作成する必要はありません。命名規則については、「用語」をご参照ください。	/level2/level3
`<your-group-id>`	コンソールで作成されたグループ ID。	GID_Test

手順 3：デモの実行

パラメーターを設定したら、IntelliJ IDEA でサンプルクラスを右クリックし、main() 関数を実行します。

結果の確認

ApsaraMQ for MQTT コンソールでメッセージトレースを照会し、メッセージが正常に送受信されたことを確認します。操作方法については、「メッセージトレースの照会」をご参照ください。