Topik ini menjelaskan kebijakan pengulangan konsumsi default yang digunakan oleh broker ApsaraMQ for RabbitMQ. Informasi ini membantu Anda memahami cara penanganan pesan gagal serta memilih kebijakan pemrosesan pesan yang sesuai dengan kebutuhan bisnis.
Proses pengulangan konsumsi
Mekanisme pengulangan konsumsi memungkinkan sistem untuk secara otomatis mengirim ulang atau memproses pesan gagal akibat kesalahan sementara. Hal ini meningkatkan keandalan sistem dan konsistensi data.
Siap: Pesan dikirim ke antrian dan tersedia untuk dikonsumsi.
Tidak Diakui: Pesan diterima dan sedang diproses oleh konsumen.
Atribut kebijakan pengulangan konsumsi
Kebijakan pengulangan konsumsi mencakup atribut utama berikut: periode batas waktu konsumsi dan jumlah maksimum percobaan pengiriman.
Periode batas waktu konsumsi
Periode batas waktu konsumsi adalah durasi maksimum yang diizinkan bagi konsumen untuk menerima dan memproses pesan. Jika konsumen gagal memproses pesan dalam periode ini, pesan akan kembali ke status Siap dan dapat diproses oleh konsumen lain. Berikut alasan pentingnya menentukan nilai yang tepat untuk atribut ini:
Mencegah permintaan tertunda terlalu lama: Nilai yang tidak tepat dapat menyebabkan penumpukan pesan dan memengaruhi kinerja sistem secara keseluruhan.
Memastikan keandalan pemrosesan pesan: Jika konsumen tidak dapat memproses pesan dalam waktu yang ditentukan, ApsaraMQ for RabbitMQ akan mengirimkan pesan kepada konsumen lain untuk memastikan pemrosesan segera dilakukan.
Jumlah maksimum percobaan pengiriman
Jumlah maksimum percobaan pengiriman adalah batas jumlah pengiriman pesan kepada konsumen. Berikut alasan pentingnya menentukan nilai yang tepat untuk atribut ini:
Mencegah pengulangan pesan tanpa batas: Mengonfigurasi atribut ini mencegah pemborosan sumber daya sistem akibat pengulangan pesan yang berlebihan.
Memungkinkan failover: Setelah jumlah maksimum percobaan tercapai, pesan gagal dialihkan ke antrian pesan gagal untuk analisis lebih lanjut.
Atribut x-delivery-limit pada antrian menentukan jumlah maksimum pengulangan. Rumus perhitungan jumlah maksimum percobaan pengiriman adalah: Jumlah maksimum percobaan = Nilai atribut x-delivery-limit + 1.
Parameter kebijakan pengulangan instance
Tipe instance | Instance serverless | Instance langganan | ||
Berbagi | Eksklusif | Enterprise Edition | Enterprise Platinum Edition | |
Pembayaran berdasarkan kapasitas-provisioned-dan-trafik-elastis/pembayaran berdasarkan permintaan-pesan | Pembayaran berdasarkan kapasitas-provisioned-dan-trafik-elastis | |||
Periode batas waktu konsumsi | Nilai maksimum: 3 jam Nilai default: 5 menit | Nilai maksimum: 12 jam Nilai default: 30 menit | Nilai maksimum: 3 jam Nilai default: 5 menit | Nilai maksimum: 12 jam Nilai default: 30 menit |
Jumlah maksimum percobaan pengiriman | Nilai maksimum: 16 Nilai default: 16 | Nilai maksimum: 16 Nilai default: 16 | Nilai maksimum: 16 Nilai default: 16 | Nilai maksimum: 64 Nilai default: 16 |
Modifikasi kebijakan pengulangan konsumsi
Masuk ke Konsol ApsaraMQ for RabbitMQ.
Di bagian Resource Distribution halaman Overview, pilih wilayah tempat instance Anda berada. Lalu, klik nama instance dalam daftar.
Kebijakan Pengulangan Instance
Di halaman Instance Details, klik tab Retry Policy, lalu klik Edit di pojok kanan atas tab.
Di panel Modify Retry Policy, konfigurasikan parameter Maximum Number of Deliveries dan Consumption Timeout Period sesuai deskripsi sebelumnya.
Kebijakan Pengulangan Antrian
Di panel navigasi sisi kiri halaman Detail Instance, klik Queues. Lalu, klik nama antrian yang ingin Anda kelola.
Di halaman Queue Details, klik tab Retry Policy, lalu klik Edit di pojok kanan atas tab.
Di panel Modify Retry Policy, konfigurasikan parameter Inherit Instance Configurations, Maximum Number of Deliveries, dan Consumption Timeout Period sesuai deskripsi sebelumnya.
Jika Anda mengatur parameter Warisi Konfigurasi Instance ke Ya, kebijakan pengulangan antrian akan mengikuti kebijakan pengulangan instance tempat antrian tersebut berada.
Jika Anda mengatur parameter Warisi Konfigurasi Instance ke Tidak, kebijakan pengulangan antrian tidak akan mengikuti kebijakan pengulangan instance, dan kebijakan antrian memiliki prioritas lebih tinggi daripada kebijakan instance.
Klik OK.