Optimieren Verbrauchende Nachrichten von Rabbitmq mit Spring Integration

Question

Ich versuche eine IntegrationFlowFactory zu erstellen, um einfach Integrationsflüsse für die Übergabe von Ereignissen zwischen Anwendungskontexten zu erstellen.

Alles scheint zu funktionieren, und Ereignisse werden sehr schnell veröffentlicht.

Allerdings kann ich nicht herausfinden, warum der Verbrauch so langsam ist. Das Hinzufügen von ConcurrentConsumers oder das Ändern von PrefetchCount scheint nichts zu ändern.

Andere Beiträge sprechen über das Netzwerk ist langsam, aber wie Sie in der RabbitConfig sehen kann, verwende ich localhost.

Ich habe ein Repository mit meiner Feder Integrations Beispiel hier: https://github.com/teplyuska/spring-integration-example

Answer 1

Ihr Problem ist hier:

Amqp.inboundGateway(getListenerContainer(queue, concurrentConsumers, prefetchCount) 

Inzwischen Ihre Abströmung ist Einweg und zurück keine Antwort :

.handle(p -> { 
       UpdateSecretEvent payload = (UpdateSecretEvent) p.getPayload(); 
       System.out.println("Account: " + payload.getAccountId() + " has secret: " + payload.getNewSecret()); 
}) 
.get(); 

oder

.handle(p -> { 
       UpdateEmailEvent payload = (UpdateEmailEvent) p.getPayload(); 
       System.out.println("Account: " + payload.getAccountId() + " has email: " + payload.getEmail()); 
}) 
.get(); 

So, das AmqpInboundGateway wartet auf die Antwort in seiner MessagingTemplate.sendAndReceive() für die private static final long DEFAULT_TIMEOUT = 1000L;

zum Amqp.inboundAdapter() Schalt es funktioniert der Trick.