全部产品
Search

搜索本产品

    ApsaraMQ for RocketMQ：Buat sumber daya

    文档中心

    ApsaraMQ for RocketMQ：Buat sumber daya

    更新时间：Jul 02, 2025

    Sebelum menggunakan SDK HTTP untuk mengirim dan menerima pesan, Anda harus membuat sumber daya yang diperlukan di konsol ApsaraMQ for RocketMQ.

    Sebelum Anda mulai

    Aktifkan ApsaraMQ for RocketMQ dan berikan izin kepada pengguna RAM.

    Informasi latar belakang

    ApsaraMQ for RocketMQ menyediakan SDK untuk berbagai bahasa pemrograman guna mengirim dan menerima pesan melalui protokol TCP dan HTTP. Kami menyarankan Anda membuat grup yang berbeda untuk setiap protokol. Untuk informasi lebih lanjut tentang batasan penggunaan grup per protokol, lihat Kelola Grup.

    Batasan akses jaringan

    Sebelum menggunakan ApsaraMQ for RocketMQ, perhatikan batasan akses jaringan berikut:

    • Topik hanya dapat diakses oleh produsen atau konsumen dalam grup jika grup tersebut dibuat pada instans yang sama dan di wilayah yang sama dengan topik tersebut. Sebagai contoh, jika Anda membuat topik pada Instans A di wilayah China (Hangzhou), topik tersebut hanya dapat diakses oleh produsen atau konsumen dalam grup yang dibuat pada Instans A di wilayah China (Hangzhou).

    • ApsaraMQ for RocketMQ menyediakan titik akhir HTTP dan TCP. Setiap jenis titik akhir hanya dapat digunakan oleh klien dengan tipe protokol yang sama. Sebagai contoh, jika Anda menggunakan SDK klien TCP, Anda hanya dapat menentukan titik akhir TCP dalam kode.

    • Titik akhir publik dan pribadi untuk klien TCP dan HTTP disediakan di semua wilayah. Dalam lingkungan produksi, kami menyarankan Anda mengakses ApsaraMQ for RocketMQ di virtual private cloud (VPC). Jika Anda ingin mengakses ApsaraMQ for RocketMQ lintas wilayah, dari pusat data lokal, atau melalui Internet saat Cloud Enterprise Network (CEN) tidak tersedia, Anda dapat menggunakan titik akhir publik untuk mengakses instans ApsaraMQ for RocketMQ. Jika Anda menggunakan titik akhir publik untuk mengakses instans ApsaraMQ for RocketMQ, Anda akan dikenakan biaya untuk lalu lintas Internet keluar. Untuk informasi lebih lanjut, lihat Penagihan Lalu Lintas Internet.

    Buat instans

    Dalam ApsaraMQ for RocketMQ, instans adalah mesin virtual yang digunakan untuk menyimpan informasi tentang topik dan grup. Untuk membuat instans ApsaraMQ for RocketMQ, ikuti langkah-langkah berikut:

    1. Masuk ke Konsol ApsaraMQ for RocketMQ.

    2. Di bilah navigasi di sebelah kiri, klik Instances.

    3. Di bilah navigasi atas, pilih wilayah, seperti China (Hangzhou).

    4. Pada halaman Instances, klik Create Instance.

    5. Di panel Create Message Queue for Apache RocketMQ Instance, konfigurasikan parameter Instance Type, Name, dan Description. Lalu, klik OK.

    Buat topik

    Dalam ApsaraMQ for RocketMQ, topik adalah pengidentifikasi tingkat pertama yang digunakan untuk mengklasifikasikan pesan. Sebagai contoh, Anda dapat membuat topik bernama Topic_Trade untuk mengidentifikasi pesan transaksional. Kemudian, produsen pesan dapat mempublikasikan pesan ke Topic_Trade dan konsumen pesan dapat berlangganan ke Topic_Trade untuk mengonsumsi pesan tersebut. Topik harus memenuhi persyaratan berikut:

    • Topik tidak dapat digunakan lintas instans. Sebagai contoh, Topik A yang dibuat pada Instans A tidak tersedia pada Instans B.

    • Setiap nama topik harus unik pada sebuah instans.

    • Kami menyarankan Anda membuat topik yang berbeda untuk mengirim jenis pesan yang berbeda. Sebagai contoh, Anda dapat membuat Topik A untuk pesan normal, Topik B untuk pesan transaksional, dan Topik C untuk pesan terjadwal dan tertunda.

    1. Di bilah navigasi di sebelah kiri halaman Detail Instans, klik Topics.

    2. Pada halaman Topics, klik Create Topic.

    3. Di panel Create Topic, konfigurasikan parameter Name dan Description, atur parameter Message Type ke Normal Message, lalu klik OK.

      Catatan

      Dalam contoh berikut, pesan normal digunakan. Topik yang Anda buat dengan melakukan langkah-langkah yang dijelaskan dalam bagian ini tidak dapat digunakan untuk mengirim atau menerima pesan dari jenis lain. Setiap topik hanya dapat digunakan untuk mengirim dan menerima pesan dari jenis tertentu. Untuk informasi tentang jenis pesan, lihat Jenis Pesan.

    Buat grup

    Dalam ApsaraMQ for RocketMQ, grup digunakan untuk mengidentifikasi produsen atau konsumen dengan tipe yang sama. Grup harus memenuhi persyaratan berikut:

    • Hingga 1.000 grup dapat dibuat pada instans ApsaraMQ for RocketMQ. Kami menyarankan Anda menggunakan kembali grup atau menghapus grup yang tidak lagi diperlukan sesegera mungkin. Jika Anda ingin meningkatkan batas maksimum grup, hubungi dukungan teknis ApsaraMQ for RocketMQ.

    • Grup tidak dapat digunakan lintas instans. Sebagai contoh, grup yang dibuat pada Instans A tidak dapat digunakan pada Instans B.

    • Dalam ApsaraMQ for RocketMQ, konsumen dapat mengonsumsi pesan melalui protokol HTTP atau TCP. Grup konsumen yang berbeda dapat menggunakan protokol yang berbeda. Kami menyarankan Anda menentukan protokol yang sama untuk semua konsumen dalam grup.

      • Jika konsumen dalam grup yang sama mengonsumsi pesan melalui protokol yang berbeda, konsumsi pesan mungkin gagal dan duplikasi pesan atau hilangnya pesan mungkin terjadi.

      • Sekitar 1 hingga 2 jam diperlukan untuk mengubah protokol yang digunakan oleh konsumen dalam grup untuk mengonsumsi pesan.

      • Jika konsumen dalam grup mengonsumsi pesan melalui protokol yang berbeda dari protokol yang ditampilkan di konsol ApsaraMQ for RocketMQ, data yang ditampilkan di konsol mungkin tidak akurat. Ini tidak memengaruhi pesan grup. Dalam kasus ini, Anda dapat menghubungi dukungan teknis ApsaraMQ for RocketMQ untuk mengubah protokol yang ditampilkan di konsol menjadi protokol yang digunakan oleh konsumen dalam grup.

    • ID grup harus ditentukan untuk setiap konsumen. Anda tidak perlu menentukan ID grup untuk setiap produsen.

    1. Di bilah navigasi di sebelah kiri halaman Detail Instans, klik Groups.

    2. Pada halaman Groups, pilih HTTP > Create Group.

    3. Di panel Create Group for HTTP Protocol, konfigurasikan parameter Group ID dan Description. Lalu, klik OK.

    Peroleh titik akhir

    Setelah Anda membuat sumber daya di konsol ApsaraMQ for RocketMQ, Anda harus mendapatkan titik akhir yang dapat Anda gunakan untuk mengakses instans. Sebelum Anda mengirim dan menerima pesan, Anda harus menentukan titik akhir pada klien produsen dan konsumen untuk memungkinkan produsen dan konsumen mengakses instans di wilayah tertentu.

    1. Di bilah navigasi di sebelah kiri halaman Detail Instans, klik Instance Details.

    2. Di bagian HTTP Endpoint pada halaman Instance Details, gerakkan penunjuk ke titik akhir dan klik titik akhir untuk menyalinnya.

    Sebelum menggunakan titik akhir, perhatikan item berikut:

    • Setiap jenis titik akhir hanya dapat digunakan oleh klien dengan tipe protokol yang sama. Sebagai contoh, jika Anda ingin menggunakan SDK klien HTTP untuk mengirim dan menerima pesan, Anda harus menggunakan titik akhir HTTP dari instans ApsaraMQ for RocketMQ Anda untuk mengakses broker ApsaraMQ for RocketMQ.

    • Titik akhir publik dan pribadi untuk klien TCP dan HTTP disediakan di semua wilayah. Dalam lingkungan produksi, kami menyarankan Anda mengakses ApsaraMQ for RocketMQ di virtual private cloud (VPC). Jika Anda ingin mengakses ApsaraMQ for RocketMQ lintas wilayah, dari pusat data lokal, atau melalui Internet saat Cloud Enterprise Network (CEN) tidak tersedia, Anda dapat menggunakan titik akhir publik untuk mengakses instans ApsaraMQ for RocketMQ. Jika Anda menggunakan titik akhir publik untuk mengakses instans ApsaraMQ for RocketMQ, Anda akan dikenakan biaya untuk lalu lintas Internet keluar. Untuk informasi lebih lanjut, lihat Penagihan Lalu Lintas Internet.

    • Titik akhir HTTP yang ditampilkan di konsol ApsaraMQ for RocketMQ adalah titik akhir wilayah tertentu. Sebelum Anda mengirim dan menerima pesan, Anda harus menentukan ID instans.

    Setelah Anda menyelesaikan operasi sebelumnya, Anda dapat menjalankan kode sampel dan menggunakan ApsaraMQ for RocketMQ untuk mengirim dan menerima pesan.

    Apa yang harus dilakukan selanjutnya

    Gunakan SDK Klien HTTP untuk Mengirim dan Berlangganan Pesan Normal.