ApsaraMQ for RocketMQ：Istilah

Topic

• Topik adalah wadah tingkat atas dalam ApsaraMQ for RocketMQ untuk transmisi dan penyimpanan pesan. Topik digunakan untuk mengidentifikasi pesan-pesan yang termasuk dalam kategori bisnis yang sama. Setiap topik diidentifikasi secara unik berdasarkan namanya. Untuk informasi selengkapnya, lihat Topik.

Lite topic

• Jika sebuah topik bertipe Lite, lite topic dapat dibuat di bawahnya. Wadah penyimpanan pesan diidentifikasi secara unik oleh kombinasi topik dan lite topic tersebut. Secara default, setiap wadah penyimpanan terdiri dari satu antrian. Untuk informasi selengkapnya, lihat Model lite topic.

Jenis pesan

• Jenis pesan adalah klasifikasi pesan dalam ApsaraMQ for RocketMQ berdasarkan karakteristik transmisinya. Jenis pesan digunakan untuk manajemen tipe dan verifikasi keamanan. ApsaraMQ for RocketMQ mendukung pesan normal, pesan terurut, pesan transaksional, serta pesan terjadwal dan tertunda.

Antrian pesan

• Antrian pesan adalah wadah aktual untuk menyimpan dan mentransmisikan pesan dalam ApsaraMQ for RocketMQ. Antrian juga merupakan unit penyimpanan pesan terkecil. Semua topik dalam ApsaraMQ for RocketMQ terdiri dari beberapa antrian. Desain ini memungkinkan pemisahan horizontal antrian dan penyimpanan streaming dalam setiap antrian. Antrian diidentifikasi secara unik berdasarkan QueueId-nya. Untuk informasi selengkapnya, lihat Antrian pesan.

Pesan

• Pesan adalah unit terkecil dalam transmisi data di ApsaraMQ for RocketMQ. Seorang produsen mengemas muatan dan properti tambahan dari data bisnis ke dalam sebuah pesan lalu mengirimkannya ke server ApsaraMQ for RocketMQ. Server kemudian mengirimkan pesan tersebut ke konsumen untuk diproses berdasarkan semantik yang relevan. Untuk informasi selengkapnya, lihat Pesan.

Tampilan pesan

• Tampilan pesan adalah antarmuka read-only yang disediakan oleh ApsaraMQ for RocketMQ dari perspektif pengembang. Tampilan pesan memungkinkan Anda membaca berbagai properti dan muatan pesan, tetapi tidak memungkinkan pengubahan pesan itu sendiri.

Tag pesan

• Tag pesan adalah properti untuk klasifikasi pesan detail halus dalam ApsaraMQ for RocketMQ. Tag memungkinkan sub-kategorisasi pesan di bawah suatu topik. Konsumen dapat menggunakan penyaringan detail halus dengan berlangganan tag tertentu. Untuk informasi selengkapnya, lihat Penyaringan pesan.

Offset pesan

• Pesan disimpan dalam antrian suatu topik sesuai urutan kedatangannya di server ApsaraMQ for RocketMQ. Setiap pesan dalam antrian memiliki koordinat unik bertipe Long. Koordinat ini adalah offset pesan. Untuk informasi selengkapnya, lihat Manajemen progres konsumen.

Offset konsumen

• Sebuah pesan tidak langsung dihapus dari antrian setelah dikonsumsi. Untuk setiap kelompok konsumen, ApsaraMQ for RocketMQ mencatat offset dari pesan yang paling baru dikonsumsi. Offset yang terekam ini disebut offset konsumen. Untuk informasi selengkapnya, lihat Manajemen progres konsumen.

Kunci pesan

• Kunci pesan adalah properti indeks untuk pesan yang disediakan oleh ApsaraMQ for RocketMQ. Dengan menetapkan kunci pesan, Anda dapat dengan cepat menemukan konten pesan yang sesuai.

Produsen

• Produsen adalah entitas yang berjalan dalam sistem ApsaraMQ for RocketMQ yang membangun dan mengirim pesan ke server. Produsen biasanya diintegrasikan ke dalam sistem bisnis. Mereka mengemas data bisnis ke dalam pesan ApsaraMQ for RocketMQ lalu mengirimkannya ke server. Untuk informasi selengkapnya, lihat Produsen.

Pemeriksa transaksi

• Pemeriksa transaksi adalah pendengar yang digunakan oleh produsen dalam ApsaraMQ for RocketMQ untuk melakukan pemeriksaan transaksi lokal dan memulihkan transaksi yang abnormal. Pemeriksa transaksi harus memeriksa dan menentukan resolusi pesan transaksional berdasarkan status data bisnis. Untuk informasi selengkapnya, lihat Pesan transaksional.

Resolusi transaksi

• Resolusi transaksi adalah identifikasi status commit dari pesan transaksional selama proses pengiriman dalam ApsaraMQ for RocketMQ. Server menggunakan resolusi transaksi untuk mengontrol apakah pesan transaksional tersebut di-commit dan dikirimkan. Resolusi transaksi meliputi commit, rollback, dan pending. Untuk informasi selengkapnya, lihat Pesan transaksional.

Kelompok konsumen

• Kelompok konsumen adalah grup penyeimbang beban dalam sistem ApsaraMQ for RocketMQ yang berisi beberapa konsumen dengan perilaku konsumsi yang identik. Berbeda dengan konsumen, kelompok konsumen adalah sumber daya logis, bukan entitas yang berjalan. Di ApsaraMQ for RocketMQ, menginisialisasi beberapa konsumen dalam satu kelompok konsumen mencapai skalabilitas horizontal untuk kinerja konsumsi dan pemulihan bencana berdaya tinggi. Untuk informasi selengkapnya, lihat Kelompok konsumen.

Konsumen

• Konsumen adalah entitas yang berjalan dalam ApsaraMQ for RocketMQ yang menerima dan memproses pesan. Konsumen biasanya diintegrasikan ke dalam sistem bisnis. Mereka mengambil pesan dari server ApsaraMQ for RocketMQ dan mengubahnya menjadi informasi yang dapat dipahami oleh bisnis untuk diproses oleh logika bisnis. Untuk informasi selengkapnya, lihat Konsumen.

Hasil konsumsi

• Hasil konsumsi dikembalikan oleh pendengar PushConsumer dalam ApsaraMQ for RocketMQ setelah selesai memproses sebuah pesan. Hasil ini menunjukkan apakah pesan telah diproses dengan benar. Hasil konsumsi meliputi sukses dan gagal.

Langganan

• Langganan adalah aturan dan konfigurasi status mengenai cara konsumen mengambil dan memproses pesan dalam sistem ApsaraMQ for RocketMQ. Langganan didaftarkan secara dinamis oleh kelompok konsumen ke server. Selama transmisi pesan berikutnya, aturan penyaringan yang ditentukan dalam langganan digunakan untuk pencocokan pesan dan pemeliharaan progres konsumen. Untuk informasi selengkapnya, lihat Langganan.

Penyaringan pesan

• Konsumen dapat menyaring pesan dengan berlangganan tag pesan tertentu (Tags) untuk memastikan hanya menerima kumpulan pesan yang telah difilter. Perhitungan dan pencocokan aturan penyaringan dilakukan di server ApsaraMQ for RocketMQ. Untuk informasi selengkapnya, lihat Penyaringan pesan.

Pengaturan ulang offset konsumen

• Fitur ini mengatur ulang progres konsumsi kelompok konsumen untuk topik yang dilanggannya ke titik waktu tertentu. Setelah pengaturan ulang, konsumen akan menerima pesan yang dikirim oleh produsen ke server ApsaraMQ for RocketMQ setelah titik waktu yang ditentukan. Untuk informasi selengkapnya, lihat Atur ulang offset konsumen.

Jejak pesan

• Jejak pesan menyediakan informasi lengkap mengenai alur sebuah pesan. Informasi ini dikumpulkan dari data seperti waktu dan lokasi dari setiap node terkait saat pesan berpindah dari produsen ke konsumen. Jejak pesan memungkinkan Anda melihat dengan jelas seluruh jalur pesan mulai dari produsen, melalui server ApsaraMQ for RocketMQ, hingga ke konsumen. Hal ini membantu dalam pemecahan masalah dan diagnosis gangguan.

Akumulasi pesan

• Akumulasi pesan terjadi ketika produsen mengirim pesan ke server ApsaraMQ for RocketMQ lebih cepat daripada kecepatan konsumen memprosesnya. Pesan yang belum dikonsumsi disimpan di server ApsaraMQ for RocketMQ.

Pesan transaksional

• Pesan transaksional adalah jenis pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Pesan ini menjamin konsistensi akhir antara produksi pesan dan transaksi lokal dalam skenario terdistribusi.

Pesan terjadwal dan tertunda

• Pesan terjadwal dan tertunda adalah jenis pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Setelah pesan dikirim ke server, pesan tersebut hanya dapat dikonsumsi oleh konsumen setelah waktu tertentu. Dengan menetapkan waktu tunda tertentu, Anda dapat mencapai efek penjadwalan dan pemicuan tertunda dalam skenario terdistribusi.

Pesan terurut

• Pesan terurut adalah jenis pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Pesan ini menjamin bahwa konsumen menerima pesan dalam urutan yang sama seperti saat dikirim. Hal ini memungkinkan pemrosesan berurutan dalam skenario bisnis.

Pesan lite

• Pesan lite adalah jenis pesan lanjutan yang disediakan oleh ApsaraMQ for RocketMQ. Pesan ini mendukung pembuatan dinamis jutaan lite topic serta menyediakan fitur seperti manajemen siklus hidup otomatis dan langganan berkinerja tinggi. Untuk informasi selengkapnya, lihat Model lite topic.