Antrian adalah buffer yang menyimpan pesan. Di ApsaraMQ for RabbitMQ, pesan dikirimkan ke satu atau beberapa antrian. Topik ini menjelaskan cara membuat antrian, melihat statistiknya, mengikatnya ke exchange, mengirim pesan ke dalamnya, melihat tag konsumen, mengosongkannya, dan menghapusnya di konsol ApsaraMQ for RabbitMQ.
Informasi latar belakang
Tag konsumen adalah pengidentifikasi untuk klien konsumen. Anda dapat menetapkan tag konsumen untuk klien konsumen ApsaraMQ for RabbitMQ. Jika Anda tidak menetapkan tag konsumen untuk klien konsumen ApsaraMQ for RabbitMQ, server ApsaraMQ for RabbitMQ akan secara otomatis menghasilkan tag unik. Kami menyarankan agar Anda menggunakan tag konsumen default dan tidak menetapkan tag kustom.
Tag konsumen harus unik. Tag yang digunakan oleh satu konsumen tidak dapat digunakan oleh konsumen lain.
SDK yang digunakan oleh klien mencatat konsumen pada suatu koneksi dalam format `Map<String, Consumer>`, di mana kuncinya adalah tag konsumen. Jika beberapa konsumen pada satu koneksi memiliki tag konsumen yang sama, hanya salah satu konsumen yang secara otomatis melanjutkan konsumsi pesan setelah koneksi dipulihkan. Konsumen lainnya tidak dipulihkan secara otomatis.
Buat antrian
Masuk ke ApsaraMQ for RabbitMQ console. Di panel navigasi sebelah kiri, klik Instances.
Di bilah navigasi atas halaman Instances, pilih wilayah tempat instans yang ingin Anda kelola berada. Lalu, di daftar instans, klik nama instans yang ingin Anda kelola.
Di panel navigasi sebelah kiri, klik Queues.
Di halaman Queues, pilih vhost dari daftar drop-down Change di samping vhost. Lalu, klik Create Queue.
Di panel Create Queue, konfigurasikan parameter berikut dan klik OK.
Parameter
Deskripsi
Catatan penggunaan
Queue Name
Nama antrian.
Nama dapat berisi huruf, angka, tanda hubung (-), garis bawah (_), titik (.), tanda pagar (#), garis miring (/), dan tanda at (@).
Panjang nama harus antara 1 hingga 255 karakter.
Setelah antrian dibuat, Anda tidak dapat mengubah namanya. Jika ingin mengganti nama antrian, hapus antrian tersebut dan buat antrian baru.
amq. adalah bidang yang dicadangkan dan tidak dapat digunakan sebagai awalan nama exchange. Misalnya, Anda tidak dapat menggunakan amq.test sebagai nama exchange.
Auto Delete
Menentukan apakah antrian dihapus secara otomatis setelah langganan terakhir dari konsumen ke antrian tersebut dibatalkan.
true: Antrian dihapus secara otomatis setelah langganan terakhir dari konsumen ke antrian ini dibatalkan.
false: Antrian tidak dihapus secara otomatis setelah langganan terakhir dari konsumen ke antrian ini dibatalkan.
Advanced Settings
Parameter lain untuk antrian, seperti dead-letter exchange, dead-letter routing key, dan waktu hidup pesan (TTL).
DeadLetterExchange: exchange tempat pesan dead-letter dikirimkan.
DeadLetterRoutingKey: routing key untuk pesan dead-letter. Exchange dead-letter mengirimkan pesan dead-letter ke antrian yang routing key-nya cocok dengan routing key pesan dead-letter tersebut.
MessageTTL: TTL pesan, dalam milidetik. Pesan yang tidak dikonsumsi dalam TTL pesan yang ditentukan menjadi pesan dead-letter dan dikirim ke exchange dead-letter. Untuk informasi selengkapnya, lihat Message TTL.
Lihat statistik
Anda dapat melihat berbagai metrik untuk mengidentifikasi dan menemukan masalah sedini mungkin.
Di halaman Queues, temukan antrian target dan klik Details di kolom Actions.
Di halaman Queue Details, klik tab Monitoring and Alerting atau Dashboard.
Statistik yang tersedia bervariasi berdasarkan edisi instans. Rincian berikut menjelaskannya:
Edisi Perusahaan dan Edisi Platinum Perusahaan: Anda dapat melihat metrik yang disediakan oleh Managed Service for Prometheus dan Managed Service for Grafana. Untuk informasi tentang dasbor dan metrik yang ditampilkan di dasbor, lihat Dashboard.
Edisi Standar dan Edisi Profesional: Anda dapat melihat data pemantauan yang disediakan oleh CloudMonitor. Untuk informasi tentang metrik yang disediakan oleh CloudMonitor, lihat Pemantauan dan peringatan.
CatatanApsaraMQ for RabbitMQ tidak lagi memungkinkan pembelian instans Edisi Standar. Anda dapat terus menggunakan instans Edisi Standar yang sudah ada.
Lihat tag konsumen
Di ApsaraMQ for RabbitMQ, Anda hanya dapat melihat tag konsumen dari klien konsumen yang sedang online. Pastikan klien sedang online sebelum melanjutkan.
Di halaman Queues, temukan antrian target dan pilih di kolom Actions.
Diikat oleh Exchange
Di halaman Queues, temukan antrian target dan klik Details di kolom Actions.
Di halaman Queue Details, klik tab Bound as Destination, lalu klik Add Binding.
Di panel Add Binding, pilih Source Exchange, masukkan kunci perutean pada kotak teks Routing Key, lalu klik Confirm.
CatatanJika exchange yang diikat adalah exchange x-consistent-hash, routing key menentukan bobot antrian. Bobot harus berupa bilangan bulat dari 1 hingga 20.
Kirim pesan
Setelah Anda mengikat exchange ke antrian, Anda dapat mengirim pesan dari exchange ke antrian di konsol ApsaraMQ for RabbitMQ.
Di halaman Queues, temukan antrian target dan klik Details di kolom Actions.
Di halaman Queue Details, klik tab Bound as Destination.
Di daftar binding, temukan binding target dan klik Send Message di kolom Actions.
Di panel Send Message, masukkan Message ID dan Message Body, lalu klik OK.
Kosongkan antrian
Di halaman Queues, temukan antrian target dan pilih di kolom Actions.
Hapus antrian
Saat Anda menghapus antrian, semua pesan yang belum dikonsumsi di dalam antrian juga akan dihapus dan tidak dapat dipulihkan. Lakukan dengan hati-hati.
Di halaman Queues, hapus satu atau beberapa antrian sesuai kebutuhan.
Untuk menghapus satu antrian: Temukan antrian target dan pilih di kolom Actions.
Atau, klik antrian target atau klik Details di kolom Actions. Lalu, di pojok kanan atas halaman Queue Details, klik Delete.
Untuk menghapus beberapa antrian: Pilih antrian target dan klik Batch Delete di bawah daftar antrian.
Di kotak dialog Note yang muncul, baca pesannya dan klik OK.