RabbitMQ wie den Verbraucher zu drosseln

Question

Ich benutze RabbitMQ erfolgreich. Allerdings habe ich ein Problem, wo, wenn ich in der Situation bin, wo viele Nachrichten in der Warteschlange sind, der Verbraucher (ein Windows-Dienst) versucht, sie alle zu bekommen und hält dann nur an ihnen, aber nie Aktionen oder quittiert sie.

Wenn die Anzahl der Nachrichten im Bereitschaftszustand niedrig ist, dann behandeln die Verbraucher den Durchsatz gut, es ist nur, wenn es ein Problem gab und es einen Rückstand gibt, dann wird es viel zu gierig.

Gibt es eine Möglichkeit, die maximale Anzahl von Nachrichten zu konfigurieren, für die ein Konsument gleichzeitig die Verantwortung übernimmt?

Ich kann das RequestedChannelMax Feld auf RabbitMQ.Client.ConnectionFactory ist das die richtige Einstellung, um dies zu begrenzen?

Dank

Answer 1

Ein Verbraucher, wird standardmäßig so viele Nachrichten wie die Bandbreite verarbeiten kann unabhängig von der tatsächlichen Meldungsverarbeitungszeit durch den Verbraucher lesen.

Sie müssen Vorabrufwerte festlegen, indem Sie die QoS (Quality of Service) des Kanals ändern, um zu beschränken, wie viele Nachrichten gleichzeitig abgerufen werden sollen. Überprüfen Sie basic.qos here. Es hat 3 Parameter, eine Größe (in Oktetten), eine Zählung (die Anzahl der ganzen Nachrichten, die es auf einmal aufnehmen wird) und eine globale Flagge.

This blog post ist eine interessante Lektüre, wenn Sie daran interessiert sind, den Durchsatz zu optimieren und spricht über Prefetching etwa 2/3 des Weges auf der Seite.

Hoffe, dass hilft!