跳到主要内容
版本:4.1.1

批量消息

Doubao 中英对照 Batched Messages

批量消息(由生产者创建)会被监听容器自动拆批(使用 springBatchFormat 消息头)。拒绝批次中的任何一条消息都会导致整批被拒绝。有关批处理的更多信息,请参阅批处理。

从 2.2 版开始,SimpleMessageListenerContainer 可用于在消费者侧创建批次(即生产者发送的是离散消息的情况)。

设置容器属性 consumerBatchEnabled 以启用此特性。deBatchingEnabled 也必须为 true,这样容器才负责处理这两种类型的批次。当 consumerBatchEnabled 为 true 时,实现 BatchMessageListener 或 ChannelAwareBatchMessageListener。从 2.2.7 版开始,SimpleMessageListenerContainer 和 DirectMessageListenerContainer 都可以把生产者创建的批次拆为 List<Message>。有关将此特性与 @RabbitListener 一起使用的信息,请参阅带批处理的 @RabbitListener。