Advanced Message Queuing Protocol

Los intercambiadores son las entidades a las que se envía los mensajes. Tienen un nombre así como un tipo y unas propiedades tales como:

• pasivo: el intercambiador no será declarado pero ocurrirá un error si no existe.
• perdurable: el intercambiador sobrevivirá a un reinicio del intercambiador.
• autoborrado: el intercambiador será borrado tan pronto como ya no queden colas vinculadas a él. Aquellos intercambiadores que nunca hayan tenido colas vinculadas nunca serán autoborrados.

Nótese que está prevista la supresión de los intercambiadores en AMQP/1.0.

Las colas son las entidades que reciben mensajes. Tienen un nombre y propiedades pero no tienen tipo. Los clientes pueden subscribirse a las colas, con el efecto de que el corredor de mensajes les entregará (mediante un mecanismo de push, es decir, de forma activa por parte del corredor) a los clientes los contenidos de la cola a los clientes. Alternativamente los clientes pueden hacer saltar activamente mensajes de la cola como crean conveniente (mecanismo de pull).

La cola garantiza que los mensajes son entregados en el mismo orden en que llegaron a la cola; esta ordenación se conoce habitualmente como FIFO. En algunos casos de reenrutamiento (por ejemplo debido a un fallo que implique un reinicio del corredor) este orden no se garantiza.

Las propiedades de las colas incluyen:

• intercambiador alternativo: cuando un mensaje es rechazado por un subscriptor o queda huérfano debido a la destrucción de una cola, son reenrutados a un intercambiador alternativo y borrados de esta cola.
• pasiva: la cola no será declarado pero ocurrirá un error si no existe.
• perdurable: la cola sobrevivirá a un reinicio del corredor.
• exclusiva: solo puede haber un cliente para esta cola específica.
• autoborrado: la cola será borrada tan pronto como no queden suscripciones activas para ella. Esta propiedad comparte la misma limitación que la propiedad de autoborrado para los intercambiadores: si ninguna suscripción ha estado jamás activa para esta cola, no será autoborrada. Una cola exclusiva, sin embargo, siempre será autoborrada cuando el cliente cierre la sesión.

Nótese que está previsto que las colas reemplacen a los intercambiadores en AMQP/1.0.

Los mensajes no tienen nombre y son publicados en un intercambiador. Consisten en un encabezamiento y un cuerpo de contenido. Mientras que el cuerpo contiene datos opacos, el encabezamiento contiene una serie de propiedades opcionales:

• clave de enrutamiento (routing-key): este campo se usa de diferentes formas dependiendo del tipo de intercambiador.
• inmediato: el mensaje será tratado como imposible de enrutar si al menos una de las colas que deberían recibir el mensaje no tiene ninguna suscripción.
• modo de entrega: indica que un mensaje puede necesitar perdurabilidad. Solo para este tipo de mensajes puede el corredor hacer un intento (best-effort) para impedir la pérdida del mensaje antes de que sea consumido. Si hay alguna incertidumbre del lado del corredor sobre la recepción correcta del mensaje (por ejemplo en caso de errores), puede opcionalmente entregar un mismo mensaje más de una vez. Los modos de entrega no persistentes no muestran este tipo de comportamiento.
• prioridad: un indicador (en el rango entre 0 y 9) de que un mensaje tiene precedencia sobre otros.
• vencimiento (expiration): la duración en milisegundos antes de que el corredor pueda tratar el mensaje como imposible de enrutar.

Una vinculación (binding) es una relación entre una cola y un intercambiador que especifica cómo fluyen los mensajes desde el intercambiador a la cola. Las propiedades de la vinculación concuerdan con el algoritmo de enrutamiento que se usa en los intercambiadores. Las vinculaciones (y los algoritmos de los intercambiadores) pueden ser ordenados en una escala de menor a mayor complejidad:

• Incondicional: la vinculación no tiene propiedades y reclama todos los mensajes del intercambiador.
• Condicional con una cadena fija: la vinculación tiene una propiedad, la clave de enrutamiento y reclama todos los mensajes que tengan una clave de enrutamiento idéntica.
• Condicional con un patrón de reconocimiento: la vinculación tiene una propiedad, la clave de enrutamiento y reclama todos los mensajes que sean detectados por un algoritmo de reconocimiento de patrones. Se puede usar cualquier sintaxis arbitraria de patrones. AMQP implementa el reconocimiento de temas.
• Condicional con múltiples cadenas fijas: la vinculación tiene una tabla de propiedades, los argumentos, y reclama todos los mensajes cuyos encabezamientos se correspondan con estos argumentos, usando operaciones lógicas AND o OR para combinar las diferentes correspondencias.
• Condicional con una comparación algorítmica: la vinculación tiene una expresión algorítmica (como una cláusula WHERE en una sentencia SELECT en SQL) y reclama todos los mensajes cuyos encabezamientos se correspondan con esta expresión.
• Condicional con inspección del contenido: la vinculación especifica criterios arbitrarios que solo pueden ser resueltos mediante la inspección del contenido concreto del mensaje.

No todas estas vinculaciones son implementadas de manera estándar, o por todas las implementaciones.

Estas cuatro entidades forman el modelo básico de AMQP. La clave para entender cómo un mensaje es pasado a una cola reside en la relación entre el tipo de intercambiador y la interpretación resultante de la clave de enrutamiento.

Un intercambiador entregará como máximo una copia de un mensaje dado a una cola si la clave de enrutamiento en el mensaje se corresponde a una vinculación (otras vinculaciones posteriores semánticamente idénticas no pueden resultar en copias duplicadas del mismo mensaje). Lo que constituye una correspondencia, en cambio, es exclusivamente dependiente del tipo de intercambiador:

• un intercambiador directo considera que hay correspondencia cuando la clave de enrutamiento y la clave de la vinculación son idénticas.
• un intercambiador de abanico (fanout) siempre considera que hay correspondencia, incluso con vinculaciones sin clave.
• un intercambiador con un tema definido (topic exchange) considera que hay correspondencia si la propiedad de clave de enrutamiento de un mensaje coincide con las palabras claves de una vinculación. Estas palabras son cadenas de caracteres separadas por puntos. Dos caracteres adicionales son también válidos: el asterisco "*", que crea una correspondencia con 1 palabra, y la almohadilla "#", que crea una correspondencia con 0 a N palabras. Por ejemplo, *.stock.# tendrá una correspondencia con las claves usd.stock y eur.stock.db, pero no con stock.nasdaq.
• un intercambiador de encabezamientos considera que hay correspondencia en presencia tanto de claves como de pares clave-valor que pueden ser concatenadas con conexiones lógicas AND y OR en el encabezamiento de un mensaje. En este caso, la clave enrutamiento no es un criterio de correspondencia que sea considerado por el intercambiador. Ni tampoco contiene la vinculación una única clave de enrutamiento, sino un formato especial que contiene claves de encabezamiento y/o pares clave-valor que crean una correspondencia al estar presente la clave del encabezamiento o al estar presente la clave del encabezamiento y el valor ser el mismo, respectivamente.

Otros tipos de intercambiadores, por ejemplo específicos del suministrador, son permitidos explícitamente por la especificación.

El concepto de vincular colas denominadas con intercambiadores denominados tiene propiedades poderosas (mientras que la vinculación mantiene ambas entidades independientes entre sí). Es posible, por ejemplo, vincular una única cola mediante vinculaciones múltiples a un único intercambiador, o a varios. O múltiples consumidores pueden compartir el nombre de una cola y vincularse a ella con los mismos parámetros, obteniendo por tanto solo los mensajes que los otros consumidores no hayan consumido. O múltiples consumidores pueden declarar colas independientes pero compartir las mismas vinculaciones y obtener por tanto todos ellos el mensaje que otro consumidor hubiera obtenido en el intercambiador vinculado con estas vinculaciones.

• OpenAMQP, la implementación original en código abierto de AMQP, escrita en C por iMatix. Funciona bajo Linux, AIX, Solaris, Windows y OpenVMS. Incluye un corredor, APIs para C/C++ y Java JMS, una consola de administración remota, secuencias de órdenes, federación, conmutación por error y AMQP-sobre-HTTP mediante el protocolo RestMS.
• AMQP Infrastructure, un paquete instalable mediante yum que cumple con AMQP 0-10 y mantenido para las últimas versiones de Fedora. Incluye el corredor, herramientas de administración, agentes y clientes.
• Apache Qpid, un proyecto de la Apache Software Foundation. Vinculaciones para muchos lenguajes evitando el uso de librerías dinámicas.
• Red Hat Enterprise MRG implementa la versión 0-10 de AMQP cuya gama de características incluye federación, distribución en modo activo-activo usando Qpid como upstream, una consola web y otras características orientadas a empresas.

• RabbitMQ, una implementación independiente de código abierto. El servidor está escrito en Erlang y también incluye un cliente de referencia escrito en Java.
• ZeroMQ, una plataforma de mensajería que es capaz de tratar a los corredores de AMQP como nodos de una red de mensajería distribuida. Tiene vinculaciones a su implementación subyacente en C, así como a otros lenguajes como Python, C++, Lisp, Ruby y otros.
• Zyre, un corredor que implementa RestMS y AMQP para permitir acceso HTTP basado en REST a redes AMQP.

• DE.SETF.AMQP, una librería cliente de AMQP para Common Lisp.
• amqplib, una librería cliente de AMQP 0-8 para Python, probada con RabbitMQ.