Cara menggunakan kelompok konsumen di RocketMQ - ApsaraMQ for RocketMQ

Topik ini menjelaskan definisi, model, atribut internal, batasan perilaku, kompatibilitas versi, dan saran penggunaan kelompok konsumen di ApsaraMQ for RocketMQ.

Definisi

Kelompok konsumen adalah unit penyeimbangan beban di ApsaraMQ for RocketMQ yang terdiri dari beberapa konsumen dengan perilaku konsumsi identik.

Berbeda dengan konsumen—yang merupakan entitas berjalan—kelompok konsumen merupakan sumber daya logis. Di ApsaraMQ for RocketMQ, Anda dapat menginisialisasi beberapa konsumen dalam satu kelompok konsumen untuk meningkatkan kinerja konsumsi dan menerapkan pemulihan bencana berdaya tinggi.

Perilaku konsumsi berikut didefinisikan pada tingkat kelompok konsumen. Semua konsumen dalam kelompok yang sama mengonsumsi pesan berdasarkan perilaku bersama ini serta kebijakan penyeimbangan beban kelompok tersebut.

Hubungan langganan: ApsaraMQ for RocketMQ mengelola dan melacak hubungan langganan pada tingkat kelompok konsumen. Untuk informasi selengkapnya, lihat Hubungan langganan.
Urutan pengiriman: Server ApsaraMQ for RocketMQ mendukung pengiriman pesan secara terurut maupun konkuren kepada konsumen. Metode pengiriman dikonfigurasi pada tingkat kelompok konsumen. Untuk informasi selengkapnya, lihat Pesan terurut.
Kebijakan pengulangan konsumsi: Ini adalah kebijakan yang berlaku ketika konsumen gagal mengonsumsi sebuah pesan. Kebijakan ini mencakup jumlah maksimum pengulangan dan pengaturan antrian pesan gagal. Untuk informasi selengkapnya, lihat Pengulangan konsumsi.

Hubungan model

Dalam model domain ApsaraMQ for RocketMQ, kelompok konsumen ditempatkan dalam alur pesan sebagai berikut: 消费组

Produsen memproduksi dan mengirim pesan ke broker ApsaraMQ for RocketMQ.
Broker ApsaraMQ for RocketMQ menyimpan pesan dalam antrian yang ditentukan oleh topik sesuai urutan penerimaannya.
Konsumen memperoleh dan mengonsumsi pesan dari broker ApsaraMQ for RocketMQ berdasarkan langganan yang ditentukan.

Atribut internal

Nama kelompok konsumen

Definisi: Nama kelompok konsumen, digunakan untuk membedakannya dari kelompok lain dan harus unik secara global dalam satu kluster.
Nilai: Kelompok konsumen dibuat dan dikonfigurasi oleh pengguna. Untuk informasi lebih lanjut mengenai konvensi penamaan, lihat Batasan parameter.

Pola konsumsi

Definisi: Pola di mana konsumen mengonsumsi pesan. ApsaraMQ for RocketMQ menyediakan dua pola konsumsi untuk skenario berbeda: CLUSTERING dan LITE_SELECTIVE. Untuk informasi selengkapnya, lihat Model topik ringan.
Nilai: Pola konsumsi default adalah CLUSTERING.

Urutan pengiriman

Definisi: Urutan di mana ApsaraMQ for RocketMQ mengirimkan pesan ke klien konsumen.
ApsaraMQ for RocketMQ mendukung pengiriman terurut dan pengiriman konkuren untuk skenario konsumsi berbeda. Untuk mencegah potensi pengecualian selama pemrosesan pesan, urutan pengiriman tidak dapat diubah setelah kelompok konsumen dibuat. Untuk informasi selengkapnya, lihat Pesan terurut.
Nilai: Metode pengiriman default adalah pengiriman konkuren. Jika pola konsumsi adalah LITE_SELECTIVE, metode pengiriman harus berupa pengiriman terurut.

Kebijakan pengulangan konsumsi

Definisi: Kebijakan yang digunakan sistem untuk mengulang pengiriman pesan ketika konsumen gagal mengonsumsi pesan tersebut. Berdasarkan kebijakan ini, sistem mengirim ulang pesan ke konsumen untuk upaya konsumsi berikutnya. Untuk informasi selengkapnya, lihat Pengulangan konsumsi.
Nilai:
Kebijakan pengulangan konsumsi mencakup:
- Pengulangan maksimum: Jumlah maksimum kali sebuah pesan dapat dikirim ulang. Jika pesan tidak berhasil dikonsumsi setelah mencapai jumlah maksimum pengulangan, pesan tersebut akan dikirim ke antrian pesan gagal atau dibuang.
- Interval pengulangan: Interval di mana server ApsaraMQ for RocketMQ mengirim ulang pesan.
Untuk informasi lebih lanjut mengenai rentang nilai dan nilai default jumlah maksimum pengulangan serta interval pengulangan, lihat Batasan parameter.
Batasan: Interval pengulangan hanya berlaku untuk PushConsumer.

Hubungan langgananDefinisi: Kumpulan hubungan langganan yang terkait dengan kelompok konsumen. Ini mencakup topik yang dilanggan konsumen dan aturan penyaringan pesan. Konsumen mendaftarkan hubungan langganan secara dinamis ke kelompok konsumen. Server ApsaraMQ for RocketMQ menyimpan hubungan langganan ini secara persisten dan menggunakannya untuk melacak progres konsumsi pesan. Untuk informasi selengkapnya, lihat Hubungan langganan.

Batasan logika konsumsi

Dalam model domain ApsaraMQ for RocketMQ, konsumen dikelola dalam kelompok konsumen. Konsumen dalam kelompok konsumen yang sama berbagi semua pesan yang dikirim ke kelompok tersebut. Untuk memastikan pesan dimuat dan dikonsumsi sebagaimana diharapkan dalam kelompok konsumen di ApsaraMQ for RocketMQ, logika konsumsi berikut harus konsisten untuk semua konsumen dalam kelompok tersebut:

Urutan pengiriman pesan
Kebijakan Pengulangan Konsumsi

Kompatibilitas versi

Urutan pengiriman pesan dan kebijakan pengulangan konsumsi harus konsisten untuk semua konsumen dalam kelompok konsumen. Poin-poin berikut menjelaskan bagaimana konsistensi ini dipastikan pada versi broker ApsaraMQ for RocketMQ yang berbeda:

ApsaraMQ for RocketMQ broker versi 5.x: Konsumen memperoleh urutan pengiriman pesan dan kebijakan pengulangan konsumsi dari kelompok konsumen tempat mereka terasosiasi. Logika konsumsi sama untuk semua konsumen. Anda tidak perlu menentukan urutan pengiriman pesan atau kebijakan pengulangan konsumsi di sisi klien.
ApsaraMQ for RocketMQ broker versi 3.x dan 4.x: Urutan pengiriman pesan dan kebijakan pengulangan konsumsi ditentukan melalui operasi API di sisi klien Anda. Anda harus menentukan urutan pengiriman pesan dan kebijakan pengulangan konsumsi di sisi klien untuk memastikan logika konsumsi semua konsumen dalam kelompok konsumen tetap sama.

Jika Anda menggunakan SDK versi lama untuk mengakses broker ApsaraMQ for RocketMQ versi 5.x, logika konsumsi konsumen ditentukan oleh konfigurasi operasi API di sisi klien konsumen.

Saran penggunaan

Pisahkan menjadi kelompok berdasarkan logika bisnis

Di ApsaraMQ for RocketMQ, konsumen dan topik memiliki hubungan banyak-ke-banyak. Ikuti prinsip-prinsip berikut saat merancang dan membuat kelompok konsumen:

Pastikan urutan pengiriman konsisten: Semua konsumen dalam kelompok konsumen yang sama harus menggunakan urutan pengiriman yang sama, baik terurut maupun konkuren. Jangan gunakan kelompok konsumen yang sama untuk skenario bisnis yang memerlukan urutan pengiriman berbeda.
Kelompokkan berdasarkan jenis bisnis: Biasanya, satu kelompok konsumen berkorespondensi dengan satu topik. Domain bisnis yang berbeda memiliki persyaratan konsumsi pesan yang berbeda, seperti atribut penyaringan pesan dan kebijakan pengulangan konsumsi yang berbeda. Oleh karena itu, Anda sebaiknya menggunakan kelompok konsumen yang berbeda untuk mengonsumsi pesan dari topik yang termasuk dalam domain bisnis berbeda. Kami merekomendasikan agar satu kelompok konsumen mengonsumsi pesan dari tidak lebih dari 10 topik.

Hindari penggunaan mekanisme otomatis untuk mengelola kelompok konsumen

Dalam arsitektur ApsaraMQ for RocketMQ, kelompok konsumen adalah sumber daya logis yang digunakan untuk manajemen status. Setiap kelompok konsumen dikaitkan dengan status konsumsi, backlog pesan, metrik yang dapat diamati, dan data pemantauan. Oleh karena itu, Anda harus mengelola sumber daya kelompok konsumen secara ketat di lingkungan produksi. Jangan sembarangan menambah, menghapus, mengubah, atau mengkueri kelompok konsumen.