デモプロジェクト - ApsaraMQ for MQTT - Alibaba Cloud ドキュメントセンター

このトピックでは、MQTT向け ApsaraMQ のデモプロジェクトについて説明し、さまざまなシナリオで Message Queue for MQTT を使用するための使用上の注意を提供します。詳細については、デモのソースコードのコメントをご参照ください。

複数のプログラミング言語のデモを入手する

サンプルコードの完全なセットについては、mqtt-demo をご参照ください。

ダウンロードしたパッケージを解凍すると、オンプレミスマシンに mqtt-demo-main という名前のフォルダーが表示されます。レベル 1 のフォルダーは、プログラミング言語に基づいて分類されます。ビジネス要件に基づいてデバッグを実行します。

Java

シナリオ	ダウンロードリンク
MQTT向け ApsaraMQ のみを使用してメッセージを送受信する方法の例	mqtt.demo.java
MQTT向け ApsaraMQ の署名認証モードを使用する方法の例	mqtt.signature.mode.demo.java
MQTT向け ApsaraMQ のトークンベース認証モードを使用する方法の例	mqtt.token.mode.demo.java
MQTT向け ApsaraMQ の SSL 暗号化機能を使用する方法の例	mqtt.ssl.demo.java
MQTT向け ApsaraMQ を使用してメッセージを送信し、RocketMQ向け ApsaraMQ を使用してメッセージを購読する方法の例	mqtt.to.rocketmq.demo.java
RocketMQ向け ApsaraMQ を使用してメッセージを送信し、MQTT向け ApsaraMQ を使用してメッセージを購読する方法の例	rocketmq.to.mqtt.demo.java
MQTT向け ApsaraMQ を使用して順序付けられたメッセージを送信し、RocketMQ向け ApsaraMQ を使用して順序付けられたメッセージを購読する方法の例	mqtt.ordered.msg.demo.java
MQTT向け ApsaraMQ クライアントの非同期ステータス通知を構成する方法の例	mqtt.client.status.notice.demo.java
MQTT向け ApsaraMQ の SSL 相互認証モードを使用する方法の例	mqtt.bissl.demo.java

Python

シナリオ	ダウンロードリンク
MQTT向け ApsaraMQ のみを使用してメッセージを送受信する方法の例	mqtt.demo.python
MQTT向け ApsaraMQ の署名認証モードを使用する方法の例	mqtt.signature.mode.demo.python
MQTT向け ApsaraMQ の SSL 暗号化機能を使用する方法の例	mqtt.ssl.mode.demo.python

PHP

シナリオ	ダウンロードリンク
MQTT向け ApsaraMQ のみを使用してメッセージを送受信する方法の例	mqtt.demo.php
MQTT向け ApsaraMQ の署名認証モードを使用する方法の例	mqtt.signature.mode.demo.php
MQTT向け ApsaraMQ のトークンベース認証モードを使用する方法の例	mqtt.token.mode.demo.php
MQTT向け ApsaraMQ を使用して順序付けられたメッセージを送信し、RocketMQ向け ApsaraMQ を使用して順序付けられたメッセージを購読する方法の例	mqtt.ordered.msg.demo.php

C

シナリオ	ダウンロードリンク
MQTT向け ApsaraMQ のみを使用してメッセージを送受信する方法の例	mqtt.demo.c
MQTT向け ApsaraMQ の署名認証モードを使用する方法の例	mqtt.signature.mode.demo.c
MQTT向け ApsaraMQ の SSL 暗号化機能を使用する方法の例	mqtt.ssl.demo.c

説明

C の依存ライブラリについては、eclipse/paho.mqtt.c をご参照ください。

.NET

シナリオ	ダウンロードリンク
MQTT向け ApsaraMQ のみを使用してメッセージを送受信する方法の例	mqtt.demo.net
MQTT向け ApsaraMQ の署名認証モードを使用する方法の例	mqtt.signature.mode.demo.net
MQTT向け ApsaraMQ の SSL 暗号化機能を使用する方法の例	mqtt.ssl.mode.demo.net

JavaScript

シナリオ	ダウンロードリンク
MQTT向け ApsaraMQ のみを使用してメッセージを送受信する方法の例	mqtt.demo.javascript
MQTT向け ApsaraMQ の署名認証モードを使用する方法の例	mqtt.signature.mode.demo.javascript
MQTT向け ApsaraMQ の SSL 暗号化機能を使用する方法の例	mqtt.ssl.demo.javascript
WebSocket を使用して MQTT向け ApsaraMQ でメッセージを送受信する方法の例	mqtt.websocket.demo.javascript

iOS

シナリオ	ダウンロードリンク
MQTT向け ApsaraMQ のみを使用してメッセージを送受信する方法の例	mqtt.demo.ios
MQTT向け ApsaraMQ の署名認証モードを使用する方法の例	mqtt.signature.mode.demo.ios
MQTT向け ApsaraMQ の SSL 暗号化機能を使用する方法の例	mqtt.ssl.demo.ios

使用上の注意

MQTT向け ApsaraMQ を RocketMQ向け ApsaraMQ などの他のバックエンドメッセージストレージサービスと一緒に使用する場合は、メッセージ構造と属性のマッピングを理解していることを確認してください。詳細については、「MQTT と RocketMQ 間のメッセージ構造マッピング」をご参照ください。

説明

デモの完全性はプログラミング言語によって異なります。デモの更新は今後のバージョンで提供されます。機能のデモがない場合は、対応するプログラミング言語の SDK をダウンロードして機能をテストしてください。詳細については、Java の例をご参照ください。

アクセス資格情報を構成する

サンプルコードを使用する前に、MQTT_AK_ENV および MQTT_SK_ENV 環境変数を構成する必要があります。次のセクションでは、環境変数を構成する方法について説明します。

重要

Alibaba Cloud アカウントの AccessKey ペアを使用して、すべての API 操作にアクセスできます。Alibaba Cloud アカウントの AccessKey ペアが漏洩した場合、アカウントに属するすべてのリソースが潜在的なリスクにさらされます。アカウントのセキュリティを確保するために、RAM ユーザーの AccessKey ペアを使用して API 操作にアクセスし、日常的な O&M を実行することをお勧めします。AccessKey ペアの取得方法については、「AccessKey ペアを作成する」をご参照ください。

Linux および macOS オペレーティングシステム

.bash_profile ファイルを作成します。
説明
初めて環境変数を構成する場合は、touch ~/.bash_profile コマンドを実行して構成ファイルを作成できます。構成ファイルが既に存在する場合は、vim ~/.bash_profile コマンドを実行して構成ファイルを編集します。
```
touch ~/.bash_profile
vim ~/.bash_profile
```

.bash_profile ファイルを構成します。

# 次のコマンドの <ACCESS_KEY_ID> および <ACCESS_KEY_SECRET> を AccessKey ID と AccessKey シークレットに置き換えます。
export MQTT_AK_ENV=<ACCESS_KEY_ID>
export MQTT_SK_ENV=<ACCESS_KEY_SECRET>

構成後にファイルを保存します。

.bash_profile ファイルを使用します。

# 構成ファイルで次のコマンドを実行します。
source ~/.bash_profile
# 構成が有効になっているかどうかを確認します。
echo $MQTT_AK_ENV

返された AccessKey ペアが有効な場合、構成は成功です。

重要

環境変数を構成した後、統合開発環境 (IDE) などの開発ツールまたはサービスを再起動します。そうしないと、新しい設定が期待どおりに有効にならない場合があります。

Windows オペレーティングシステム

GUI を使用する

手順
Windows 10 で GUI を使用して環境変数を構成する場合は、次の手順を実行します。
Windows デスクトップで、この PC を右クリックし、[プロパティ] を選択します。表示されるページで、[システムの詳細設定] をクリックします。[システムのプロパティ] ダイアログボックスの [詳細設定] タブで、[環境変数] をクリックします。[環境変数] ダイアログボックスで、[ユーザー変数] または [システム変数] セクションの [新規] をクリックします。次に、次の表に示す変数を構成します。
変数
例
AccessKey ID
変数名: MQTT_AK_ENV
変数値: LTAI****
AccessKey シークレット
変数名: MQTT_SK_ENV
変数値: EZJn****
構成が成功したかどうかを確認します。
[開始] をクリックするか、Win + R キーを押します。 [実行] ダイアログボックスに「cmd」と入力し、[OK] をクリックするか、Enter キーを押して、コマンドプロンプトを開きます。次に、echo %MQTT_AK_ENV% コマンドと echo %MQTT_SK_ENV% コマンドを実行します。有効な AccessKey ペアが返された場合、構成は成功です。

CMD を使用する

手順
管理者としてコマンドプロンプトウィンドウを開き、次のコマンドを実行してオペレーティングシステムに環境変数を追加します。
```
setx MQTT_AK_ENV LTAI**** /M
setx MQTT_SK_ENV EZJn**** /M
```
/M は、環境変数がシステムレベルであることを示します。ユーザーレベルの環境変数を構成する場合は、このパラメーターを使用できません。
構成が成功したかどうかを確認します。
[スタート] をクリックするか、Win + R キーを押します。 [実行] ダイアログボックスに「cmd」と入力し、[OK] をクリックするか、Enter キーを押してコマンドプロンプトを開きます。次に、/* echo %MQTT_AK_ENV% */ コマンドと /* echo %MQTT_SK_ENV% */ コマンドを実行します。有効な AccessKey ペアが返された場合、構成は成功です。

Windows PowerShell を使用する

PowerShell で、新しい環境変数を構成します。環境変数は、すべての新しいセッションに適用されます。

[System.Environment]::SetEnvironmentVariable('MQTT_AK_ENV', 'LTAI****', [System.EnvironmentVariableTarget]::User)
[System.Environment]::SetEnvironmentVariable('MQTT_SK_ENV', 'EZJn****', [System.EnvironmentVariableTarget]::User)

すべてのユーザーの環境変数を構成します。次のコマンドを管理者として実行する必要があります。

[System.Environment]::SetEnvironmentVariable('MQTT_AK_ENV', 'LTAI****', [System.EnvironmentVariableTarget]::Machine)
[System.Environment]::SetEnvironmentVariable('MQTT_SK_ENV', 'EZJn****', [System.EnvironmentVariableTarget]::Machine)

一時的な環境変数を構成します。環境変数は、現在のセッションにのみ適用されます。

$env:MQTT_AK_ENV = "LTAI****"
$env:MQTT_SK_ENV = "EZJn****"

PowerShell で、Get-ChildItem env:MQTT_AK_ENV および Get-ChildItem env:MQTT_SK_ENV コマンドを実行します。返された AccessKey ペアが有効な場合、構成は成功です。

重要

追加情報

サンプルコードは参照用にのみ提供されています。特定のプログラミング言語の SDK の入手方法については、「SDK をダウンロードする」をご参照ください。

変数	例
AccessKey ID	変数名: MQTT_AK_ENV 変数値: LTAI****
AccessKey シークレット	変数名: MQTT_SK_ENV 変数値: EZJn****