Plugins para Amazon MQ para RabbitMQ - Amazon MQ

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Plugins para Amazon MQ para RabbitMQ

Amazon MQ para RabbitMQ es compatible con el complemento de administración RabbitMQ que impulsa la administración y la consola web de RabbitMQ. API Puede usar la consola web y la administración para crear y administrar los usuarios y las políticas de los corredores. API

Además del de administración, Amazon MQ para RabbitMQ también admite los siguientes complementos.

el complemento Shovel (pala)

Los agentes administrados por Amazon MQ admiten palas de RabbitMQ, lo que permite mover mensajes de colas e intercambios de una instancia de agente a otra. Puede utilizar palas para conectar agentes con acoplamiento débil y distribuir mensajes lejos de los nodos con mayores cargas de mensajes.

Los agentes de RabbitMQ administrados por Amazon MQ admiten palas dinámicas. Las palas dinámicas se configuran utilizando parámetros de tiempo de ejecución y se pueden iniciar y detener en cualquier momento mediante programación a través de una conexión de cliente. Por ejemplo, con la administración de RabbitMQAPI, puede crear una PUT solicitud al siguiente API punto final para configurar una pala dinámica. En el ejemplo, {vhost} se puede reemplazar por el nombre del vhost del agente, y {name}, por el nombre de la nueva pala dinámica.

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

En el cuerpo de la solicitud, debe especificar una cola o un intercambio, pero no ambos. En el ejemplo que se incluye a continuación, se configura una pala dinámica entre una cola local especificada en src-queue y una cola remota definida en dest-queue. Del mismo modo, puede utilizar los parámetros src-exchange y dest-exchange para configurar una pala entre dos intercambios.

{ "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" } }
importante

No puede configurar la pala entre colas o intercambios si el destino de la pala es un agente privado. Solo puede configurar la pala entre colas o intercambios en agentes públicos, o entre un origen de un agente privado y un destino de un agente público.

Para obtener más información acerca del uso de palas dinámicas, consulte el tema sobre el complemento de pala dinámica de RabbitMQ.

nota

Amazon MQ no admite el uso de palas estáticas.

Complemento Federation (federación)

Amazon MQ admite intercambios y colas federados. El complemento de federación le permite replicar el flujo de mensajes entre colas, intercambios y consumidores en agentes independientes. Las colas y bolsas federadas utilizan point-to-point enlaces para conectarse con pares de otros corredores. Mientras que los intercambios federados, de forma predeterminada, enrutan mensajes una sola vez, las colas federadas pueden mover mensajes la cantidad de veces que los consumidores lo necesiten.

Puede utilizar el complemento de federación para permitir que un agente descendente consuma un mensaje de un intercambio o cola ascendente. Puede habilitar la federación en los corredores intermedios mediante la consola web de RabbitMQ o la administración. API

importante

No puede configurar la federación si la cola o el intercambio ascendente se encuentra en un agente privado. Solo puede configurar la federación entre colas o intercambios en agentes públicos, o entre una cola o intercambio ascendente en un agente público y una cola o intercambio descendente en un agente privado.

Por ejemplo, mediante la administraciónAPI, puede configurar la federación de la siguiente manera.

  • Configure uno o más flujos ascendentes que definan conexiones de federación con otros nodos. Puede definir las conexiones de federación mediante la consola web de RabbitMQ o la administración. API Mediante la administraciónAPI, puede crear una POST solicitud /api/parameters/federation-upstream/%2f/my-upstream con el siguiente cuerpo de solicitud.

    {"value":{"uri":"amqp://server-name","expires":3600000}}
  • Configure una política para permitir la federación de sus colas o intercambios. Puede configurar las políticas mediante la consola web de RabbitMQ o la administración. API Mediante la administraciónAPI, puede crear una POST solicitud /api/policies/%2f/federate-me con el siguiente cuerpo de solicitud.

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

    El cuerpo de la solicitud asume que los intercambios del servidor se se nombran comenzando con amq. El uso de la expresión regular ^amq\. garantizará que se habilite la federación para todos los intercambios cuyos nombres comiencen con "amq". Los intercambios de su servidor RabbitMQ se pueden nombrar de otra manera.

Para obtener más información acerca de cómo configurar el complemento de federación, consulte el tema sobre el complemento de federación de RabbitMQ.

Complemento de intercambio Hash consistente

De forma predeterminada, Amazon MQ para RabbitMQ es compatible con el complemento de tipo de intercambio Hash consistente. Los intercambios Hash consistentes enrutan mensajes a colas en función de un valor hash que se calcula a partir de la clave de enrutamiento de un mensaje. Si se proporciona una clave de enrutamiento razonablemente uniforme, los intercambios Hash consistentes pueden distribuir mensajes entre colas de manera razonablemente pareja.

En el caso de las colas vinculadas a un intercambio de hash coherente, la clave de enlace es la number-as-a-string que determina el peso de enlace de cada cola. Las colas con un peso de enlace más alto recibirán una distribución proporcionalmente mayor de mensajes del intercambio Hash consistente al que están enlazadas. En una topología de intercambio Hash consistente, los publicadores pueden simplemente publicar mensajes para el intercambio, pero los consumidores deben estar explícitamente configurados para consumir mensajes de colas específicas.

Para obtener más información sobre los intercambios de hash consistentes, consulte RabbitMQ Consistent Hash Exchange Type en el sitio web. GitHub