Plugin untuk Amazon MQ untuk RabbitMQ

Amazon MQ untuk RabbitMQ mendukung plugin manajemen RabbitMQ yang mendukung manajemen dan konsol web RabbitMQ. API Anda dapat menggunakan konsol web dan manajemen API untuk membuat dan mengelola pengguna dan kebijakan broker.

Selain plugin manajemen, Amazon MQ untuk RabbitMQ juga mendukung plugin berikut.

Plugin shovel

Broker terkelola Amazon MQ mendukung shovel RabbitMQ, memungkinkan Anda memindahkan pesan dari antrean dan pertukaran pada satu instans broker ke instans broker lainnya. Anda dapat menggunakan shovel untuk menghubungkan broker dengan penggabungan longgar dan mendistribusikan pesan dari simpul dengan beban pesan yang lebih berat.

Broker RabbitMQ yang dikelola Amazon MQ mendukung shovel dinamis. Shovel dinamis dikonfigurasi menggunakan parameter waktu aktif, serta dapat dimulai dan dihentikan kapan saja secara terprogram oleh koneksi klien. Misalnya, menggunakan manajemen RabbitMQAPI, Anda dapat membuat PUT permintaan ke API titik akhir berikut untuk mengonfigurasi sekop dinamis. Dalam contoh, {vhost} dapat diganti dengan nama vhost broker, dan {name} diganti dengan nama shovel dinamis baru.

/api/parameters/shovel/{vhost}/{name}

Dalam isi permintaan, Anda harus menentukan antrean atau pertukaran, tidak keduanya. Contoh di bawah ini mengonfigurasi shovel dinamis antara antrean lokal yang ditentukan dalam src-queue dan antrean jarak jauh yang ditentukan dalam dest-queue. Demikian pula, Anda dapat menggunakan parameter src-exchange dan dest-exchange untuk mengonfigurasi shovel antara dua pertukaran.

{
                "value": {
                    "src-protocol": "amqp091",
                    "src-uri":  "amqp://localhost",
                    "src-queue":  "source-queue-name",
                    "dest-protocol": "amqp091",
                    "dest-uri": "amqps://b-c8352341-ec91-4a78-ad9c-a43f23d325bb.mq.us-west-2.amazonaws.com:5671",
                    "dest-queue": "destination-queue-name"
                }
                }

penting

Anda tidak dapat mengonfigurasi sekop di antara antrian atau pertukaran jika tujuan sekop adalah broker pribadi. Anda hanya dapat mengkonfigurasi sekop antara antrian atau pertukaran di broker publik, atau antara sumber di broker swasta, dan tujuan di broker publik.

Untuk informasi selengkapnya tentang penggunaan shovel dinamis, lihat Plugin shovel dinamis RabbitMQ.

catatan

Amazon MQ tidak mendukung penggunaan shovel statis.

Plugin federasi

Amazon MQ mendukung pertukaran dan antrean federasi. Dengan federasi, Anda dapat mereplikasi alur pesan antara antrean, pertukaran, dan konsumen pada broker terpisah. Antrian dan pertukaran federasi menggunakan point-to-point tautan untuk terhubung ke rekan-rekan di broker lain. Sedangkan pertukaran federasi, secara default, merutekan pesan satu kali, antrean federasi dapat memindahkan pesan beberapa kali sesuai kebutuhan konsumen.

Anda dapat menggunakan federasi untuk memungkinkan broker hilir mengonsumsi pesan dari pertukaran atau antrean di hulu. Anda dapat mengaktifkan federasi pada pialang hilir dengan menggunakan konsol web RabbitMQ atau manajemen. API

penting

Anda tidak dapat mengonfigurasi federasi jika antrian atau pertukaran hulu ada di broker pribadi. Anda hanya dapat mengkonfigurasi federasi antara antrian atau pertukaran di pialang publik, atau antara antrian hulu atau pertukaran di broker publik, dan antrian hilir atau pertukaran di broker swasta.

Misalnya, menggunakan manajemenAPI, Anda dapat mengonfigurasi federasi dengan melakukan hal berikut.

• Mengonfigurasi satu atau lebih hulu yang menentukan koneksi federasi ke simpul lain. Anda dapat menentukan koneksi federasi dengan menggunakan konsol web RabbitMQ atau manajemen. API Dengan menggunakan manajemenAPI, Anda dapat membuat POST permintaan /api/parameters/federation-upstream/%2f/my-upstream dengan badan permintaan berikut.

  {"value":{"uri":"amqp://server-name","expires":3600000}}

• Konfigurasikan kebijakan untuk mengaktifkan antrean atau pertukaran agar menjadi federasi. Anda dapat mengonfigurasi kebijakan menggunakan konsol web RabbitMQ, atau pengelolaannya. API Dengan menggunakan manajemenAPI, Anda dapat membuat POST permintaan /api/policies/%2f/federate-me dengan badan permintaan berikut.

  {"pattern":"^amq\.", "definition":{"federation-upstream-set":"all"}, "apply-to":"exchanges"}

  catatan

  Isi permintaan mengambil pertukaran pada server yang namanya dimulai dengan amq. Menggunakan ekspresi reguler ^amq\. akan memastikan bahwa federasi diaktifkan untuk semua pertukaran yang namanya dimulai dengan "amq." Pertukaran di server RabbitMQ Anda dapat diberikan nama yang berbeda.

Untuk informasi selengkapnya tentang mengonfigurasi plugin federasi, lihat plugin federasi RabbitMQ.

Plugin pertukaran Hash yang konsisten

Secara default, Amazon MQ untuk RabbitMQ mendukung plugin tipe pertukaran Hash Konsisten. Pertukaran Hash yang konsisten merutekan pesan ke antrian berdasarkan nilai hash yang dihitung dari kunci perutean pesan. Mengingat kunci routing yang cukup merata, pertukaran Hash Konsisten dapat mendistribusikan pesan antar antrian secara merata.

Untuk antrian yang terikat pada pertukaran Hash Konsisten, kunci pengikatan adalah kunci number-as-a-string yang menentukan bobot pengikatan setiap antrian. Antrian dengan bobot pengikatan yang lebih tinggi akan menerima distribusi pesan yang lebih tinggi secara proporsional dari pertukaran Hash Konsisten yang terikat. Dalam topologi pertukaran Hash Konsisten, penerbit dapat dengan mudah mempublikasikan pesan ke bursa, tetapi konsumen harus dikonfigurasi secara eksplisit untuk mengkonsumsi pesan dari antrian tertentu.

Untuk informasi selengkapnya tentang pertukaran Hash Konsisten, lihat Jenis Pertukaran Hash Konsisten RabbitMQ di situs web. GitHub