自 2.0 以来 2.1 中的更改

AMQP 客户端库

Spring AMQP 现在使用 5.4.x 版本的amqp-client库。 默认情况下,此客户端配置了自动恢复。 请参阅 RabbitMQ 自动连接/拓扑恢复spring-doc.cadn.net.cn

从版本 4.0 开始,客户端默认启用自动恢复。 虽然与此功能兼容,但 Spring AMQP 有自己的恢复机制,通常不需要 Client 端恢复功能。 我们建议禁用amqp-client自动恢复,以避免AutoRecoverConnectionNotCurrentlyOpenException代理可用但连接尚未恢复的实例。 从版本 1.7.1 开始, Spring AMQP 禁用它,除非你显式地创建自己的 RabbitMQ 连接工厂并将其提供给CachingConnectionFactory. RabbitMQ 函数ConnectionFactoryRabbitConnectionFactoryBean默认情况下,也禁用了该选项。

套件更改

某些类已移至不同的包。 大多数是内部类,不会影响用户应用程序。 两个例外是ChannelAwareMessageListenerRabbitListenerErrorHandler. 这些接口现在位于org.springframework.amqp.rabbit.listener.api.spring-doc.cadn.net.cn

发布者确认更改

当存在未完成的确认时,启用了发布者确认的通道不会返回到缓存中。 有关更多信息,请参阅 Correlated Publisher Confirms and Returnsspring-doc.cadn.net.cn

Listener Container Factory 改进

现在,您可以使用侦听器容器工厂创建任何侦听器容器,而不仅仅是那些用于@RabbitListenerannotations 或@RabbitListenerEndpointRegistry. 有关更多信息,请参阅使用容器工厂spring-doc.cadn.net.cn

ChannelAwareMessageListener现在继承自MessageListener.spring-doc.cadn.net.cn

Broker 事件侦听器

一个BrokerEventListener用于将选定的代理事件发布为ApplicationEvent实例。 有关更多信息,请参阅 Broker Event Listenerspring-doc.cadn.net.cn

RabbitAdmin 更改

RabbitAdmin发现 bean 类型的Declarables(这是Declarable - Queue,ExchangeBinding对象)并在代理上声明包含的对象。 不建议用户使用旧的声明机制<Collection<Queue>>(和其他) 并且应该使用Declarablesbeans 来代替。 默认情况下,旧机制处于禁用状态。 有关更多信息,请参见Declaring Collections of Exchanges, Queues, and Bindingsspring-doc.cadn.net.cn

AnonymousQueue实例现在使用x-queue-master-locator设置为client-local默认情况下,确保在应用程序连接到的节点上创建队列。 有关更多信息,请参阅 配置 Brokerspring-doc.cadn.net.cn

RabbitTemplate 更改

您现在可以配置RabbitTemplate使用noLocalReplyConsumer选项来控制noLocal标志sendAndReceive()操作。 有关更多信息,请参阅请求/回复消息。spring-doc.cadn.net.cn

CorrelationData对于发布者确认,现在有一个ListenableFuture,您可以使用它来获取确认,而不是使用回调。 启用返回和确认后,关联数据(如果提供)将填充返回的消息。 有关更多信息,请参阅 Correlated Publisher Confirms and Returnsspring-doc.cadn.net.cn

一个名为replyTimedOut现在提供以通知子类 Reply 已超时,从而允许进行任何状态清理。 有关更多信息,请参阅 Reply Timeout (回复超时)。spring-doc.cadn.net.cn

您现在可以指定ErrorHandler在将 request/reply 与DirectReplyToMessageListenerContainer(默认值)在传递回复时发生异常(例如,延迟回复)。 看setReplyErrorHandlerRabbitTemplate. (也是从 2.0.11 开始)。spring-doc.cadn.net.cn

消息转换

我们引入了一个新的Jackson2XmlMessageConverter支持将消息从 XML 格式转换为 XML 格式。 看Jackson2XmlMessageConverter了解更多信息。spring-doc.cadn.net.cn

管理 REST API

RabbitManagementTemplate现已弃用,取而代使用的直接com.rabbitmq.http.client.Client(或com.rabbitmq.http.client.ReactorNettyClient) 使用情况。 有关更多信息,请参阅 RabbitMQ REST APIspring-doc.cadn.net.cn

@RabbitListener变化

侦听器容器工厂现在可以使用RetryTemplate以及可选的RecoveryCallback发送回复时使用。 有关更多信息,请参阅启用侦听器终端节点注释spring-doc.cadn.net.cn

异步@RabbitListener返回

@RabbitListenermethods 现在可以返回ListenableFuture<?>Mono<?>. 看异步@RabbitListener返回类型了解更多信息。spring-doc.cadn.net.cn

连接工厂 Bean 更改

默认情况下,RabbitConnectionFactoryBean现在调用enableHostnameVerification(). 要恢复到之前的行为,请将enableHostnameVerificationproperty 设置为false.spring-doc.cadn.net.cn

连接工厂更改

CachingConnectionFactory现在无条件地在底层 RabbitMQ 中禁用自动恢复ConnectionFactory,即使构造函数中提供了预配置的实例。 虽然已经采取了步骤使 Spring AMQP 与自动恢复兼容,但出现了某些极端情况,问题仍然存在。 Spring AMQP 从 1.0.0 开始就有了自己的恢复机制,不需要使用 Client 端提供的恢复。 虽然仍然可以启用该功能(使用cachingConnectionFactory.getRabbitConnectionFactory() .setAutomaticRecoveryEnabled()) 在CachingConnectionFactory构造的,我们强烈建议您不要这样做。 我们建议您使用单独的 RabbitMQConnectionFactory如果在直接使用 Client 端工厂(而不是使用 Spring AMQP 组件)时需要自动恢复连接。spring-doc.cadn.net.cn

侦听器容器更改

默认的ConditionalRejectingErrorHandler现在,如果x-death标头。 有关更多信息,请参阅异常处理spring-doc.cadn.net.cn

立即重新排队

新的ImmediateRequeueAmqpException用于通知侦听器容器消息必须重新排队。 要使用此功能,需要新的ImmediateRequeueMessageRecovererimplementation 的 implementation 中。spring-doc.cadn.net.cn