Overzicht van wachtrij met berichten
Het Kader van de Rij van het Bericht (MQF) is een systeem dat een module toestaat om berichten aan rijen te publiceren. Het bepaalt ook de consumentendie de berichten asynchroon zullen ontvangen. MQF gebruikt RabbitMQals overseinenmakelaar, die een scalable platform voor het verzenden van en het ontvangen van berichten verstrekt. Het omvat ook een mechanisme voor het opslaan van niet-geleverde berichten. RabbitMQ is gebaseerd op de Geavanceerde specificatie 0.9.1 van het een rij vormen van het Bericht van het Protocol (AMQP).
Het volgende diagram illustreert het Kader van de Rij van het Bericht:
-
Een uitgever is een component die berichten naar een uitwisseling verzendt. Het weet aan welke uitwisseling te publiceren aan en het formaat van de berichten het verzendt.
-
Een uitwisseling ontvangt berichten van uitgevers en verzendt hen naar rijen. Hoewel RabbitMQ veelvoudige types van uitwisseling steunt, gebruikt Commerce onderwerpuitwisseling slechts. Een onderwerp omvat een verpletterende sleutel, die tekstkoorden bevat die door punten worden gescheiden. De indeling voor een onderwerpnaam is
string1.string2: bijvoorbeeldcustomer.createdofcustomer.sent.email.De makelaar staat u toe om vervangingen te gebruiken wanneer het plaatsen van regels voor het door:sturen van berichten. U kunt een asterisk (
*) gebruiken om één koord of een pond teken (#) te vervangen om 0 of meer koorden te vervangen.customer.*filtert bijvoorbeeld opcustomer.createencustomer.delete, maar nietcustomer.sent.email.customer.#filtert echter opcustomer.create,customer.deleteencustomer.sent.email. -
Een wachtrij is een buffer die berichten opslaat.
-
Een consument ontvangt berichten. Het weet welke rij te verbruiken is. Het kan bewerkers van het bericht aan een specifieke rij in kaart brengen.
Een basissysteem voor een wachtrij met berichten kan ook worden ingesteld zonder RabbitMQ te gebruiken. In dit systeem slaat een MySQL-adapter berichten op in de database. Drie databasetabellen (queue, queue_message en queue_message_status ) beheren de werkbelasting van de wachtrij met berichten. Cron jobs zorgen ervoor dat de consumenten berichten kunnen ontvangen. Deze oplossing is niet erg schaalbaar. RabbitMQ moet indien mogelijk worden gebruikt.