すべてのプロダクト
Search
ドキュメントセンター

ApsaraMQ for MQTT:デモプロジェクト

最終更新日:Mar 24, 2025

このトピックでは、ApsaraMQ for MQTT のデモプロジェクトについて説明し、さまざまなシナリオにおける ApsaraMQ for MQTT の使用上の注意点を示します。デモのソースコード内のコメントもご参照ください。

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

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

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

Java

シナリオ

ダウンロードリンク

ApsaraMQ for MQTT のみを使用してメッセージを送受信する方法の例

mqtt.demo.java

ApsaraMQ for MQTT の署名認証モードを使用する方法の例

mqtt.signature.mode.demo.java

ApsaraMQ for MQTT のトークンベース認証モードを使用する方法の例

mqtt.token.mode.demo.java

ApsaraMQ for MQTT の SSL 暗号化機能を使用する方法の例

mqtt.ssl.demo.java

ApsaraMQ for MQTT を使用してメッセージを送信し、ApsaraMQ for RocketMQ を使用してメッセージを購読する方法の例

mqtt.to.rocketmq.demo.java

ApsaraMQ for RocketMQ を使用してメッセージを送信し、ApsaraMQ for MQTT を使用してメッセージを購読する方法の例

rocketmq.to.mqtt.demo.java

ApsaraMQ for MQTT を使用して順序付けられたメッセージを送信し、ApsaraMQ for RocketMQ を使用して順序付けられたメッセージを購読する方法の例

mqtt.ordered.msg.demo.java

ApsaraMQ for MQTT クライアントの非同期ステータス通知を設定する方法の例

mqtt.client.status.notice.demo.java

ApsaraMQ for MQTT の SSL 相互認証モードを使用する方法の例

mqtt.bissl.demo.java

Python

シナリオ

ダウンロードリンク

ApsaraMQ for MQTT のみを使用してメッセージを送受信する方法の例

mqtt.demo.python

ApsaraMQ for MQTT の署名認証モードを使用する方法の例

mqtt.signature.mode.demo.python

ApsaraMQ for MQTT の SSL 暗号化機能を使用する方法の例

mqtt.ssl.mode.demo.python

PHP

シナリオ

ダウンロードリンク

ApsaraMQ for MQTT のみを使用してメッセージを送受信する方法の例

mqtt.demo.php

ApsaraMQ for MQTT の署名認証モードを使用する方法の例

mqtt.signature.mode.demo.php

ApsaraMQ for MQTT のトークンベース認証モードを使用する方法の例

mqtt.token.mode.demo.php

ApsaraMQ for MQTT を使用して順序付けられたメッセージを送信し、ApsaraMQ for RocketMQ を使用して順序付けられたメッセージを購読する方法の例

mqtt.ordered.msg.demo.php

C

シナリオ

ダウンロードリンク

ApsaraMQ for MQTT のみを使用してメッセージを送受信する方法の例

mqtt.demo.c

ApsaraMQ for MQTT の署名認証モードを使用する方法の例

mqtt.signature.mode.demo.c

ApsaraMQ for MQTT の SSL 暗号化機能を使用する方法の例

mqtt.ssl.demo.c

説明

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

.NET

シナリオ

ダウンロードリンク

ApsaraMQ for MQTT のみを使用してメッセージを送受信する方法の例

mqtt.demo.net

ApsaraMQ for MQTT の署名認証モードを使用する方法の例

mqtt.signature.mode.demo.net

ApsaraMQ for MQTT の SSL 暗号化機能を使用する方法の例

mqtt.ssl.mode.demo.net

JavaScript

シナリオ

ダウンロードリンク

ApsaraMQ for MQTT のみを使用してメッセージを送受信する方法の例

mqtt.demo.javascript

ApsaraMQ for MQTT の署名認証モードを使用する方法の例

mqtt.signature.mode.demo.javascript

ApsaraMQ for MQTT の SSL 暗号化機能を使用する方法の例

mqtt.ssl.demo.javascript

WebSocket を使用して ApsaraMQ for MQTT でメッセージを送受信する方法の例

mqtt.websocket.demo.javascript

iOS

シナリオ

ダウンロードリンク

ApsaraMQ for MQTT のみを使用してメッセージを送受信する方法の例

mqtt.demo.ios

ApsaraMQ for MQTT の署名認証モードを使用する方法の例

mqtt.signature.mode.demo.ios

ApsaraMQ for MQTT の SSL 暗号化機能を使用する方法の例

mqtt.ssl.demo.ios

使用上の注意

ApsaraMQ for MQTTApsaraMQ for RocketMQ などの他のバックエンド メッセージ ストレージ サービスと共に使用する場合は、メッセージ構造と属性のマッピングを理解していることを確認してください。詳細については、「ApsaraMQ for MQTT と ApsaraMQ for 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 オペレーティング システム

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

    説明

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

    touch ~/.bash_profile
    vim ~/.bash_profile
  2. .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>

    設定後、ファイルを保存します。

  3. .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 ペアが有効な場合、設定は成功です。

重要

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

参考資料

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