Fusible JBoss - Apache AMQ
En este capítulo, conoceremos ActiveMQ y cómo actúa como intermediario de mensajes para permitir que las aplicaciones se comuniquen entre sí.
¿Qué es AMQ?
ActiveMQ es un agente de mensajes de código abierto escrito en Java. Es totalmente compatible con los estándares JMS 1.1.
JMS es una especificación que permite el desarrollo de un sistema basado en mensajes. ActiveMQ actúa como un intermediario de mensajes que se encuentra entre las aplicaciones y les permite comunicarse de manera asincrónica y confiable.
Tipos de mensajería
Hay dos tipos de opciones de mensajería que se explican a continuación para una mejor comprensión.
Punto a punto
En este tipo de comunicación, el corredor envía mensajes a un solo consumidor, mientras que los otros consumidores esperarán hasta recibir los mensajes del corredor. Ningún consumidor recibirá el mismo mensaje.
Si no hay consumidores, el corredor retendrá los mensajes hasta que obtenga un consumidor. Este tipo de comunicación también se denominaQueue based communicationdonde el productor envía mensajes a una cola y solo un consumidor recibe un mensaje de la cola. Si hay más de un consumidor, es posible que reciba el siguiente mensaje, pero no recibirá el mismo mensaje que el otro consumidor.
Publicar / Suscribirse
En este tipo de comunicación, el Broker envía la misma copia de mensajes a todos los consumidores activos. Este tipo de comunicación también se conoce comoTopic based communicationdonde el corredor envía el mismo mensaje a todos los consumidores activos que se han suscrito a un tema en particular. Este modelo admite la comunicación unidireccional donde no se espera la verificación de los mensajes transmitidos.
Crear cola y temas
Fuse viene incluido con ActiveMQ. Podemos acceder a ActiveMQ usando la consola FMC (la interfaz basada en navegador para trabajar con AMQ).
Inicie sesión en FMC usando localhost:8181 y seleccione ActiveMQ lengüeta.
- Haga clic en + Crear
- Ingrese el nombre de la cola / tema
- Seleccione Cola / Tema del botón de opción
- Haga clic en Crear cola / Crear tema
Ahora debería poder ver el TestQ creado en root → Cola →
Para comprobar el tema creado, siga root → Tema.
Examinar / eliminar contenido de la cola
Inicie sesión en FMC usando localhost:8181
Seleccione la pestaña ActiveMQ
Raíz → Cola → TestQ <seleccione la cola que desea explorar> → Examinar
- Para verificar el contenido de este mensaje, haga clic en ese mensaje en particular.
Puede eliminar un mensaje en particular haciendo clic en el botón Eliminar que se muestra en la esquina superior derecha