Wie kann ich die Menge an Nachrichten, die von ActiveMQ in meiner C# -App kommen, drosseln?

Question

Ich benutze ActiveMQ in einem .Net-Programm und ich bin mit Nachrichten-Ereignissen überflutet.

Kurz gesagt, wenn ich ein Queue-Ereignis 'onMessage (IMessage receivedMsg)' bekomme, lege ich die Nachricht in eine interne Warteschlange, aus der X-Threads ihre Sache machen.

Zuerst hatte ich: "AcknowledgementMode.AutoAcknowledge" beim Erstellen der Sitzung, so nehme ich an, dass alle Nachrichten in der Warteschlange wurde abgesaugt und in die Speicherwarteschlange (was ist riskant, da mit einem Absturz, alles ist) hat verloren).

Also habe ich verwendet: 'AcknowledgementMode.ClientAcknowledge' beim Erstellen der Sitzung, und wenn ein Arbeiter mit der Nachricht fertig war, ruft er die 'commit()' Methode für die Nachricht auf. Allerdings werden immer noch alle Nachrichten aus der Warteschlange abgesaugt.

Wie kann ich konfigurieren, dass NUR eine X Anzahl von Nachrichten verarbeitet wird oder sich in einer internen Warteschlange befindet und nicht alles sofort heruntergeladen wird?

Answer 1

Sind Sie auf .NET 4.0? Sie könnten eine BlockingCollection verwenden. Stellen Sie es auf die maximale Menge ein, die es enthalten kann. Sobald ein Thread versucht, ein überschüssiges Element einzufügen, blockiert die Add-Operation, bis die Sammlung erneut unter den Schwellenwert fällt.

Vielleicht würde das für die Drosselung tun?

Es gibt auch eine API für die Drosselung im Rx-Framework, aber ich weiß nicht, wie es implementiert ist. Wenn Sie Ihre Queue-Quelle als Observable implementieren, wird diese API für Sie verfügbar sein, aber ich weiß nicht, ob dies Ihren Anforderungen entspricht.

Answer 2

Sie können den Client-Vorabruf so einstellen, dass gesteuert wird, wie viele Nachrichten der Client gesendet wird. Wenn die Sitzung automatisch bestätigt wird, bestätigt der Client nur dann eine Nachricht, wenn sie über den Rückruf von onMessage oder einen synchronen Empfang an Ihre App gesendet wurde. Standardmäßig ruft der Client 1000 Nachrichten vom Broker ab. Wenn der Client ausfällt, werden diese Nachrichten an einen anderen Client zurückgegeben, wenn dies eine Warteschlange ist. Andernfalls werden sie für ein Thema einfach verworfen, da es sich um einen broadcastbasierten Kanal handelt. Wenn Sie den Vorabruf auf 1 setzen, wird Ihr Client nur eine Nachricht vom Server gesendet, und jedes Mal, wenn Ihr onMessage-Rückruf abgeschlossen ist, wird eine neue Nachricht gesendet, da der Client diese Nachricht bestätigt, dh wenn die Sitzung in Auto Ack ist Modus.

finden Sie in der NMS-Konfigurationsseite für alle Optionen: http://activemq.apache.org/nms/configuring.html

Grüße

Tim.