Siapkan ApsaraMQ for MQTT, kirim pesan pertama Anda, dan verifikasi konektivitas end-to-end. Panduan ini mencakup pembuatan instans ApsaraMQ for MQTT, pengikatannya ke instans penyimpanan, serta penerbitan dan langganan pesan.
Panduan ini mencakup protokol MQTT default. Untuk mengakses instans ApsaraMQ for MQTT melalui protokol non-MQTT, seperti Standar Nasional Kendaraan Listrik Tiongkok, beli instans ApsaraMQ for MQTT Edisi Platinum. Dokumentasi dan dukungan teknis untuk Edisi Platinum disediakan melalui saluran eksklusif.
Prasyarat
Sebelum memulai, pastikan Anda memiliki:
Akun Alibaba Cloud dengan Pasangan Kunci Akses. Untuk detailnya, lihat Dapatkan Pasangan Kunci Akses.
ApsaraMQ for RocketMQ yang telah diaktifkan. Jika belum diaktifkan, aktifkan ApsaraMQ for RocketMQ.
Cara kerja
ApsaraMQ for MQTT adalah gerbang tanpa status yang mempertahankan koneksi klien dan meneruskan pesan dalam skenario IoT dan Internet seluler. Layanan ini tidak menyimpan data pesan secara persisten. Setiap instans ApsaraMQ for MQTT harus diikatkan ke instans ApsaraMQ for RocketMQ yang menangani penyimpanan pesan. Hanya instans ApsaraMQ for RocketMQ yang didukung sebagai instans penyimpanan.
Alur kerja keseluruhan:
Buat instans ApsaraMQ for MQTT (gerbang).
Buat dan ikatkan instans ApsaraMQ for RocketMQ (penyimpanan).
Buat topik dan ID grup.
Dapatkan titik akhir.
Terbitkan dan berlangganan pesan.
Verifikasi konfigurasi Anda.
Buat semua resource sebelum menerbitkan atau berlangganan pesan. Broker ApsaraMQ for MQTT akan menolak koneksi dari klien yang merujuk ke resource yang tidak ada.
Langkah 1: Buat instans ApsaraMQ for MQTT
Instans ApsaraMQ for MQTT adalah gerbang yang mempertahankan koneksi klien dan meneruskan pesan.
Masuk ke Konsol ApsaraMQ for MQTT.
Pada bilah navigasi atas, pilih wilayah, misalnya China (Beijing).
Pada panel navigasi kiri, klik Instances.
Pada halaman Instances, klik Create Instance.
Pilih tipe instans, konfigurasikan spesifikasi, dan selesaikan pembelian.
Perkirakan transaksi per detik (TPS), jumlah koneksi, dan jumlah subscription berdasarkan skenario bisnis Anda. Untuk instansi langganan, spesifikasi yang terlalu kecil dapat memicu pembatasan kecepatan.
Setelah pembelian, instans akan muncul dalam daftar instans pada halaman Instances.
Instans Edisi Dasar langsung aktif. Instans Edisi Platinum memerlukan waktu penerapan. Anda akan diberi notifikasi saat instans tersedia.
Jumlah instans ApsaraMQ for MQTT yang dapat dibuat di setiap wilayah terbatas. Untuk batas spesifiknya, lihat prompt di konsol.
Langkah 2: Buat dan ikatkan instans penyimpanan
Setelah membuat instans ApsaraMQ for MQTT, buat instans ApsaraMQ for RocketMQ untuk penyimpanan dan ikatkan keduanya.
Aturan pengikatan
| Rule | Description |
|---|---|
| One-time binding | Instans ApsaraMQ for MQTT hanya dapat diikatkan satu kali. Instans penyimpanan yang telah diikatkan tidak dapat diubah. |
| One-to-one only | Setiap instans penyimpanan hanya dapat diikatkan ke satu instans ApsaraMQ for MQTT. |
| Same namespace type | Kedua instans harus memiliki tipe namespace yang sama. Instans exclusive-namespace tidak dapat diikatkan ke instans non-exclusive-namespace. |
| Storage dependency | Menghapus instans penyimpanan yang telah diikatkan dapat menyebabkan instans ApsaraMQ for MQTT tidak tersedia. |
Prosedur
Pada panel navigasi kiri, klik Overview. Pilih instans ApsaraMQ for MQTT dan klik Configure Settings.
Pada kotak dialog Message Persistence Settings, atur parameter:
Jika Anda sudah memiliki instans ApsaraMQ for RocketMQ: Pilih Select Existing Instance, klik instans Anda, lalu klik Confirm.
Jika Anda belum memiliki instans ApsaraMQ for RocketMQ, pilih salah satu opsi berikut:
Create Shared Instance: Membuat instans ApsaraMQ for RocketMQ Edisi Standar. Masukkan nama dan deskripsi, lalu klik OK.
Purchase Platinum Instance: Membuat instans ApsaraMQ for RocketMQ Edisi Platinum. Pilih Purchase Platinum Instance dan klik Buy Now. Selesaikan pembelian, lalu kembali dan pilih Select Existing Instance untuk mengikatkannya.
Langkah 3: Buat topik dan ID grup
Buat topik
Topik induk adalah topik tingkat pertama untuk menerbitkan dan berlangganan pesan. Subtopik pada berbagai level dapat ditambahkan langsung dalam kode tanpa membuatnya di konsol.
Karena pengikatan satu-ke-satu antara instans ApsaraMQ for MQTT dan instans penyimpanan ApsaraMQ for RocketMQ-nya, topik dibuat pada instans penyimpanan dan dipetakan ke konsol ApsaraMQ for MQTT. Operasi topik juga dapat dilakukan di konsol ApsaraMQ for RocketMQ.
Jika Anda sudah membuat topik melalui ApsaraMQ for RocketMQ, gunakan langsung. Jika belum:
Pada panel navigasi kiri, klik Message Storage.
Pada halaman Topics, pilih instans ApsaraMQ for MQTT dan klik Create Topic.
Pada kotak dialog Create Topic, masukkan nama topik, pilih tipe pesan, masukkan keterangan, lalu klik OK.
Untuk menerbitkan pesan terurut dari klien ApsaraMQ for MQTT, pilih tipe pesan terurut. Klien ApsaraMQ for MQTT tidak mendukung pesan terurut kuat dalam skenario konsumsi.
Buat ID grup
ID grup mengidentifikasi sekumpulan perangkat dengan fitur yang sama. ID grup dan ID perangkat bersama-sama membentuk client ID. Untuk detailnya, lihat Terms.
Pada panel navigasi kiri, klik Groups.
Pada halaman Groups, pilih instans ApsaraMQ for MQTT dan klik Create Group ID.
Pada kotak dialog Create Group ID, masukkan ID grup dan klik OK.
Setelah dibuat, ID grup akan muncul pada halaman Groups.
Hapus ID grup yang tidak digunakan sesegera mungkin.
ID grup hanya dapat digunakan oleh akun yang membuatnya. ID grup yang dibuat oleh Akun Alibaba Cloud tidak dapat digunakan oleh Pengguna RAM di bawah akun tersebut. Pengguna RAM harus membuat ID grup mereka sendiri.
Langkah 4: Dapatkan titik akhir
Untuk menerbitkan dan berlangganan pesan dengan SDK, tentukan titik akhir instans ApsaraMQ for MQTT. Titik akhir terdiri dari nama domain dan port.
Pada bilah navigasi atas, pilih wilayah tempat instans Anda berada. Pada panel navigasi kiri, klik Instances.
Pada halaman Instances, pilih instans ApsaraMQ for MQTT dan klik tab Instance Information.
Pada bagian Endpoint Information, temukan nama domain titik akhir.
Tipe titik akhir
| Endpoint type | Description | Typical use case |
|---|---|---|
| Public Endpoint | Akses ApsaraMQ for MQTT melalui Internet | Perangkat IoT, aplikasi seluler |
| VPC Endpoint | Akses ApsaraMQ for MQTT dalam virtual private cloud (VPC) | Aplikasi cloud |
Selalu gunakan nama domain, bukan alamat IP. Alamat IP berubah secara dinamis. ApsaraMQ for MQTT tidak bertanggung jawab atas titik kegagalan yang disebabkan oleh:
Penggunaan alamat IP yang menjadi tidak valid setelah pembaruan resolusi nama domain.
Kebijakan firewall yang memblokir alamat IP baru setelah pembaruan resolusi nama domain.
Port yang didukung
| Protocol | Port | Use case |
|---|---|---|
| MQTT on TCP | 1883 | Koneksi perangkat IoT standar |
| SSL | 8883 | Koneksi perangkat IoT terenkripsi |
| WebSocket | 80 | Client berbasis browser |
| WebSocket SSL/TLS | 443 | Client berbasis browser terenkripsi |
| Flash | 843 | Aplikasi Flash lawas |
Gantilah nomor port pada titik akhir sesuai kebutuhan.
ApsaraMQ for MQTT menyediakan enkripsi SSL satu arah. Tidak diperlukan unggahan sertifikat di sisi klien. Sertifikat sisi server dikeluarkan secara otomatis selama handshake permintaan dan diikatkan ke nama domain titik akhir. Enkripsi sertifikat kustom tidak didukung.
Langkah 5: Terbitkan dan berlangganan pesan
Gunakan SDK
Unduh SDK klien. Untuk tautan unduhan dalam berbagai bahasa, lihat Download the SDK. ApsaraMQ for MQTT mendukung protokol MQTT standar. SDK klien MQTT pihak ketiga open source bekerja dengan baik. Jika bahasa Anda tidak tercantum, cari SDK kompatibel MQTT apa pun.
Unduh proyek demo dan tinjau deskripsi parameternya. Jalankan demo untuk menerbitkan dan berlangganan pesan. Untuk tautan unduhan, lihat Demo projects. Pustaka demo mencakup beberapa bahasa utama dan diperbarui dari waktu ke waktu. Jika bahasa Anda belum tersedia, unduh demo Java dan modifikasi sesuai kebutuhan. Demo hanya menunjukkan fungsi dasar. Modifikasi semua parameter untuk lingkungan produksi Anda.
Uji cepat dari konsol
Untuk memverifikasi ketersediaan topik tanpa menulis kode, terbitkan pesan uji dari konsol:
Pada panel navigasi kiri, klik Message Storage.
Pada bagian Topics di halaman Message Storage, temukan topik dan klik Send pada kolom Actions.
Pada kotak dialog Send Message, atur atribut pesan, masukkan konten, lalu klik OK. Konsol akan mengembalikan notifikasi berisi ID pesan.
Catatan penggunaan
Hanya topik dan ID grup pada instans yang sama di wilayah yang sama yang dapat berkomunikasi. Misalnya, jika topik dibuat pada Instans A di wilayah China (Beijing), hanya klien dengan ID grup yang dibuat pada Instans A di wilayah China (Beijing) yang dapat mengakses topik tersebut.
Langkah selanjutnya
Referensi SDK: Integrasikan ApsaraMQ for MQTT dengan SDK berbasis bahasa.
Terms: Subtopik, level QoS, clean session, dan konsep MQTT lainnya.
Demo projects: Contoh implementasi dalam berbagai bahasa pemrograman.