ApsaraMQ for MQTT:Panduan cepat MQTT

Catatan penggunaan

ApsaraMQ for MQTT memerlukan antrian penyimpanan pesan backend. Perhatikan poin-poin berikut:

• Instans ApsaraMQ for MQTT adalah gerbang tanpa status. Instans ini mempertahankan koneksi klien dan meneruskan pesan untuk skenario IoT dan seluler. Instans tersebut tidak menyediakan persistensi pesan; Anda harus mengonfigurasi instans penyimpanan terpisah untuk menyimpan pesan.

• Setiap instans ApsaraMQ for MQTT (instans gerbang) harus di-bind ke instans penyimpanan (instans ApsaraMQ for RocketMQ).

• Saat ini, hanya instans ApsaraMQ for RocketMQ yang didukung sebagai instans penyimpanan backend.

• Anda dapat membuat jumlah terbatas instans ApsaraMQ for MQTT dalam satu wilayah. Setiap instans ApsaraMQ for MQTT hanya dapat di-bind ke satu instans ApsaraMQ for RocketMQ yang sesuai. Untuk batasan spesifik, lihat informasi di Konsol.

Saat menggunakan ApsaraMQ for MQTT, perhatikan pembatasan akses jaringan berikut:

Klien hanya dapat mengakses topik jika Group ID klien tersebut dan topik tersebut berada dalam instans dan wilayah yang sama. Misalnya, jika sebuah topik dibuat di Instans A di wilayah China (Beijing), topik tersebut hanya dapat diakses oleh klien ApsaraMQ for MQTT yang menggunakan Group ID yang dibuat di Instans A di wilayah China (Beijing).

Alur kerja

Alur kerja panduan cepat menunjukkan cara menggunakan ApsaraMQ for MQTT untuk mengirim dan menerima pesan.

Seperti yang ditunjukkan dalam alur kerja panduan cepat, Anda harus membuat sumber daya sebelum dapat menggunakan klien untuk mengirim dan menerima pesan. Jika tidak, server ApsaraMQ for MQTT akan menolak koneksi dari klien dengan Client ID yang tidak valid.

Prasyarat

• Anda telah mengaktifkan ApsaraMQ for RocketMQ. Jika belum mengaktifkan layanan tersebut, aktifkan terlebih dahulu.

• Anda memiliki AccessKey Alibaba Cloud. Untuk informasi selengkapnya, lihat Mendapatkan AccessKey.

Langkah 1: Buat sumber daya

1. Pilih wilayah.

   Pilih wilayah tempat Anda akan membuat sumber daya berdasarkan kebutuhan bisnis Anda.

   1. Masuk ke Konsol Message Queue for MQTT.

   2. Di bilah navigasi atas, pilih wilayah tempat Anda ingin membuat sumber daya, misalnya China (Beijing).

2. Buat instans ApsaraMQ for MQTT.

   Sebelum membuat instans ApsaraMQ for MQTT, perhatikan hal-hal berikut:

   • Jumlah total instans semua jenis yang dapat Anda buat di setiap wilayah dibatasi. Untuk batasan spesifik, lihat informasi di Konsol.

   • Perkirakan transaksi per detik (TPS), jumlah koneksi, dan jumlah subscription yang dibutuhkan berdasarkan skenario bisnis Anda untuk memilih spesifikasi instans yang sesuai. Untuk instans subscription, pemilihan spesifikasi yang terlalu rendah dapat memicu service throttling dan memengaruhi bisnis Anda.

   • Instans Edisi Dasar langsung berlaku setelah pembelian. Instans Edisi Platinum memerlukan waktu untuk deployment. Anda akan diberi tahu saat instans siap digunakan.

   Lakukan langkah-langkah berikut untuk membuat instans ApsaraMQ for MQTT:

   1. Di panel navigasi kiri, klik Overview.

   2. Di halaman Instances, klik Create Instance.

   3. Di halaman pembelian, pilih edisi dan konfigurasikan spesifikasi instans ApsaraMQ for MQTT sesuai kebutuhan. Lalu, selesaikan pembelian sesuai petunjuk.

   Kembali ke daftar instans di halaman Overview di Konsol. Anda dapat melihat instans ApsaraMQ for MQTT yang telah Anda buat.

3. Buat dan bind instans penyimpanan data.

   Setelah membuat instans ApsaraMQ for MQTT, Anda juga perlu membuat instans untuk menyimpan topik dan pesan (saat ini hanya instans ApsaraMQ for RocketMQ yang didukung), lalu bind instans ApsaraMQ for RocketMQ yang telah dibuat ke instans ApsaraMQ for MQTT dalam hubungan satu-ke-satu.

   Binding ini tunduk pada batasan berikut:

   • Instans ApsaraMQ for MQTT hanya dapat di-bind satu kali. Setelah binding berhasil, tidak dapat diubah.

   • Instans penyimpanan hanya dapat di-bind ke satu instans ApsaraMQ for MQTT. Binding satu-ke-banyak tidak didukung.

   • Dua instans yang akan di-bind harus memiliki tipe namespace yang sama. Instans dengan namespace eksklusif tidak dapat di-bind ke instans dengan namespace non-eksklusif.

   • Jika Anda menghapus instans penyimpanan yang di-bind ke instans ApsaraMQ for MQTT secara prematur, instans ApsaraMQ for MQTT tersebut akan menjadi tidak tersedia.

   Lakukan langkah-langkah berikut untuk membuat dan bind instans penyimpanan:

   1. Di panel navigasi kiri, klik Overview. Temukan instans ApsaraMQ for MQTT yang telah Anda buat dan klik Continue to Configure.

   2. Di kotak dialog Message Persistence Settings, pilih opsi sesuai kebutuhan Anda.

      • Jika Anda memiliki instans ApsaraMQ for RocketMQ, pilih Select Existing Instance. Daftar instans penyimpanan pesan Anda yang ada akan ditampilkan. Pilih instans penyimpanan pesan ApsaraMQ for RocketMQ yang ingin digunakan dan klik Confirm untuk menyelesaikan binding.

      • Jika Anda tidak memiliki instans ApsaraMQ for RocketMQ, pilih salah satu opsi berikut:

        • Create Shared Instance: Membuat instans ApsaraMQ for RocketMQ Edisi Standar. Masukkan nama dan deskripsi instans, lalu klik Confirm untuk membuat instans.

        • Purchase Platinum Instance: Membuat instans ApsaraMQ for RocketMQ Edisi Platinum. Pilih Purchase Platinum Instance dan klik Buy Now. Ikuti petunjuk di layar untuk menyelesaikan pembelian.

        Setelah membuat instans, ulangi Langkah i dan Langkah ii. Pilih Select Existing Instance, pilih instans ApsaraMQ for RocketMQ yang baru saja Anda buat, lalu klik Confirm untuk menyelesaikan binding.

4. Buat topik.

   Untuk memublikasikan dan berlangganan pesan, Anda harus terlebih dahulu membuat topik induk. Anda tidak perlu membuat subtopik di Konsol; subtopik tersebut dapat langsung digunakan dalam kode Anda.

   Hubungan satu-ke-satu terbentuk antara instans ApsaraMQ for MQTT dan instans penyimpanannya. Oleh karena itu, topik dibuat pada instans penyimpanan dan hubungan pemetaan dibuat di Konsol ApsaraMQ for MQTT. Semua operasi topik dapat dilakukan dengan cara yang sama seperti pada instans penyimpanan.

   Jika Anda telah membuat topik di ApsaraMQ for RocketMQ, Anda dapat langsung menggunakannya. Jika belum, lakukan langkah-langkah berikut untuk membuat topik:

   1. Di panel navigasi kiri, klik Message Storage.

   2. Di halaman Topic Management, pilih instans ApsaraMQ for MQTT yang telah Anda buat, lalu klik Create Topic.

   3. Di kotak dialog Create Topic, masukkan nama topik, pilih tipe pesan, dan tambahkan keterangan. Lalu, klik Confirm.

   Catatan

   Jika Anda perlu mengirim ordered messages dari klien ApsaraMQ for MQTT, Anda harus menggunakan topik ordered. Namun, klien ApsaraMQ for MQTT tidak mendukung konsumsi pesan ordered yang ketat.

5. Buat Group ID.

   Di ApsaraMQ for MQTT, Group ID mengidentifikasi sekelompok klien dengan fungsi logis yang identik, seperti kelas perangkat serupa. Group ID dan Device ID membentuk Client ID yang mengidentifikasi klien MQTT. Untuk informasi selengkapnya, lihat Istilah.

   1. Di panel navigasi kiri, klik Group Management.

   2. Di halaman Group Management, pilih instans ApsaraMQ for MQTT yang telah Anda buat dan klik Create Group ID.

   3. Di kotak dialog Create Group ID , masukkan Group ID yang ingin Anda buat dan klik OK.

   Setelah Group ID dibuat, Group ID tersebut akan muncul di halaman Group Management. Halaman ini menampilkan semua Group ID yang Anda miliki di wilayah saat ini.

   Catatan

   • Jika Group ID sudah tidak digunakan, segera hapus.

   • Group ID hanya dapat digunakan oleh akun yang membuatnya. Misalnya, RAM user tidak dapat menggunakan Group ID yang dibuat oleh Akun Alibaba Cloud induk dan harus membuat Group ID sendiri.

Langkah 2: Dapatkan endpoint

Saat menggunakan SDK untuk mengirim dan menerima pesan, Anda harus menentukan endpoint instans ApsaraMQ for MQTT. Endpoint terdiri dari nama domain dan nomor port.

Setelah instans ApsaraMQ for MQTT di-bind ke instans ApsaraMQ for RocketMQ, informasi endpoint ditampilkan di bagian Endpoint Information. Anda dapat memperoleh informasi endpoint dari bagian ini.

Setelah instans ApsaraMQ for MQTT dan instans ApsaraMQ for RocketMQ di-bind, Anda juga dapat melakukan langkah-langkah berikut untuk mendapatkan endpoint:

1. Di bilah navigasi atas Konsol, pilih wilayah tempat Anda membuat sumber daya. Lalu, di panel navigasi kiri, klik Instance Details.

2. Di halaman Instance Details, pilih instans ApsaraMQ for MQTT yang telah Anda buat dan klik tab Instance Information.

3. Di tab Instance Information, temukan bagian Endpoint Information untuk melihat nama domain endpoint yang diperlukan. Di bagian ini, temukan bidang public endpoint dan klik Copy untuk mendapatkan alamat endpoint.

Port

Selain protokol MQTT standar di TCP, ApsaraMQ for MQTT mendukung MQTT over SSL, WebSocket, WebSocket over SSL/TLS, dan Flash. Port layanan yang sesuai tercantum dalam Deskripsi port. Pilih port sesuai kebutuhan Anda.

Langkah 3: Publikasikan dan berlangganan pesan

1. Unduh SDK klien. Untuk tautan unduhan SDK dalam berbagai bahasa, lihat Unduhan SDK.

   Karena ApsaraMQ for MQTT mendukung protokol MQTT standar secara default, kami menyarankan Anda menggunakan SDK klien pihak ketiga open-source. Jika SDK untuk bahasa pemrograman Anda tidak tersedia, Anda dapat mencari SDK lain yang kompatibel dengan MQTT.

2. Unduh proyek demo untuk melihat deskripsi parameter. Anda kemudian dapat menjalankan demo tersebut untuk memublikasikan dan berlangganan pesan. Untuk tautan unduhan demo, lihat Proyek Demo.

   Pustaka demo mendukung beberapa bahasa pemrograman umum dan akan terus dikembangkan. Demo menampilkan fitur dasar dan Anda harus memodifikasi parameternya sesuai aplikasi dan lingkungan produksi Anda.

Informasi lebih lanjut

Anda juga dapat mengirim pesan dari Konsol untuk memverifikasi ketersediaan topik secara cepat. Untuk melakukannya, lakukan langkah-langkah berikut:

1. Di panel navigasi kiri, klik Message Storage.

2. Di halaman Message Storage, di bagian Topic List, temukan topik yang telah Anda buat, lalu klik Send di kolom Actions.

3. Di kotak dialog Send Message, atur properti pesan, masukkan konten pesan, lalu klik OK.

   Konsol akan mengembalikan notifikasi sukses dan ID pesan yang sesuai.