Übersicht über Nachrichtenwarteschlangen
Das Message Queue Framework (MQF) ist ein System, mit dem ein Modul Nachrichten in Warteschlangen veröffentlichen kann. Außerdem werden die consumer definiert, die die Nachrichten asynchron empfangen. Der MQF verwendet RabbitMQ als Messaging-Broker, der eine skalierbare Plattform zum Senden und Empfangen von Nachrichten bietet. Es enthält auch einen Mechanismus zum Speichern nicht zugestellter Nachrichten. RabbitMQ basiert auf der AMQP-Spezifikation 0.9.1 (Advanced Message Queuing Protocol).
Das folgende Diagramm zeigt das Message Queue Framework:
-
Ein Herausgeber ist eine Komponente, die Nachrichten an einen Austausch sendet. Sie weiß, an welchen Austausch sie veröffentlichen soll und welches Format sie sendet.
-
Ein Austausch empfängt Nachrichten von Herausgebern und sendet sie an Warteschlangen. Obwohl RabbitMQ mehrere Arten von Austauschen unterstützt, verwendet Commerce nur den Themenaustausch. Ein Thema enthält einen Routing-Schlüssel, der durch Punkte getrennte Textzeichenfolgen enthält. Das Format für einen Themennamen ist
string1.string2: z. B.customer.createdodercustomer.sent.email.Der Broker ermöglicht Ihnen die Verwendung von Platzhaltern bei der Festlegung von Regeln für die Weiterleitung von Nachrichten. Sie können ein Sternchen (
*) verwenden, um die Zeichenfolge one oder ein Rautenzeichen (#) zu ersetzen, um 0 oder mehr Zeichenfolgen zu ersetzen. Beispielsweise würdecustomer.*nachcustomer.createundcustomer.deletefiltern, aber nicht nachcustomer.sent.email.customer.#würde jedoch nachcustomer.create,customer.deleteundcustomer.sent.emailfiltern. -
Eine Warteschlange ist ein Puffer, der Nachrichten speichert.
-
Ein Verbraucher erhält Nachrichten. Er weiß, welche Warteschlange zu verbrauchen ist. Er kann Prozessoren der Nachricht einer bestimmten Warteschlange zuordnen.
Ein einfaches Nachrichtenwarteschlangesystem kann auch ohne Verwendung von RabbitMQ eingerichtet werden. In diesem System speichert ein MySQL-Adapter Nachrichten in der Datenbank. Drei Datenbanktabellen (queue, queue_message und queue_message_status) verwalten die Arbeitslast der Nachrichtenwarteschlange. Cron-Aufträge stellen sicher, dass die Verbraucher Nachrichten empfangen können. Diese Lösung ist nicht sehr skalierbar. RabbitMQ sollte nach Möglichkeit verwendet werden.