带预取的Spring AMQP单用户并行

Question

但是，这种设计似乎不能用于Spring-AMQP世界。在SimpleMessageListenerContainer中，对于每个AMQP使用者，所有消息都被传递到一个BlockingQueueConsumer，并且一个线程将消息从BlockingQueueConsumer的阻塞队列传递到MessageListener。尽管SimpleMessageListenerContainer支持TaskExecutor，但TaskExecutor仅用于每个使用者运行一个任务。因此，要并行处理多个消息，就必须使用多个使用者。

这就引出了一些关于spring-amqp并行性的问题。首先，我最初设计的单用户和高预取计数是实现与AMQP并行的有效方法吗？如果是这样，为什么Spring-AMQP要避开这种设计而采用每个用户的线程设计呢？是否可以定制Spring-AMQP来实现单用户并行？

Answer 1

Spring AMQP是针对rabbit客户端库的早期版本设计的，该版本每个连接只有一个线程。

DefaultConsumer的handleDelivery方法可以生成一个新的Runnable，该Runnable执行工作并在工作结束时确认消息。

这并不比简单地增加concurrentconsumers多得多--唯一的区别是每个线程都有一个consumer，但没有太多的开销。