IoT Platform:PHP 用 SDK を使用してクライアントを IoT Platform に接続する

SDK をダウンロードする

サンプルコードは Stomp PHP ライブラリに基づいて記述されており、Simple Text Oriented Message Protocol（STOMP）を介して Stomp PHP クライアントを IoT Platform に接続できます。 Stomp PHP クライアントをダウンロードして手順を表示するには、Stomp PHP にアクセスしてください。

Stomp SDK for PHP がサポートする PHP バージョンについては、Stomp SDK for PHP の composer.json ファイルの require パラメーターの宣言を参照してください。composer.json

5.0.0 より前の Stomp PHP バージョンでは、SDK が切断された後、SDK が IoT Platform に再接続できない場合があります。 Stomp PHP 5.0.0 以降をダウンロードすることをお勧めします。詳細については、問題 を参照してください。

PHP プロジェクトディレクトリで、次のコマンドを実行して Stomp PHP 5.0.0 の SDK をダウンロードします。

composer require stomp-php/stomp-php 5.0.0

サンプルコード

<?php
// パラメータの詳細については、「AMQP クライアントを IoT Platform に接続する」トピックを参照してください。
// AccessKey ペアをプロジェクトコードにハードコードすると、プロジェクトコードが漏洩した場合に AccessKey ペアが公開される可能性があります。この場合、アカウント内のリソースは安全ではなくなります。次のサンプルコードは、環境変数から AccessKey ペアを取得する方法の例を示しています。この例は参照用です。
require __DIR__ . '/vendor/autoload.php';
use Stomp\Client;
use Stomp\Network\Observer\Exception\HeartbeatException;
use Stomp\Network\Observer\ServerAliveObserver;
use Stomp\StatefulStomp;

$accessKey = getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
$accessSecret = getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET');
$consumerGroupId = "${YourConsumerGroupId}"; // コンシューマーグループ ID
$clientId = "${YourClientId}"; // クライアント ID
// iotInstanceId: IoT Platform インスタンスの ID。
$iotInstanceId = "${YourIotInstanceId}"; // IoT Platform インスタンス ID
$timeStamp = round(microtime(true) * 1000);
// 署名アルゴリズム。有効な値：hmacmd5、hmacsha1、および hmacsha256。
$signMethod = "hmacsha1";
// userName パラメータの構造。詳細については、「AMQP クライアントを IoT Platform に接続する」トピックを参照してください。
// バイナリ形式でメッセージを送信する場合は、userName パラメータに encode=base64 を指定します。IoT Platform は、これらのメッセージを送信する前に、Base64 アルゴリズムを使用してこれらのメッセージをエンコードします。詳細については、このトピックの「バイナリ形式のメッセージ」セクションを参照してください。
$userName = $clientId . "|authMode=aksign"
            . ",signMethod=" . $signMethod
            . ",timestamp=" . $timeStamp
            . ",authId=" . $accessKey
            . ",iotInstanceId=" . $iotInstanceId
            . ",consumerGroupId=" . $consumerGroupId
            . "|";
$signContent = "authId=" . $accessKey . "&timestamp=" . $timeStamp;
// 署名を計算します。パスワードの構築方法の詳細については、「AMQP クライアントを IoT Platform に接続する」トピックを参照してください。
$password = base64_encode(hash_hmac("sha1", $signContent, $accessSecret, $raw_output = TRUE));
// エンドポイント。詳細については、「AMQP クライアントを IoT Platform に接続する」トピックを参照してください。
$client = new Client('ssl://${YourHost}:61614'); // エンドポイント
$sslContext = ['ssl' => ['verify_peer' => true, 'verify_peer_name' => false], ];
$client->getConnection()->setContext($sslContext);

// クライアントと IoT Platform 間の接続の状態を監視するリスナーを設定します。
$observer = new ServerAliveObserver();
$client->getConnection()->getObservers()->addObserver($observer);
// ハートビート設定。この設定により、IoT Platform は 30 秒ごとにハートビートパケットを送信できます。
$client->setHeartbeat(0, 30000);
$client->setLogin($userName, $password);
try {
    $client->connect();
}
catch(StompException $e) {
    echo "failed to connect to server, msg:" . $e->getMessage() , PHP_EOL; // サーバーへの接続に失敗しました
}
// 例外が発生しない場合、次のコードを実行します。
$stomp = new StatefulStomp($client);
$stomp->subscribe('/topic/#');
echo "connect success"; // 接続成功

while (true) {
    try {

        // 接続状態を確認します。
        if (!$client->isConnected()) {
            echo "connection not exists, will reconnect after 10s.", PHP_EOL; // 接続が存在しません。10 秒後に再接続します。
            sleep(10);
            $client->connect();
            $stomp->subscribe('/topic/#');
            echo "connect success", PHP_EOL; // 接続成功
        }

        // メッセージを処理するビジネスロジックを指定します。
        echo $stomp->read();
    }
    catch(HeartbeatException $e) {
        echo 'The server failed to send us heartbeats within the defined interval.', PHP_EOL; // サーバーは定義された間隔内にハートビートを送信できませんでした。
        $stomp->getClient()->disconnect();
    } catch(Exception $e) {
        echo 'process message occurs error: '. $e->getMessage() , PHP_EOL; // メッセージの処理中にエラーが発生しました
        $stomp->getClient()->disconnect();
    }
}   

次の表のパラメーターの説明に基づいて、上記のコードのパラメーターを設定できます。他のパラメーターの詳細については、「AMQP クライアントを IoT Platform に接続する」をご参照ください。

サンプル結果

• 次のような出力が表示された場合、AMQP クライアントは IoT Platform に接続されており、メッセージを受信できます。

• 次のような出力が表示された場合、AMQP クライアントは IoT Platform に接続できません。

  ログに基づいてコードまたはネットワーク環境を確認し、問題を解決してから、コードを再度実行できます。

  

バイナリ形式のメッセージ

バイナリ形式でメッセージを送信する場合は、Base64 アルゴリズムを使用してメッセージをエンコードします。 Base64 アルゴリズムを使用してメッセージをエンコードしない場合、STOMP はテキストベースのプロトコルであるため、メッセージが切り捨てられる可能性があります。

次のコードは、userName パラメーターに encode=base64 を指定する方法を示しています。この設定により、IoT Platform はメッセージを送信する前に Base64 アルゴリズムを使用してメッセージをエンコードできます。

$userName = $clientId . "|authMode=aksign"
                . ",signMethod=" . $signMethod
                . ",timestamp=" . $timeStamp
                . ",authId=" . $accessKey
                . ",iotInstanceId=" . $iotInstanceId
                . ",consumerGroupId=" . $consumerGroupId
                . ",encode=base64" . "|";

関連情報

サーバー側サブスクリプション機能に関連するエラーコードの詳細については、「IoT プラットフォームログ」トピックの メッセージに関連するエラーコード セクションをご参照ください。