rabbitmq - Spring-Rabbit模板-批量操作

Question

有人知道是否可以使用 Rabbit 模板将一组消息发送到队列吗？

显然，我可以一次发送一个，但我想在一次批量操作中完成它(以提高性能)。

谢谢!

Answer 1

您可以创建一个 BatchingRabbitTemplate 的 bean 并使用它。这是一个工作示例 bean:

@Bean
public BatchingRabbitTemplate batchingRabbitTemplate(ConnectionFactory connectionFactory) {
    BatchingStrategy strategy = new SimpleBatchingStrategy(500, 25_000, 3_000);
    TaskScheduler scheduler = new ConcurrentTaskScheduler();
    BatchingRabbitTemplate template = new BatchingRabbitTemplate(strategy, scheduler);
    template.setConnectionFactory(connectionFactory);
    // ... other settings
    return template;
}

现在您可以在另一个 bean 中注入(inject) BatchingRabbitTemplate 并使用它:

@Bean
public ApplicationRunner runner(BatchingRabbitTemplate template) {
    MessageProperties props = //...
    return args -> template.send(new Message("Test").getBytes(), props);
}