Fusibile JBoss - Apache AMQ

In questo capitolo impareremo a conoscere ActiveMQ e come agisce da broker di messaggi per consentire alle applicazioni di comunicare tra loro.

Cos'è AMQ?

ActiveMQ è un broker di messaggi open source scritto in Java. È completamente conforme agli standard JMS 1.1.

JMS è una specifica che consente lo sviluppo di un sistema basato su messaggi. ActiveMQ funge da broker di messaggi che si trova tra le applicazioni e consente loro di comunicare in modo asincrono e affidabile.

Tipi di messaggistica

Esistono due tipi di opzioni di messaggistica spiegate di seguito per una migliore comprensione.

Punto a punto

In questo tipo di comunicazione, il broker invia messaggi a un solo consumatore, mentre gli altri consumatori aspetteranno fino a quando non riceveranno i messaggi dal broker. Nessun consumatore riceverà lo stesso messaggio.

Se non ci sono consumatori, il broker manterrà i messaggi fino a quando non ottiene un consumatore. Questo tipo di comunicazione è anche chiamato comeQueue based communicationdove il produttore invia messaggi a una coda e solo un consumatore riceve un messaggio dalla coda. Se è presente più di un consumatore, potrebbero ricevere il messaggio successivo ma non riceveranno lo stesso messaggio dell'altro consumatore.

Pubblica / Iscriviti

In questo tipo di comunicazione, il Broker invia la stessa copia dei messaggi a tutti i consumatori attivi. Questo tipo di comunicazione è anche noto comeTopic based communicationdove il broker invia lo stesso messaggio a tutti i consumatori attivi che si sono iscritti a un determinato argomento. Questo modello supporta la comunicazione unidirezionale in cui non è prevista alcuna verifica dei messaggi trasmessi.

Creazione di code e argomenti

Fuse viene fornito in bundle con ActiveMQ. Possiamo accedere ad ActiveMQ utilizzando la console FMC (l'interfaccia basata su browser per lavorare con AMQ).

Accedi a FMC utilizzando localhost:8181 e seleziona ActiveMQ tab.