此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring AMQP 3.2.6spring-doc.cadn.net.cn

批处理消息

批处理消息(由生产者创建)由侦听器容器自动取消批处理(使用springBatchFormatmessage header) 的 Message 标头)。 拒绝批处理中的任何邮件会导致整个批处理被拒绝。 有关批处理的更多信息,请参阅批处理spring-doc.cadn.net.cn

从 2.2 版开始,SimpleMessageListenerContainer可用于在消费者端(生产者发送离散消息的地方)创建批处理。spring-doc.cadn.net.cn

设置容器属性consumerBatchEnabled以启用此功能。deBatchingEnabled还必须为 true,以便容器负责处理这两种类型的批次。 实现BatchMessageListenerChannelAwareBatchMessageListener什么时候consumerBatchEnabled是真的。 从 2.2.7 版开始,两个SimpleMessageListenerContainerDirectMessageListenerContainer可以将生产者创建的批次取消批处理为List<Message>. 请参阅 @RabbitListener 与批处理 有关将此功能与@RabbitListener.spring-doc.cadn.net.cn