Sebelum menggunakan SDK untuk mengirim dan menerima pesan, Anda harus membuat resource berikut di ApsaraMQ for RocketMQ:
Instance — layanan perpesanan terkelola dengan metode penagihan dan konfigurasi jaringan yang Anda pilih.
Topic — channel tempat pesan dikirim dan diterima.
Consumer group — pengelompokan logis consumer yang berlangganan ke topik.
Setelah membuat resource tersebut, Anda akan mendapatkan titik akhir instans dan kredensial untuk digunakan dalam kode SDK Anda.
Prasyarat
Sebelum memulai, selesaikan tugas-tugas berikut:
Batasan
Wilayah: Instans ApsaraMQ for RocketMQ harus berada di wilayah yang sama dengan VPC dan vSwitch yang Anda buat di bagian "Prasyarat".
Konvensi penamaan: Untuk informasi tentang konvensi penamaan instans, topik, dan kelompok konsumen ApsaraMQ for RocketMQ, lihat Kuota dan batasan.
Jenis pesan topik: Jenis pesan suatu topik harus konsisten dengan jenis pesan yang dikirim dan diterima melalui topik tersebut. Misalnya, jika Anda membuat topik untuk mengirim dan menerima pesan normal, Anda hanya dapat menggunakannya untuk pesan normal. Untuk informasi selengkapnya, lihat Catatan penggunaan.
Informasi latar belakang
ApsaraMQ for RocketMQ memungkinkan Anda membuat resource melalui Konsol ApsaraMQ for RocketMQ atau dengan memanggil operasi API. Topik ini menjelaskan cara membuat resource melalui Konsol ApsaraMQ for RocketMQ.
Jika Anda ingin membuat resource dengan memanggil operasi API, lihat topik-topik berikut:
Buat Instans
Masuk ke Konsol ApsaraMQ for RocketMQ. Di panel navigasi sebelah kiri, klik Instances.
Di bilah navigasi atas, pilih wilayah, misalnya China (Hangzhou).
Pada halaman Instances, klik Create Instance. Di panel Create Message Queue for Apache RocketMQ Instance, atur parameter Instance Version ke V5.0 dan konfigurasikan parameter Billing Method. Kemudian, klik OK. ApsaraMQ for RocketMQ mendukung metode penagihan berikut: Untuk informasi tentang item yang dapat ditagih dan skenario metode penagihan yang berbeda, lihat Ringkasan penagihan.
Instans ApsaraMQ for RocketMQ arsitektur tanpa server hanya tersedia di wilayah-wilayah berikut: China (Hangzhou), China (Shanghai), China (Beijing), China (Zhangjiakou), China (Shenzhen), China (Chengdu), Singapura, Jerman (Frankfurt), dan AS (Virginia).
Billing method Cara penagihan Subscription Diperlukan pembayaran di muka berdasarkan spesifikasi komputasi dan durasi langganan (dalam bulan) yang Anda pilih untuk instans. Pay-as-you-go Biaya dibayar setelah pemakaian berdasarkan spesifikasi komputasi yang Anda pilih untuk instans dan durasi penggunaan aktual (dalam jam) instans tersebut. Serverless Anda dikenai biaya berdasarkan jumlah total panggilan API yang dilakukan untuk menerima dan mengirimkan pesan. Di halaman pembelian, pilih spesifikasi instans dan klik Buy Now. Kemudian, ikuti petunjuk di layar untuk menyelesaikan pembayaran. Tabel berikut memberikan contoh cara mengonfigurasi parameter di halaman pembelian. Untuk informasi tentang spesifikasi yang ditampilkan di halaman pembelian, lihat Pemilihan instans.
PentingSetelah membuat instans ApsaraMQ for RocketMQ, Anda tidak dapat mengubah VPC atau vSwitch tempat instans tersebut ditempatkan. Jika ingin mengubah VPC atau vSwitch, Anda harus merilis instans tersebut dan membeli instans baru.
Parameter yang dikonfigurasi untuk instans serverless
| Parameter | Contoh | Deskripsi |
|---|---|---|
| Primary Edition | Standard Edition | -- |
| Billing Method | Pay-by-Request | Secara otomatis ditentukan. |
| Message Storage Capacity | -- | Anda tidak perlu menentukan kapasitas penyimpanan. Anda dikenai biaya untuk storage space berdasarkan penggunaan aktual. |
| VPC ID | *vpc-bp1cg09dua6sgh0\*\*\*\*\*\** | ID VPC yang Anda buat di bagian "Prasyarat" topik ini. |
| VSwitch ID | *vsw-bp1vqb0p9nz3irz\*\*\*\*\*\** | ID vSwitch yang Anda buat di bagian "Prasyarat" topik ini. Anda harus memilih dua ID vSwitch untuk instans ApsaraMQ for RocketMQ arsitektur tanpa server. |
| Internet Access | Disable | Dalam contoh ini, client terhubung ke broker ApsaraMQ for RocketMQ di dalam VPC. Secara default, akses Internet dinonaktifkan. Jika ingin mengakses ApsaraMQ for RocketMQ melalui Internet, atur parameter ini ke Enable. |
| Internal Network Metering Method | Pay-by-Traffic | Secara otomatis ditentukan. Anda hanya dapat mengakses instans ApsaraMQ for RocketMQ arsitektur tanpa server di dalam VPC. |
| Resource Group | Default resource group | Kelompok sumber daya tempat instans ApsaraMQ for RocketMQ arsitektur tanpa server tersebut berada. |
| Security Group | -- | Security group yang Anda buat di bagian "Prasyarat" topik ini. |
Parameter yang dikonfigurasi untuk instans subscription atau pay-as-you-go
| Parameter | Contoh | Deskripsi |
|---|---|---|
| Primary Edition | Standard Edition | -- |
| Sub-category Edition | High-availability Cluster Edition (Direkomendasikan untuk Lingkungan Produksi) | -- |
| Computing Specification | rmq.s2.2xlarge | -- |
| VPC ID | *vpc-bp1cg09dua6sgh0\*\*\*\*\*\** | ID VPC yang Anda buat di bagian "Prasyarat" topik ini. |
| VSwitch ID | *vsw-bp1vqb0p9nz3irz\*\*\*\*\*\** | ID vSwitch yang Anda buat di bagian "Prasyarat" topik ini. |
| Internet Access | Disable | Dalam contoh ini, client terhubung ke broker ApsaraMQ for RocketMQ di dalam VPC. Secara default, akses Internet dinonaktifkan. Jika ingin mengakses ApsaraMQ for RocketMQ melalui Internet, atur parameter ini ke Enable. |
| Resource Group | Default resource group | Kelompok sumber daya tempat instans ApsaraMQ for RocketMQ tersebut berada. |
| Disk Encryption | Disable | Fitur enkripsi disk hanya didukung untuk instans ApsaraMQ for RocketMQ Edisi Platinum Enterprise versi 5.x. |
| Disk Encryption Key | key-hzz66c8207\*\*\*\* | ID kunci yang digunakan untuk enkripsi disk di wilayah tempat instans tersebut ditempatkan. Parameter ini wajib diisi hanya jika Anda mengatur parameter Disk Encryption ke Enable. |
Setelah instans dibuat, pastikan instans tersebut muncul di halaman Instances dan statusnya adalah Running.
Buat topik
Di halaman Instances, klik nama instans yang ingin Anda kelola.
Di panel navigasi sebelah kiri, klik Topics. Di halaman Topics yang muncul, klik Create Topic.
Di panel Create Topic, masukkan nama dan deskripsi topik, atur parameter Message Type ke Normal Message, lalu klik OK.
Setelah topik dibuat, pastikan topik tersebut muncul di daftar topik.
Buat kelompok konsumen
Di halaman Instances, klik nama instans yang ingin Anda kelola.
Di panel navigasi sebelah kiri, klik Groups. Di halaman Groups yang muncul, klik Create Group.
Di panel Create Group, konfigurasikan parameter Group ID dan klik OK. Anda dapat menggunakan nilai default untuk parameter lain di panel tersebut.
Setelah kelompok konsumen dibuat, pastikan kelompok tersebut muncul di daftar kelompok.
Dapatkan titik akhir instans
Anda memerlukan titik akhir instans untuk menghubungkan client Anda. Untuk mendapatkannya:
Di halaman Instances, klik nama instans yang ingin Anda kelola.
Di bagian TCP Endpoint halaman Instance Details, lihat titik akhir instans tersebut.
VPC endpoint: Titik akhir yang digunakan untuk mengakses instans ApsaraMQ for RocketMQ di dalam VPC. Ini adalah titik akhir default yang disediakan oleh ApsaraMQ for RocketMQ.
Public endpoint: Titik akhir yang digunakan untuk mengakses ApsaraMQ for RocketMQ melalui Internet. Titik akhir publik hanya ditampilkan jika Anda mengaktifkan akses Internet.
Dapatkan username dan password instans
Dalam contoh ini, Intelligent Authentication digunakan untuk menjelaskan cara mendapatkan username dan password instans ApsaraMQ for RocketMQ. Jika ingin menggunakan autentikasi berbasis access control list (ACL), Anda harus membuat pengguna ACL, memberikan izin yang diperlukan kepada pengguna ACL tersebut, dan mendapatkan username serta password pengguna ACL tersebut. Untuk informasi selengkapnya, lihat Autentikasi pengguna.
Saat menghubungkan client ke broker ApsaraMQ for RocketMQ, apakah Anda perlu menentukan username dan password instans tergantung pada metode akses:
Jika Anda mengakses broker ApsaraMQ for RocketMQ melalui Internet, Anda harus menentukan username dan password instans.
Jika Anda mengakses broker ApsaraMQ for RocketMQ di dalam VPC, Anda hanya perlu menentukan username dan password jika instans tersebut merupakan instans arsitektur tanpa server dan fitur bebas autentikasi di VPC dinonaktifkan untuk instans tersebut. Dalam kasus lain, sistem secara otomatis mengenali client berdasarkan titik akhir VPC yang digunakan client tersebut.
Untuk mendapatkan kredensial:
Di halaman Instances, klik nama instans yang ingin Anda kelola.
Di panel navigasi sebelah kiri halaman yang muncul, klik Access Control.
Klik tab Intelligent Authentication untuk melihat username dan password instans.
Langkah selanjutnya
Anda telah membuat semua resource yang diperlukan untuk mengirim dan menerima pesan. Lanjutkan ke langkah berikutnya: