Saat client MQTT terhubung atau terputus, aplikasi backend Anda sering memerlukan visibilitas real-time terhadap event tersebut untuk manajemen sesi, pencatatan log audit, atau penanganan failover. Aturan notifikasi status client meneruskan event online dan offline ini dari ApsaraMQ for MQTT ke topik ApsaraMQ for RocketMQ, tempat layanan backend dapat mengonsumsinya.
Hanya instans ApsaraMQ for RocketMQ 4.0 yang didukung sebagai tujuan notifikasi. Instans MQTT dan instans RocketMQ harus berada di wilayah yang sama.
Cara kerja
Client ApsaraMQ for MQTT terhubung ke atau terputus dari broker.
Broker menghasilkan event notifikasi status berdasarkan aturan yang dikonfigurasi.
Event tersebut diteruskan ke topik ApsaraMQ for RocketMQ yang ditentukan.
Layanan backend yang dideploy pada instans Elastic Compute Service (ECS) berlangganan ke topik RocketMQ tersebut dan memproses notifikasinya.
Untuk detail struktur pesan dari event yang diteruskan, lihat Pemetaan struktur pesan antara Message Queue for MQTT dan Message Queue for Apache RocketMQ.
Buat aturan notifikasi status client
Sebelum memulai, pastikan Anda telah memiliki:
Instans ApsaraMQ for MQTT dengan versi kernel V3.x.x
Instans ApsaraMQ for RocketMQ 4.0 di wilayah yang sama dengan instans MQTT Anda
Topik RocketMQ untuk menerima event notifikasi
Group ID yang dikonfigurasi untuk perangkat MQTT yang ingin Anda pantau
Untuk membuat aturan, ikuti langkah-langkah berikut:
Masuk ke Konsol ApsaraMQ for MQTT. Di panel navigasi sebelah kiri, klik Instances.
Di bilah navigasi atas, pilih wilayah tempat instans Anda berada. Klik nama instans untuk membuka halaman Instance Details.
Di panel navigasi sebelah kiri, klik Rules. Di pojok kiri atas halaman, klik Create Rule.
Pada langkah Configure Basic Information, atur parameter berikut, lalu klik Next.
Parameter Contoh Deskripsi Rule ID 111111 Identifier unik global untuk aturan. Dapat berisi huruf, angka, tanda hubung (-), dan garis bawah (_). Harus menyertakan setidaknya satu huruf atau angka, serta terdiri dari 3 hingga 64 karakter. Nilai yang melebihi 64 karakter akan dipotong secara otomatis. Tidak dapat diubah setelah dibuat. Description migrate from rocketmq Deskripsi aturan. Status Enable Apakah aturan langsung diaktifkan. Nilai yang valid: Enable, Disable. Rule Type Client Status Notification Pilih Client Status Notification untuk meneruskan event online dan offline client. Nilai valid lainnya: Data Outbound (lihat Ekspor data dari ApsaraMQ for MQTT ke layanan Alibaba Cloud lainnya), Data Inbound (lihat Impor data dari layanan cloud lain ke ApsaraMQ for MQTT). Pada langkah Configure Rule Source, atur sumber data, lalu klik Next.
Parameter Contoh Deskripsi Group ID GID_Client_Status Group ID perangkat yang event statusnya diteruskan. Untuk informasi selengkapnya tentang group ID, lihat Terms. Pada langkah Configure Rule Destination, atur tujuan untuk event yang diteruskan, lalu klik Create.
Parameter Contoh Deskripsi Destination Service Type Message Queue for Apache RocketMQ Layanan cloud yang menerima event status. Hanya ApsaraMQ for RocketMQ yang didukung. Message Queue for Apache RocketMQ Instance MQ_INST_13801563067\*\*\*\*\*_BbyOD2jQ Instans ApsaraMQ for RocketMQ yang menerima event. Harus berada di wilayah yang sama dengan instans MQTT. Topic TopicB Topik RocketMQ yang menerima event notifikasi.
Setelah aturan dibuat, aturan tersebut akan muncul di halaman Rules.
Edit aturan
Di halaman Rules, temukan aturan yang dituju. Di kolom Actions, pilih More > Edit.
Di halaman Edit Rule, ubah parameter apa pun kecuali Rule ID.
Klik Save di langkah Configure Rule Destination.
Aktifkan atau nonaktifkan aturan
Di halaman Rules, temukan aturan yang dituju. Di kolom Actions, pilih More > Enable atau Disable.
Di kotak dialog konfirmasi, klik OK.
Hapus aturan
Di halaman Rules, temukan aturan yang dituju. Di kolom Actions, pilih More > Delete.
Di kotak dialog konfirmasi, klik OK.