全部产品
Search

搜索本产品

    ApsaraMQ for RocketMQ：Buat sumber daya

    文档中心

    ApsaraMQ for RocketMQ：Buat sumber daya

    更新时间：Jul 02, 2025

    Sebelum menggunakan SDK klien TCP untuk mengirim dan menerima pesan, Anda harus membuat sumber daya yang diperlukan di konsol ApsaraMQ for RocketMQ. Saat menggunakan SDK, konfigurasikan parameter sumber daya berdasarkan informasi yang tersedia.

    Sebelum memulai

    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 terpisah 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).

    • 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.

    • ApsaraMQ for RocketMQ menyediakan titik akhir HTTP dan titik akhir 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.

    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 panel 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 pengenal 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 di lintas instans. Sebagai contoh, Topik A yang dibuat pada Instans A tidak tersedia pada Instans B.

    • Nama setiap 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 panel 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 dibuat dengan mengikuti langkah-langkah pada bagian ini hanya dapat digunakan untuk mengirim dan menerima pesan dari tipe tertentu, bukan jenis pesan lainnya. Untuk informasi lebih lanjut tentang tipe pesan, lihat Tipe 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 di 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. Hal ini tidak memengaruhi pengiriman 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 panel navigasi di sebelah kiri halaman Detail Instans, klik Groups.

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

    3. Di panel Create Group for TCP 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 memperoleh titik akhir yang dapat Anda gunakan untuk mengakses instans. Sebelum Anda mengirim dan menerima pesan, tentukan titik akhir pada klien produsen dan konsumen agar mereka dapat mengakses instans di wilayah tertentu.

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

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

    Sebelum menggunakan titik akhir, perhatikan hal-hal berikut:

    • Setiap jenis titik akhir hanya dapat digunakan oleh klien dengan tipe protokol yang sama. Sebagai contoh, jika Anda ingin menggunakan SDK klien TCP untuk mengirim dan menerima pesan, Anda harus menggunakan titik akhir TCP 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.

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

    Apa yang harus dilakukan selanjutnya

    Panggil SDK Klien TCP untuk Mengirim dan Berlangganan Pesan Normal