Spring AMQP在队列Bean上设置预取计数

Question

如何为此队列使用者设置预取计数？

@Bean
public Queue eventQueue(AmqpAdmin amqpAdmin) {
    Queue queue = QueueBuilder.durable(EVENT_QUEUE_NAME)
            ...
            .build();

    TopicExchange topicExchange = new TopicExchange(TOPIC_EXCHANGE, true, false);

    amqpAdmin.declareBinding(BindingBuilder
            .bind(queue)
            .to(topicExchange)
            .with(EVENT_ROUTING_KEY));

    return queue;
}

文档指出，这是一个容器配置，但在我的factory bean上设置它不起作用，默认值为250：

    @Bean
    public SimpleRabbitListenerContainerFactory containerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setPrefetchCount(10); // doesn't work; defaults to 250
        return factory;
    }

更新

根据@GaryRussell下面的评论，我测试了默认的rabbitListenerContainerFactory，还验证了我的Spring Boot配置。rabbitmq。听众。易于理解的预取正在AbstractRabbitListenerContainerFactoryConfigurer中使用。但是，当我查看RabbitMQ中的队列使用者时，我可以看到我使用默认容器设置定义的队列仍然具有250的预取计数：

我使用RabbitMQ管理面板作为真相的来源。我不认为这是在撒谎，因为我有一堆使用自定义容器实例化的动态队列，并且它们确实具有非默认（正确）的prefetchCounts。我还在Spring容器启动中验证了只有一个（预期）RabbitListenerContainerFactorybean。

Answer 1

预回迁不是队列属性，而是使用者属性。

你的听众长什么样？

您正在为容器工厂使用非标准名称。

您要么需要将容器工厂属性添加到@RabbitListener，要么需要将您的bean重命名为RabbitListenerContainerFactory（覆盖Boot定义的工厂@Bean）。

而且

amqpAdmin.declareBinding(BindingBuilder

您不应该在bean定义中与经纪人交谈——现在还为时过早。

只需将队列、交换和绑定添加为Bean，您也可以在应用程序中设置预取。属性/yaml文件（如果使用Spring Boot）。管理员将在第一次打开连接时找到并声明它们。

编辑

还有别的事情。。。

@SpringBootApplication
public class So62049769Application {

    public static void main(String[] args) {
        SpringApplication.run(So62049769Application.class, args);
    }

    @Bean
    public Queue queue() {
        return new Queue("so62049769");
    }

    @RabbitListener(queues = "so62049769")
    public void listen(String in) {
        System.out.println(in);
    }

}

spring.rabbitmq.listener.simple.prefetch=42