ApsaraMQ for RocketMQ：Istilah

topik

• Topik digunakan untuk mengklasifikasikan pesan. Topik adalah pengklasifikasi utama dari pesan. Untuk informasi lebih lanjut, lihat Praktik terbaik topik dan tag.

pesan

• Dalam ApsaraMQ for RocketMQ, pesan adalah pembawa yang digunakan untuk mentransfer informasi.

ID pesan

• ID Pesan adalah pengenal unik global dari sebuah pesan. ID Pesan secara otomatis dibuat oleh ApsaraMQ for RocketMQ.

kunci pesan

• Kunci pesan adalah pengenal unik yang digunakan untuk mengidentifikasi logika bisnis dari sebuah pesan. Kunci pesan ditentukan oleh produsen pesan.

tag

• Tag digunakan untuk mengklasifikasikan lebih lanjut pesan di dalam sebuah topik. Tag adalah pengklasifikasi sekunder dari pesan. Untuk informasi lebih lanjut, lihat Praktik terbaik topik dan tag.

produser

• Produser, juga dikenal sebagai penerbit pesan, memproduksi dan mengirimkan pesan.

instansi produser

• Instansi produser merujuk pada klien produser. Instansi produser yang berbeda dapat berjalan di proses yang berbeda atau pada mesin yang berbeda. Instansi produser bersifat thread-safe. Sebuah instansi produser dapat menjalankan beberapa thread dalam proses yang sama.

konsumen

• Konsumen, juga dikenal sebagai pelanggan pesan, menerima dan mengonsumsi pesan. Dalam ApsaraMQ for RocketMQ, konsumen dapat dibagi menjadi jenis-jenis berikut:

  • Konsumen dorong: ApsaraMQ for RocketMQ mendorong pesan ke konsumen tipe ini.

  • Konsumen Tarik: Konsumen tipe ini secara aktif menarik pesan dari ApsaraMQ for RocketMQ. Hanya TCP SDK untuk Java yang mendukung jenis konsumen ini.

    Penting

    Jika Anda ingin menggunakan konsumen tarik, pastikan bahwa instansi ApsaraMQ for RocketMQ Anda merupakan Edisi Platinum Perusahaan.

  Untuk informasi lebih lanjut, lihat Metode dan parameter dan Berlangganan pesan.

offset konsumen

• Sebuah topik dapat berisi beberapa partisi. Jumlah total pesan dalam sebuah partisi dikenal sebagai offset maksimum (MaxOffset). Titik awal sebuah partisi dikenal sebagai offset minimum (MinOffset).

  Dalam ApsaraMQ for RocketMQ, konsumen tarik mengonsumsi pesan dalam sebuah partisi secara berurutan dan mencatat jumlah pesan yang dikonsumsi, yang dikenal sebagai offset konsumen. Jumlah pesan yang belum dikonsumsi (akumulasi pesan) dalam sebuah partisi adalah selisih antara offset maksimum (MaxOffset) dan offset konsumen (ConsumerOffset).

instansi konsumen

• Instansi konsumen merujuk pada klien konsumen. Instansi konsumen yang berbeda dapat berjalan di proses yang berbeda atau pada mesin yang berbeda. Sebuah instansi konsumen menggunakan kolam thread untuk mengonsumsi pesan.

grup

• Grup produser atau konsumen. Klien dalam grup produser atau konsumen memproduksi atau mengonsumsi pesan dengan tipe yang sama dan menerbitkan atau berlangganan pesan berdasarkan logika yang sama.

ID grup

• ID Grup digunakan untuk mengidentifikasi sebuah grup.

antrian pesan

• Juga dikenal sebagai partisi topik. Partisi topik adalah partisi fisik. Sebuah topik dapat berisi satu atau lebih antrian. Saat Anda membuat topik, sistem secara otomatis menetapkan antrian tersebut. Anda tidak dapat mengubah jumlah antrian dalam sebuah topik.

konsumsi klustering

• Dalam mode konsumsi klustering, sistem mendistribusikan pesan dalam sebuah topik secara merata kepada konsumen dalam grup konsumen. Misalnya, sebuah topik berisi sembilan pesan, dan sebuah grup konsumen berisi tiga konsumen. Dalam mode ini, setiap konsumen mengonsumsi tiga pesan. Untuk informasi lebih lanjut, lihat Konsumsi klustering dan konsumsi siaran.

konsumsi siaran

• Dalam mode konsumsi siaran, setiap konsumen dalam grup konsumen mengonsumsi setiap pesan dalam topik yang disubskripsikan oleh grup konsumen tersebut. Misalnya, sebuah topik berisi sembilan pesan, dan sebuah grup konsumen berisi tiga konsumen. Dalam mode ini, setiap konsumen mengonsumsi sembilan pesan. Untuk informasi lebih lanjut, lihat Konsumsi klustering dan konsumsi siaran.

pesan terjadwal

• Pesan terjadwal adalah pesan yang dikirim oleh broker ApsaraMQ for RocketMQ kepada konsumen pada titik waktu tertentu. Untuk informasi lebih lanjut, lihat Pesan terjadwal dan pesan tertunda.

pesan tertunda

• Pesan tertunda adalah pesan yang dikirim oleh broker ApsaraMQ for RocketMQ kepada konsumen setelah periode waktu tertentu. Untuk informasi lebih lanjut, lihat Pesan terjadwal dan pesan tertunda.

pesan transaksional

• ApsaraMQ for RocketMQ menyediakan fitur transaksi terdistribusi yang mirip dengan eXtended Architecture (X/Open XA) untuk memastikan konsistensi akhir dari transaksi terdistribusi. Fitur ini dikenal sebagai pesan transaksional. Untuk informasi lebih lanjut, lihat Pesan transaksional.

pesan terurut

• Pesan terurut adalah jenis pesan yang disediakan oleh ApsaraMQ for RocketMQ. Pesan terurut dipublikasikan dan dikonsumsi dalam urutan first-in, first-out (FIFO) yang ketat. Untuk informasi lebih lanjut, lihat Pesan terurut.

pesan terurut berpartisi

• Pesan dalam topik tertentu dipartisi berdasarkan kunci sharding. Pesan dalam setiap partisi dipublikasikan dan dikonsumsi dalam urutan FIFO yang ketat. Kunci sharding adalah bidang kunci berdasarkan mana ApsaraMQ for RocketMQ mempartisi pesan terurut dalam sebuah topik. Kunci sharding tidak dapat digunakan sebagai kunci pesan. Untuk informasi lebih lanjut, lihat Pesan terurut.

akumulasi pesan

• Jika konsumen tidak dialokasikan sumber daya yang cukup untuk mengonsumsi semua pesan yang dikirim oleh produser dalam waktu singkat, pesan-pesan tersebut akan bertumpuk dan disimpan di broker ApsaraMQ for RocketMQ. Fenomena ini disebut akumulasi pesan.

• Jumlah pesan terakumulasi = Jumlah pesan inflight + Jumlah pesan siap. Gambar berikut menggambarkan metrik:

penyaringan pesan

• Konsumen dapat menentukan tag sebagai filter untuk mendapatkan jenis pesan yang ingin mereka konsumsi. Penyaringan pesan diselesaikan di broker ApsaraMQ for RocketMQ. Untuk informasi lebih lanjut, lihat Penyaringan pesan.

jejak pesan

• Jejak pesan mencakup informasi lengkap tentang pesan dari titik waktu saat pesan diterbitkan oleh produser hingga titik waktu saat pesan dikonsumsi oleh konsumen, seperti cap waktu dan lokasi pesan. Jejak pesan mencatat rute lengkap pesan, dari produser ke broker ApsaraMQ for RocketMQ, lalu ke konsumen. Jejak pesan dapat membantu Anda menyelesaikan masalah. Untuk informasi lebih lanjut, lihat Kueri jejak pesan.

pengaturan ulang offset konsumen

• Anda dapat menggunakan garis waktu sebagai koordinat dan mengatur ulang kemajuan konsumen dari topik yang disubskripsikan oleh grup konsumen dalam rentang waktu penyimpanan persisten (tiga hari secara default). Setelah pengaturan selesai, konsumen dapat menerima pesan yang dikirim ke broker ApsaraMQ for RocketMQ setelah titik waktu tertentu. Untuk informasi lebih lanjut, lihat Atur ulang offset konsumen.

antrian pesan gagal

• Antrian pesan gagal digunakan untuk memproses pesan yang tidak dapat dikonsumsi. Ketika sebuah pesan gagal dikonsumsi, ApsaraMQ for RocketMQ secara otomatis mencoba ulang pesan. Jika pesan masih gagal dikonsumsi setelah jumlah maksimum percobaan ulang tercapai, konsumen tidak dapat mengonsumsi pesan sesuai harapan. Dalam hal ini, ApsaraMQ for RocketMQ tidak langsung membuang pesan tersebut. Sebagai gantinya, ia mengirimkan pesan ke antrian khusus yang sesuai dengan konsumen.

  Dalam ApsaraMQ for RocketMQ, pesan yang tidak dapat dikonsumsi dengan benar disebut pesan mati, dan antrian khusus yang digunakan untuk menyimpan pesan mati disebut antrian pesan gagal.

  Untuk informasi lebih lanjut, lihat Antrian pesan gagal.