RabbitMQ-Konsumenten addieren sich nicht

Question

Wir haben eine Java-Anwendung, die Nachrichten von Rabbitmq mit Spring AMQP erhält. Bei einigen Warteschlangen nimmt die Anzahl der Verbraucher nicht zu, was zu einer langsameren Nachrichtenübermittlungsrate führt. z.B. obwohl der maximale Verbraucher auf 50 eingestellt ist, blieb die Anzahl der Verbraucher für die meiste Zeit 6 für die Last von 9000 Nachrichten.

Dies ist jedoch bei anderen Warteschlangen nicht der Fall. i..e Verbraucher zählen bis 35 für andere Warteschlangen erreicht.

Wir verwenden die setMaxConcurrentConsumers-API von SimpleMessageListenerContainer zum Festlegen von maximalen Konsumenten.

Kann mir bitte jemand helfen, das zu verstehen?

Konfiguration:
Anzahl der gleichzeitigen Verbraucher: 4
Anzahl von max gleichzeitige Verbraucher: 50

Answer 1

Wenn Fragen wie diese zu fragen, müssen Sie immer Konfiguration zeigen. Bearbeiten Sie Ihre Frage mit vollständigen Details.

Es hängt von Ihrer Konfiguration ab. Standardmäßig wird ein neuer Benutzer nur einmal alle 10 Sekunden hinzugefügt, und nur dann, wenn ein vorhandener Kunde 10 Nachrichten ohne Lücken erhält.

Wenn diese Frage immer noch nicht beantwortet wird, aktivieren Sie die DEBUG-Protokollierung. Wenn Sie es nicht herausfinden können, posten Sie das Protokoll (mindestens startConsumerMinInterval Millisekunden) irgendwo wie Pastebin oder Dropbox.