IoT Platform:Menghubungkan klien ke IoT Platform menggunakan SDK untuk PHP

Unduh SDK

Kode contoh ditulis berdasarkan pustaka Stomp PHP dan memungkinkan Anda menghubungkan klien Stomp PHP ke IoT Platform melalui Simple Text Oriented Message Protocol (STOMP). Untuk mengunduh klien Stomp PHP dan melihat petunjuknya, kunjungi Stomp PHP.

Untuk informasi tentang versi PHP yang didukung oleh Stomp SDK untuk PHP, lihat deklarasi parameter require dalam file composer.json dari Stomp SDK untuk PHP.

Pada versi Stomp PHP sebelum 5.0.0, SDK mungkin gagal menyambung kembali ke IoT Platform setelah terputus. Kami menyarankan Anda mengunduh Stomp PHP 5.0.0 atau yang lebih baru. Untuk informasi lebih lanjut, lihat Masalah.

Di direktori proyek PHP, jalankan perintah berikut untuk mengunduh SDK Stomp PHP 5.0.0:

composer require stomp-php/stomp-php 5.0.0

Kode contoh

<?php
require __DIR__ . '/vendor/autoload.php';
use Stomp\Client;
use Stomp\Network\Observer\Exception\HeartbeatException;
use Stomp\Network\Observer\ServerAliveObserver;
use Stomp\StatefulStomp;

// Untuk informasi lebih lanjut tentang parameter, lihat topik "Menghubungkan klien AMQP ke IoT Platform".
// Jika Anda melakukan hard-code pasangan AccessKey dalam kode proyek, pasangan AccessKey tersebut mungkin terungkap jika kode proyek bocor. Dalam hal ini, sumber daya dalam akun Anda menjadi tidak aman. Contoh kode berikut memberikan contoh cara mendapatkan pasangan AccessKey dari variabel lingkungan. Contoh ini hanya untuk referensi.
$accessKey = getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
$accessSecret = getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET');
$consumerGroupId = "${YourConsumerGroupId}";
$clientId = "${YourClientId}";
// iotInstanceId: ID instance IoT Platform.
$iotInstanceId = "${YourIotInstanceId}";
$timeStamp = round(microtime(true) * 1000);
// Algoritma tanda tangan. Nilai yang valid: hmacmd5, hmacsha1, dan hmacsha256.
$signMethod = "hmacsha1";
// Struktur parameter userName. Untuk informasi lebih lanjut, lihat topik "Menghubungkan klien AMQP ke IoT Platform".
// Jika Anda ingin mentransmisikan pesan dalam format biner, tentukan encode=base64 dalam parameter userName. Sebelum IoT Platform mengirimkan pesan-pesan ini, IoT Platform mengkodekan pesan-pesan tersebut menggunakan algoritma Base64. Untuk informasi lebih lanjut, lihat bagian "Pesan dalam format biner" dari topik ini.
$userName = $clientId . "|authMode=aksign"
            . ",signMethod=" . $signMethod
            . ",timestamp=" . $timeStamp
            . ",authId=" . $accessKey
            . ",iotInstanceId=" . $iotInstanceId
            . ",consumerGroupId=" . $consumerGroupId
            . "|";
$signContent = "authId=" . $accessKey . "&timestamp=" . $timeStamp;
// Hitung tanda tangan. Untuk informasi lebih lanjut tentang cara membangun kata sandi, lihat topik "Menghubungkan klien AMQP ke IoT Platform".
$password = base64_encode(hash_hmac("sha1", $signContent, $accessSecret, $raw_output = TRUE));
// Titik akhir. Untuk informasi lebih lanjut, lihat topik "Menghubungkan klien AMQP ke IoT Platform".
$client = new Client('ssl://${YourHost}:61614');
$sslContext = ['ssl' => ['verify_peer' => true, 'verify_peer_name' => false], ];
$client->getConnection()->setContext($sslContext);

// Konfigurasikan pendengar untuk memantau status koneksi antara klien dan IoT Platform.
$observer = new ServerAliveObserver();
$client->getConnection()->getObservers()->addObserver($observer);
// Pengaturan denyut jantung. Pengaturan ini memungkinkan IoT Platform mengirim paket denyut jantung setiap 30 detik.
$client->setHeartbeat(0, 30000);
$client->setLogin($userName, $password);
try {
    $client->connect();
}
catch(StompException $e) {
    echo "gagal terhubung ke server, pesan:" . $e->getMessage() , PHP_EOL;
}
// Jalankan kode berikut jika tidak ada pengecualian yang terjadi:
$stomp = new StatefulStomp($client);
$stomp->subscribe('/topic/#');
echo "koneksi berhasil";

while (true) {
    try {

        // Periksa status koneksi.
        if (!$client->isConnected()) {
            echo "koneksi tidak ada, akan menyambung kembali setelah 10 detik.", PHP_EOL;
            sleep(10);
            $client->connect();
            $stomp->subscribe('/topic/#');
            echo "koneksi berhasil", PHP_EOL;
        }

        // Tentukan logika bisnis untuk memproses pesan.
        echo $stomp->read();
    }
    catch(HeartbeatException $e) {
        echo 'Server gagal mengirim denyut jantung kepada kita dalam interval yang ditentukan.', PHP_EOL;
        $stomp->getClient()->disconnect();
    } catch(Exception $e) {
        echo 'terjadi kesalahan saat memproses pesan: '. $e->getMessage() , PHP_EOL;
        $stomp->getClient()->disconnect();
    }
}   

Anda dapat mengonfigurasi parameter dalam kode sebelumnya sesuai dengan deskripsi parameter dalam tabel berikut. Untuk informasi lebih lanjut tentang parameter lainnya, lihat Menghubungkan Klien AMQP ke IoT Platform.

Hasil contoh

• Jika informasi serupa dengan output berikut ditampilkan, klien AMQP terhubung ke IoT Platform dan dapat menerima pesan.

• Jika informasi serupa dengan output berikut ditampilkan, klien AMQP gagal terhubung ke IoT Platform.

  Anda dapat memeriksa kode atau lingkungan jaringan berdasarkan log, menyelesaikan masalah, lalu menjalankan kode lagi.

  

Pesan dalam format biner

Jika Anda ingin mentransmisikan pesan dalam format biner, gunakan algoritma Base64 untuk mengkodekan pesan. Jika Anda tidak menggunakan algoritma Base64 untuk mengkodekan pesan, pesan mungkin terpotong karena STOMP adalah protokol berbasis teks.

Kode berikut menunjukkan cara menentukan encode=base64 dalam parameter userName. Pengaturan ini memungkinkan IoT Platform mengkodekan pesan menggunakan algoritma Base64 sebelum IoT Platform mengirimkan pesan.

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

Referensi

Untuk informasi lebih lanjut tentang kode kesalahan yang terkait dengan fitur langganan sisi server, lihat bagian Kode Kesalahan yang Terkait dengan Pesan dari topik "Log IoT Platform".