Glosarium ini mendefinisikan konsep inti dalam ApsaraMQ for RocketMQ. Istilah dikelompokkan berdasarkan fungsinya: cara pesan disusun, cara diproduksi dan dikonsumsi, serta cara dikelola dan dipantau.
Pesan
Topik
Topik adalah klasifikasi utama untuk pesan. Produsen mengirim pesan ke topik, dan konsumen berlangganan topik tersebut untuk menerimanya. Setiap topik berisi satu atau lebih antrian pesan (partisi).
Untuk panduan tentang penyusunan topik, lihat Best practices of topics and tags.
Tag
Tag adalah klasifikasi sekunder yang mengkategorikan pesan dalam suatu topik. Jika topik menentukan kategori pesan secara umum, tag memungkinkan konsumen menyaring subset pesan tertentu dalam topik tersebut.
Untuk panduan penggunaan tag bersama topik, lihat Best practices of topics and tags.
Pesan
Pesan adalah unit dasar transfer data dalam ApsaraMQ for RocketMQ. Setiap pesan termasuk dalam suatu topik dan dapat secara opsional membawa tag.
Message ID
Identifier unik global yang secara otomatis diberikan oleh ApsaraMQ for RocketMQ kepada setiap pesan. Gunakan Message ID untuk melacak dan melakukan kueri terhadap pesan individual.
Message key
Identifier tingkat bisnis yang ditetapkan oleh produsen untuk mengaitkan pesan dengan logika bisnis tertentu. Berbeda dengan Message ID (dihasilkan sistem), message key ditentukan oleh aplikasi dan membantu menemukan pesan yang terkait dengan operasi bisnis tertentu.
Message queue
Juga dikenal sebagai topic partition. Message queue adalah partisi fisik dalam suatu topik. Setiap topik berisi satu atau lebih antrian, yang ditetapkan secara otomatis saat topik dibuat. Jumlah antrian dalam suatu topik tidak dapat diubah setelah pembuatan.
Produsen
Produsen
Entitas (juga disebut penerbit pesan) yang membuat dan mengirim pesan ke ApsaraMQ for RocketMQ.
Producer instance
Proses client produsen. Instance produsen yang berbeda dapat berjalan dalam proses terpisah atau pada mesin yang berbeda. Instance produsen bersifat thread-safe—satu instance dapat menjalankan beberapa thread dalam proses yang sama.
Konsumen
Konsumen
Entitas (juga disebut subscriber pesan) yang menerima dan memproses pesan dari ApsaraMQ for RocketMQ. ApsaraMQ for RocketMQ mendukung dua tipe konsumen:
| Consumer type | Behavior |
|---|---|
| Push consumer | Broker mendorong pesan ke konsumen. |
| Pull consumer | Konsumen secara aktif menarik pesan dari broker. Hanya SDK TCP untuk Java yang mendukung tipe konsumen ini. |
Pull consumer memerlukan instans Enterprise Platinum Edition. Untuk detailnya, lihat Methods and parameters dan Subscribe to messages.
Consumer instance
Proses client konsumen. Instance konsumen yang berbeda dapat berjalan dalam proses terpisah atau pada mesin yang berbeda. Setiap instance konsumen menggunakan kolam thread untuk memproses pesan.
Consumer offset
Consumer offset melacak sejauh mana pull consumer telah membaca melalui suatu partisi. Pull consumer mengonsumsi pesan dalam partisi secara berurutan. Setiap partisi memiliki penanda offset berikut:
MaxOffset: Jumlah total pesan dalam partisi.
MinOffset: Titik awal partisi.
ConsumerOffset: Jumlah pesan yang telah dikonsumsi.
Jumlah pesan yang belum dikonsumsi (terakumulasi) sama dengan MaxOffset dikurangi ConsumerOffset.
Group
Kumpulan logis produsen atau konsumen. Semua client dalam satu group memproduksi atau mengonsumsi jenis pesan yang sama dan mengikuti logika publish/subscribe yang sama.
Group ID
Identifier unik untuk suatu group.
Mode konsumsi
ApsaraMQ for RocketMQ mendukung dua mode konsumsi. Perbedaannya terletak pada apakah setiap pesan dikirimkan ke satu konsumen atau ke semua konsumen dalam suatu group.
| Mode | Delivery behavior | Contoh (9 pesan, 3 konsumen) |
|---|---|---|
| Clustering consumption | Pesan didistribusikan secara merata ke seluruh konsumen dalam group. Setiap pesan hanya dikirim ke satu konsumen. | Setiap konsumen memproses 3 pesan. |
| Broadcasting consumption | Setiap konsumen dalam group menerima setiap pesan. | Setiap konsumen memproses semua 9 pesan. |
Untuk detailnya, lihat Clustering consumption and broadcasting consumption.
Tipe pesan
Scheduled message
Pesan yang dikirimkan ke konsumen pada waktu tertentu. Broker menyimpan pesan tersebut hingga waktu pengiriman yang dijadwalkan tiba.
Untuk detailnya, lihat Scheduled messages and delayed messages.
Delayed message
Pesan yang dikirimkan ke konsumen setelah periode penundaan tertentu. Berbeda dengan scheduled message (dikirim pada waktu tetap), delayed message dikirim setelah interval waktu relatif sejak pesan dikirim.
Untuk detailnya, lihat Scheduled messages and delayed messages.
Transactional message
Pesan yang berpartisipasi dalam transaksi terdistribusi. ApsaraMQ for RocketMQ menyediakan mekanisme transaksi terdistribusi yang mirip dengan X/Open XA (eXtended Architecture) untuk memastikan konsistensi akhir dalam transaksi terdistribusi.
Untuk detailnya, lihat Transactional messages.
Ordered message
Pesan yang dipublikasikan dan dikonsumsi dalam urutan first-in, first-out (FIFO) yang ketat.
Untuk detailnya, lihat Ordered messages.
Partitionally ordered message
Pesan yang diurutkan dalam partisi tertentu, bukan di seluruh topik. ApsaraMQ for RocketMQ menggunakan sharding key untuk menetapkan pesan ke partisi. Pesan yang memiliki sharding key yang sama dipublikasikan dan dikonsumsi dalam urutan FIFO yang ketat dalam partisinya.
Sharding key tidak dapat digunakan sebagai message key.
Untuk detailnya, lihat Ordered messages.
Operasi dan pemantauan
Message accumulation
Message accumulation terjadi ketika konsumen tidak mampu mengimbangi laju pengiriman pesan oleh produsen. Pesan yang belum dikonsumsi menumpuk di broker.
Pesan terakumulasi = Inflight messages + Ready messages
Inflight messages: Pesan yang sedang diproses oleh konsumen tetapi belum diakui (acknowledged).
Ready messages: Pesan yang tersedia untuk dikonsumsi tetapi belum dikirimkan.
Message filtering
Mekanisme di sisi broker yang memungkinkan konsumen hanya menerima pesan yang sesuai dengan tag tertentu. Karena filtering berjalan di broker, pesan yang tidak relevan tidak pernah dikirimkan ke konsumen.
Untuk detailnya, lihat Message filtering.
Message trace
Catatan lengkap mengenai siklus hidup pesan, mulai dari saat produsen mempublikasikannya hingga saat konsumen memprosesnya. Setiap jejak mencakup cap waktu dan lokasi sepanjang rute lengkap: produsen, broker, dan konsumen. Gunakan message trace untuk mendiagnosis masalah pengiriman dan memverifikasi alur pesan.
Untuk detailnya, lihat Query message traces.
Consumer offset resetting
Mengatur ulang progres konsumsi kelompok konsumen ke titik waktu tertentu. Setelah diatur ulang, konsumen membaca ulang semua pesan yang dikirim setelah cap waktu yang ditentukan. Rentang pengaturan ulang dibatasi oleh jendela Penyimpanan persisten, yang secara default adalah tiga hari.
Untuk detailnya, lihat Reset consumer offsets.
Dead-letter queue
Antrian khusus yang menyimpan pesan yang tidak dapat dikonsumsi secara berhasil. Ketika suatu pesan gagal dikonsumsi, ApsaraMQ for RocketMQ secara otomatis mencoba mengirim ulang. Jika pesan tersebut tetap gagal setelah mencapai jumlah maksimum percobaan, pesan tersebut menjadi dead-letter message dan dipindahkan ke dead-letter queue yang terkait dengan kelompok konsumen tersebut, bukan dibuang.
Untuk detailnya, lihat Dead-letter queues.