RabbitMQ und round-robin-Thema Austausch
Ich bin auf der Suche nach einer beraten, wie man am besten konfigurieren Sie meine rabbitMQ Austausch.
Ich versuche, ein Thema exchange in einer round-robin-Methode. Jeder Verbraucher hat seine eigenen (eindeutigen) namens-Warteschlange angefügt, um ein Thema exchange. Ich möchte die exchange-round-robin-Nachrichten an jedem Verbraucher die Warteschlange für den "gleichen" Thema - sagen wir *.log
zum Beispiel.
Ich habe versucht, mehrere Kombinationen und nur zu sein scheinen in der Lage, gleichzeitig Nachrichten an die consumer-queues, die effektiv bedeutet, dass ich der Verarbeitung der Meldung zweimal, einmal in jeder Verbraucher.
Zur Klarheit, ich habe auch ein fanout exchange, die ich verwenden, um "Kontrolle" der Verbraucher (start, stop etc).dies sollte in Kraft bleiben in jedem möglichem Ergebnis.
Keine Anleitung, wie man am besten zur Erreichung der genannten Ergebnis wäre toll.
- Warum wollen Sie round-robin-Nachrichten? wenn Sie möchten, verteilen Sie die Arbeit dann pump alles in eine Warteschlange und haben mehrere "log-Datei" die Verbraucher Lesen Sie aus dieser Warteschlange...
- Suche, um herauszufinden, die gleichen. welche Lösung haben Sie für diese?
- Ich löste dies mit e2e (exchange-to-exchange -) Bindungen. stackoverflow.com/a/39577177/67065
Du musst angemeldet sein, um einen Kommentar abzugeben.
Der trick ist, dass jeder Arbeiter/Verbraucher, dass Sie möchten, round-robin zwischen, um das setup eine Warteschlange, und alle verwenden die gleichen Warteschlange, statt eigene zu erstellen.
So könnte man erstellen Sie eine Warteschlange namens "log" für alle die "melden" - Arbeiter. Erstellen Sie eine andere Warteschlange für sagen wir "foo" für alle "foo" Arbeitnehmer. Anfragen geliefert werden round-robin für alle Verbraucher die gleichen Warteschlange.