Was ist eine gute Event-Store/Stream-Middleware für Service-orientierte/Microservice-Architekturen

Question

Ich baue eine Microservice-Architektur und ich bin auf der Suche nach einer guten Möglichkeit, Ereignisse zu streamen.

Derzeit habe ich einen Dienst, der ein Ereignis veröffentlicht, auf das drei andere Dienste in einer bestimmten Weise reagieren müssen, die Reaktion auf dieses Ereignis soll jedoch nur einmal erfolgen.

Im Moment verwende ich RabbitMQ und mein Dienst veröffentlicht drei Nachrichten in separaten Warteschlangen, und jeder abonnierende Dienst hört eine Warteschlange. Daher kann nur eine Dienstinstanz die Nachricht annehmen und darauf reagieren.

Allerdings mag ich diesen Ansatz nicht, denn wenn ich einen neuen Abonnenten hinzufügen möchte, muss ich eine neue Warteschlange für den Veröffentlichungsdienst hinzufügen.

Ich suche im Grunde nach einer Art Middleware für einen Ereignisstrom, der mehrere Dienste einem Ereignis zuhören lässt, aber sicherstellt, dass nur eine Instanz jedes Dienstes tatsächlich auf das Ereignis reagiert.

Ich habe noch nichts gefunden, also würde ich mich über Vorschläge freuen.

Answer 1

Sie können einen Blick auf this page werfen, die erklärt, wie AMQP-Modell und damit RabbitMQ funktioniert.

Ihre Nachricht wird in einem Exchange nicht in der Warteschlange veröffentlicht. Die Vermittlungsstelle leitet die Nachricht gemäß dem Exchange-Typ und dem verknüpften Schlüssel und Routing-Schlüssel an die verknüpften Warteschlangen weiter.

Im Allgemeinen kümmern sich Verlage nicht um den Routing hinter einer Börse. Es ist das Anliegen der Konsumenten, eine Warteschlange zu erstellen und an die Börse zu binden, je nachdem, was sie verbrauchen wollen und wie.

So, wenn Ihr Produzent seine Nachrichten an die ExchangeA zum Beispiel unter Verwendung veröffentlicht ein direct exchange, Service A/B/C kann ihre Warteschlangen an diesen Austausch schaffen und binden und sie werden jedes die veröffentlichte Nachricht erhalten. Wenn ein neuer Dienst E erzeugt wird, sollte er auch eine Warteschlange für diesen Austausch erstellen und binden. Daher müssen Sie den Herausgeber nicht ändern.

Answer 2

Wir empfehlen, das PUB/SUB-Modell mit RabbitMQ zu verwenden, damit mehrere Abonnenten einzelne Warteschlangen anhören und entsprechend agieren können. Siehe: https://www.rabbitmq.com/tutorials/tutorial-three-python.html