RabbitMQ Java-Client hört auf, Nachrichten zu konsumieren

Question

Meine Anwendung verbraucht einige Nachrichten von RabbitMQ und verarbeitet sie. Ich habe etwa 10 Warteschlangen und jede Warteschlange hat bis zu zehn Verbraucher (Threads). Ich habe einen Prefetch von 5. Ich verwende mein Setup in Heroku mit dem CloudAMQP-Plugin (RabbitMQ als Dienst).

Ich bin mit den Standard-Heartbeat und Connection Timeout-Einstellungen (60 Sekunden) ausgeführt.

Meine Java-Anwendung ist eine Spring-Boot-Anwendung mit der Feder-Kaninchen-Bibliothek.

Versionen:

RabbitMQ 3.5.3 
Erlang 17.5.3 
Java 1.8 
Spring boot 1.3.2.RELEASE 
Spring rabbit 1.5.3.RELEASE 

Das Problem ist, dass für die Verbraucher von einer bestimmten Warteschlange Stop raubend Nachrichten nach einiger Zeit. Wenn ich meine Java-Anwendung neu starte, funktioniert alles einwandfrei. Die anderen Warteschlangen werden jedoch normal verbraucht. Keine Fehler auf der Anwendungsseite. Auf dem Protokollstrom Seite des Kaninchens Ich sehe einige Einträge wie

= REPORT==== 2016-08-02 15:53:32 UTC === 
closing AMQP connection <SOMETHING> (SOMETHING_ELSE -> SOMETHING_ELSE_ELSE): 
{heartbeat_timeout,running} 

ich lokal oder in einer Testumgebung in Heroku nicht wiedergeben kann.

aktualisieren

Der folgende Code kann in AMQConnection.class

int heartbeat = negotiatedMaxValue(this.requestedHeartbeat, 
            connTune.getHeartbeat()); 


private static int negotiatedMaxValue(int clientValue, int serverValue) { 
     return (clientValue == 0 || serverValue == 0) ? 
      Math.max(clientValue, serverValue) : 
      Math.min(clientValue, serverValue); 
} 

ich über 60 Sekunden (das ist, was ich bin immer vom Server des Herzschlages kann nicht den Wert erhöhen finden).

Answer 1

Leider scheint dies ein Netzwerkproblem. Dies könnte an ein paar Dinge liegen:

Der CloudAMQP-Dienst hat einige Probleme und tötet Ihre Verbindung (nicht wahrscheinlich, da Ihre anderen Verbraucher in Ordnung sind).

Ihr CloudAMQP-Plan erlaubt nicht so viele gleichzeitige Verbindungen wie Sie möchten. Haben Sie überprüft, ob Sie einen ausreichend hohen Plan haben, um alle Ihre Kunden zu unterstützen? https://elements.heroku.com/addons/cloudamqp

Ihr Heroku-Prüfpunkt mit dem fraglichen Verbraucher wird neu gestartet, wodurch die Verbindung unterbrochen wird. Heroku Dynos starten regelmäßig neu. Wenn Ihre Dynos nicht ordnungsgemäß neu gestartet werden können, sollten Sie untersuchen, warum.

Einer Ihrer Heroku-Dyna ist mit Netzwerkproblemen verbunden (in diesem Fall wird er wahrscheinlich ohne Ihr Eingreifen neu gestartet).

Eine Möglichkeit, alle Ihre Dynos zum Neustart zu zwingen, besteht darin, $ heroku ps:restart auszuführen. Dadurch wird Heroku gezwungen, Ihre Dynos neu zu starten, was häufig bedeutet, dass Sie sie auf einen neuen EC2-Host verschieben müssen. Dies kann helfen, wenn es sich um ein einmaliges Problem handelt.