Shovel-plugin voor federatie

Zie Shovel als een permanente hulp:

• De plug-in consumeert berichten uit een specifieke bronwachtrij op de ene broker.
• Vervolgens publiceert de plug-in deze berichten naar een bestemmingsexchange of bestemmingswachtrij op een andere broker.
• Dit proces vindt voortdurend en betrouwbaar plaats, zelfs als verbindingen tijdelijk uitvallen.

Het is alsof je een toegewezen werker hebt wiens enige taak het is om berichten van punt A naar punt B te verplaatsen, ongeacht de afstand.

RabbitMQ biedt twee hoofdtypen Shovels:

• Statische Shovels: deze worden rechtstreeks op een RabbitMQ-node geconfigureerd, vaak via de opdrachtregelinterface (CLI) of de beheerinterface. Ze zijn vast ingesteld en blijven actief zolang de broker actief is.
• Dynamische Shovels: deze zijn flexibeler en worden geconfigureerd met runtimeparameters of beleidsregels. Je kunt ze direct aanmaken, bijwerken of verwijderen, waardoor ze ideaal zijn voor tijdelijke of door beleid gestuurde berichtenstromen.

Om een statische Shovel in te stellen, definieer je de bron en bestemming. Dit is een conceptuele CLI-opdracht:

rabbitmqctl shovel add [name] --uri=[source_uri] --source-queue=[q_name] --destination-uri=[dest_uri] --destination-exchange=[ex_name]

Je geeft de verbindingsgegevens (URI's) voor beide brokers op, evenals de exacte wachtrij of exchange die moet worden gebruikt.

Laten we de belangrijkste parameters van een statische Shovel bekijken:

• --uri: verbindingsreeks voor de bronbroker.
• --source-queue: de naam van de wachtrij op de bronbroker waaruit berichten worden geconsumeerd.
• --destination-uri: verbindingsreeks voor de bestemmingsbroker.
• --destination-exchange (of --destination-queue): de naam van de exchange of wachtrij op de bestemmingsbroker waarnaar berichten worden gepubliceerd.

De plug-in beheert al het onderliggende AMQP-verbindingsbeheer.

Dynamische Shovels zijn krachtig voor het beheren van veel vergelijkbare berichtenstromen. In plaats van elke Shovel handmatig toe te voegen, kun je een beleidsregel definiëren.

Een beleidsregel bevat regels (bijvoorbeeld voor het matchen van wachtrijnamen met een patroon) waarmee automatisch Shovels worden aangemaakt. Dit is handig voor:

• Automatisch nieuwe wachtrijen overbruggen die aan een naamgevingsconventie voldoen.
• Shovelconfiguraties centraal beheren.

Het is belangrijk om je Shovels te bewaken, zodat je zeker weet dat berichten correct worden doorgestuurd.

Je kunt hun status controleren via de RabbitMQ-beheerinterface (onder het tabblad 'Shovels') of via de CLI:

Je hebt kennisgemaakt met de krachtige RabbitMQ Shovel-plug-in!

• De plug-in verplaatst berichten betrouwbaar tussen verschillende RabbitMQ-brokers.
• Shovel werkt als consument op een bron en als producent voor een bestemming en handelt het opnieuw verbinden automatisch af.
• We hebben zowel statische (vaste configuratie) als dynamische (door beleidsregels gestuurde) Shovels behandeld.
• Shovel is essentieel voor het integreren van systemen via WAN's, het garanderen van berichtduurzaamheid en het mogelijk maken van noodherstel.

Het is een onmisbaar hulpmiddel voor het bouwen van robuuste, gedistribueerde berichtsystemen!