2.2 版本相对于 2.1 版本的变更
本节描述了 2.1 版本与 2.2 版本之间的变更。
包变更
以下类/接口已从 org.springframework.amqp.rabbit.core.support 移动到 org.springframework.amqp.rabbit.batch
-
BatchingStrategy -
MessageBatch -
SimpleBatchingStrategy
此外,ListenerExecutionFailedException 已从 org.springframework.amqp.rabbit.listener.exception 移动到 org.springframework.amqp.rabbit.support。
依赖变更
JUnit (4) 现在是一个可选依赖项,将不再作为传递依赖项出现。
spring-rabbit-junit 模块现在是 spring-rabbit-test 模块中的一个 编译时 依赖项,以便在仅使用单个 spring-rabbit-test 即可获得 AMQP 组件的完整测试工具栈时,提供更好的目标应用开发体验。
[[-breaking-api-changes]] == API 破坏性变更
JUnit (5) 的 RabbitAvailableCondition.getBrokerRunning() 现在返回一个 `BrokerRunningSupport` 实例,而不是依赖于 JUnit 4 的 `BrokerRunning`。它们拥有相同的 API,因此只需更改任何引用的类名即可。更多信息请参见 JUnit5 Conditions。
@RabbitListener 变更
现在可以在每个监听器上配置一个 executor,覆盖工厂配置,以便更容易地识别与该监听器相关的线程。现在可以使用注解的 ackMode 属性覆盖容器工厂的 acknowledgeMode 属性。更多信息请参见 覆盖容器工厂属性。
使用 批处理 时,@RabbitListener 方法现在可以在一次调用中接收完整的消息批次,而无需逐条接收。
逐条接收批量消息时,最后一条消息的 isLastInBatch 消息属性会被设置为 true。
此外,接收到的批量消息现在包含 amqp_batchSize 头信息。
监听器还可以消费在 SimpleMessageListenerContainer 中创建的批次,即使该批次不是由生产者创建的。更多信息请参见 选择容器。
Jackson2JsonMessageConverter 现在支持 Spring Data Projection 接口。更多信息请参见 使用 Spring Data Projection 接口。
如果不存在 contentType 属性,或者它是默认值 (application/octet-string),Jackson2JsonMessageConverter 现在会假定内容是 JSON。更多信息请参见 从 Message 转换。
类似地,如果不存在 contentType 属性,或者它是默认值 (application/octet-string),Jackson2XmlMessageConverter 现在会假定内容是 XML。更多信息请参见 Jackson2XmlMessageConverter。
当 @RabbitListener 方法返回结果时,bean 和 `Method` 现在可在回复消息属性中获取。这允许配置 beforeSendReplyMessagePostProcessor,例如,在回复中设置一个头信息以指示服务器上调用了哪个方法。更多信息请参见 回复管理。
现在可以配置 ReplyPostProcessor 以便在发送回复消息之前对其进行修改。更多信息请参见 回复管理。
AMQP 日志 Appender 变更
Log4J 和 Logback 的 AmqpAppender 现在支持 verifyHostname SSL 选项。
此外,这些 appender 现在可以配置为不将 MDC 条目作为头信息添加。已引入 addMdcAsHeaders 布尔选项来配置这种行为。
这些 appender 现在支持 SaslConfig 属性。
更多信息请参见 日志子系统 AMQP Appender。
MessageListenerAdapter 变更
MessageListenerAdapter 现在提供了一个新的 buildListenerArguments(Object, Channel, Message) 方法来构建传递给目标监听器的参数数组,旧的方法已被弃用。更多信息请参见 MessageListenerAdapter。
[[exchange/queue-declaration-changes]] == 交换机/队列声明变更
用于由 RabbitAdmin 声明 Exchange 和 Queue 对象的 ExchangeBuilder 和 QueueBuilder 流式 API 现在支持“已知”参数。更多信息请参见 队列和交换机的 Builder API。
RabbitAdmin 有一个新的属性 explicitDeclarationsOnly。更多信息请参见 条件声明。
连接工厂变更
CachingConnectionFactory 有一个新的属性 shuffleAddresses。当提供 broker 节点地址列表时,列表在创建连接之前会被打乱,从而使连接尝试的顺序随机化。更多信息请参见 连接到集群。
使用 Publisher confirms 和 returns 时,回调现在在连接工厂的 executor 上调用。这避免了如果在回调中执行 rabbit 操作可能导致的 amqp-clients 库中的死锁。更多信息请参见 关联的 Publisher Confirms 和 Returns。
此外,publisher confirm 类型现在使用 ConfirmType 枚举指定,而不是两个互斥的 setter 方法。
启用 SSL 时,RabbitConnectionFactoryBean 现在默认使用 TLS 1.2。更多信息请参见 RabbitConnectionFactoryBean 和配置 SSL。
新的 MessagePostProcessor 类
已添加 DeflaterPostProcessor 和 InflaterPostProcessor 类,分别用于在消息的 content-encoding 设置为 deflate 时支持压缩和解压缩。
其他变更
Declarables 对象(用于声明多个队列、交换机、绑定)现在为每种类型提供了过滤的 getter 方法。更多信息请参见 声明交换机、队列和绑定的集合。
现在可以在 RabbitAdmin 处理声明之前自定义每个 Declarable bean。更多信息请参见 自动声明交换机、队列和绑定。
已向 QueueBuilder 添加 singleActiveConsumer() 方法,用于设置 x-single-active-consumer 队列参数。更多信息请参见 队列和交换机的 Builder API。
类型为 Class> 的出站头信息现在使用 getName() 而非 toString() 进行映射。更多信息请参见 消息属性转换器。
现在支持恢复生产者创建的失败批次。更多信息请参见 批处理监听器重试。