Panoramica delle code di messaggi
MQF (Message Queue Framework) è un sistema che consente a un modulo di pubblicare messaggi nelle code. Definisce inoltre i consumer che riceveranno i messaggi in modo asincrono. MQF supporta più broker di messaggistica:
- RabbitMQ - Gestore di messaggistica primario, che fornisce una piattaforma scalabile per l'invio e la ricezione di messaggi. Include un meccanismo per l’archiviazione dei messaggi non consegnati ed è basato sulla specifica AMQP (Advanced Message Queuing Protocol) 0.9.1.
- Apache ActiveMQ Artemis - Gestore di messaggistica alternativo che utilizza il protocollo STOMP (Simple Text Oriented Messaging Protocol) per la messaggistica affidabile e scalabile. Introdotto in Adobe Commerce 2.4.6 e versioni successive.
RabbitMQ (AMQP)
Il diagramma seguente illustra il framework della coda di messaggi:
-
Un editore è un componente che invia messaggi a uno scambio. Sa a quale scambio pubblicare e il formato dei messaggi che invia.
-
Uno scambio riceve messaggi dagli editori e li invia alle code. Sebbene RabbitMQ supporti più tipi di scambi, Commerce utilizza solo gli scambi di argomenti. Un argomento include una chiave di instradamento, che contiene stringhe di testo separate da punti. Il formato del nome di un argomento è
string1.string2, ad esempiocustomer.createdocustomer.sent.email.Il broker consente di utilizzare i caratteri jolly per impostare le regole per l’inoltro dei messaggi. È possibile utilizzare un asterisco (
*) per sostituire una stringa o un cancelletto (#) per sostituire 0 o più stringhe. Ad esempio,customer.*filtrerebbe sucustomer.createecustomer.delete, ma non sucustomer.sent.email. Tuttaviacustomer.#filtrerebbe sucustomer.create,customer.deleteecustomer.sent.email. -
Una coda è un buffer che memorizza i messaggi.
-
Un consumatore riceve messaggi. Sa quale coda consumare. Può mappare i processori del messaggio a una coda specifica.
Apache ActiveMQ Artemis (STOMP)
In alternativa a RabbitMQ, Adobe Commerce supporta anche Apache ActiveMQ Artemis come broker di messaggistica utilizzando il protocollo STOMP (Simple Text Oriented Messaging Protocol).
Il diagramma seguente illustra il framework STOMP con ActiveMQ Artemis:
Componenti framework STOMP
-
Un editore è un componente che invia messaggi a una destinazione (coda o argomento). Sa a quale destinazione pubblicare e il formato dei messaggi che invia.
-
Una destinazione in STOMP svolge un ruolo simile agli scambi in AMQP, ricevendo messaggi dagli editori e instradandoli. STOMP utilizza l'indirizzamento di destinazione diretto con un modello di denominazione gerarchica utilizzando i punti: ad esempio,
customer.createdoinventory.updated.Adobe Commerce utilizza la modalità di indirizzamento ANYCAST per le destinazioni STOMP, che fornisce la consegna di messaggi point-to-point. In modalità ANYCAST, i messaggi vengono inviati a un solo consumatore da un pool di consumatori disponibili, consentendo il bilanciamento del carico e la distribuzione del lavoro tra più istanze.
-
Una coda è un buffer che memorizza i messaggi. Grazie all'indirizzamento ANYCAST, la coda assicura che i messaggi vengano inviati a un solo utente, anche quando più utenti sono connessi alla stessa destinazione.
-
Un consumatore riceve messaggi dalle destinazioni. Sa a quale destinazione abbonarsi e può elaborare i messaggi con diverse modalità di riconoscimento (auto, client o client-individuale).
Scheda MySQL (fallback)
È inoltre possibile configurare un sistema di code di messaggi di base senza utilizzare broker di messaggi esterni. In questo sistema, un adattatore MySQL memorizza i messaggi nel database. Tre tabelle di database (queue, queue_message e queue_message_status) gestiscono il carico di lavoro della coda messaggi. I lavori di cron garantiscono che i consumatori siano in grado di ricevere messaggi. Questa soluzione non è molto scalabile. Se possibile, per gli ambienti di produzione è necessario utilizzare gestori di messaggi esterni come RabbitMQ o Apache ActiveMQ Artemis.
Informazioni correlate
Per le istruzioni di installazione e configurazione: