2016-05-17 4 views
0

Wie Implementieren der Arbeitswarteschlange in Hase mq mit easynetq-Treiber?Implementieren von Arbeitswarteschlangenmuster mit easynetq-Treiber auf Kaninchen mq

Auch Bestätigung in beiden Herausgeber und Abonnenten ist wünschenswert.

Die Idee ist, dass eine Nachricht nur von einem einzelnen Teilnehmer verarbeitet wird. Ist dies ein Standardverhalten oder wird die Nachricht vom Publisher an den Abonnenten weitergeleitet?

+0

Hallo. Dies ist eine sehr weit gefasste Frage und klingt wie Sie sollten lesen Sie die (gute) Kaninchen mq Dokumentation. Edit: Eigentlich, wenn Sie planen, easynetq zu verwenden, haben sie auch eine Menge guter Dokumentation darüber, wie Sie genau das tun können, wonach Sie suchen. –

+0

Es scheint, dass das Standardverhalten für Publish-Subskriptionsmuster direkten Austausch statt Fanout verwendet, was ich annahm. Daher erhält nur ein Verbraucher die Nachricht, anstatt dass mehrere Verbraucher die veröffentlichte Nachricht erhalten. – TrustyCoder

+0

@TrustyCoder Was genau ist Ihr gewünschtes Verhalten? Wenn Sie das Standard-Pub/Sub-Beispiel für easynetq verwenden, haben Sie eine verwendbare Worker Queue-Einrichtung. –

Antwort

0

Das einfache Publish-Subskriptionsmuster implementiert das Arbeitswarteschlangenmuster. Wenn zwei Consumer vorhanden sind, erhielt der erste Consumer alle Nachrichten, da der Prefetch-Wert 50 (Standard) war, der verhindert, dass der andere Consumer keine Nachrichten erhält.