Pourquoi les performances des consommateurs spring-amqp sont-elles très lentes ?

J'ai commencé producteur et consommateur simultanément. Après 6 heures, le producteur a produit environ 6 crores de messages dans la file d'attente et a arrêté le producteur après 6 heures, mais le consommateur fonctionne en continu, même après avoir exécuté 18 heures, 4 crores de messages sont toujours en file d'attente. Quelqu'un pourrait-il me dire pourquoi les performances des consommateurs sont très lentes ?

Merci d'avance!

@Bean
 public SimpleMessageListenerContainer listenerContainer() {
 SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
 container.setConnectionFactory(connectionFactory());
 container.setQueueNames(this.queueName);
 container.setMessageListener(new MessageListenerAdapter(new TestMessageHandler(), new JsonMessageConverter()));
 return container;
 }
@Bean
 public ConnectionFactory connectionFactory() {
 CachingConnectionFactory connectionFactory = new CachingConnectionFactory(
 "localhost");
 connectionFactory.setUsername("guest");
 connectionFactory.setPassword("guest");
 return connectionFactory;
 }
 @Bean
 public RabbitTemplate rabbitTemplate() {
 RabbitTemplate template = new RabbitTemplate(connectionFactory());
 template.setMessageConverter(new JsonMessageConverter());
 template.setRoutingKey(this.queueName);
 template.setQueue(this.queueName);
 return template;
 }
 public class TestMessageHandler {
 // receive messages
 public void handleMessage(MessageBeanTest msgBean) {
  // Storing bean data into CSV file
 }
 }

Solution du problème

Selon la suggestion de Gary, vous pouvez les définir comme suit. Découvrez @RabbitListener

@Bean
public SimpleRabbitListenerContainerFactory listenerContainer( {
 SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
 factory.setConnectionFactory(baseConfig.connectionFactory());
 factory.setConcurrentConsumers(7); // choose a value
 factory.setPrefetchCount(1); // how many messages per consumer at a time
 factory.setMaxConcurrentConsumers(10); // choose a value
 factory.setDefaultRequeueRejected(false); // if you want to deadletter
 return factory;
}