附录 C:变更历史

本节介绍随着版本的变化而进行的更改。spring-doc.cadn.net.cn

C.1. 当前版本

C.2. 以前的版本

C.2.1. 自 2.3 以来 2.4 中的更改

本节介绍版本 2.3 和版本 2.4 之间的更改。 有关以前版本中的更改,请参阅更改历史记录spring-doc.cadn.net.cn

@RabbitListener变化

MessageProperties现在可用于参数匹配。 有关更多信息,请参阅带注释的端点方法签名spring-doc.cadn.net.cn

RabbitAdmin变化

新属性recoverManualDeclarations允许恢复手动声明的 queues/exchanges/bindings。 有关更多信息,请参阅恢复自动删除声明spring-doc.cadn.net.cn

远程处理支持

使用 Spring Framework 的 RMI 支持进行远程处理的支持已弃用,并将在 3.0 中删除。有关更多信息,请参见Spring Remoting with AMQP。spring-doc.cadn.net.cn

C.2.2. 消息转换器更改

Jackson2JsonMessageConverter现在可以从contentEncoding页眉。 有关更多信息,请参见Jackson2JsonMessageConverterspring-doc.cadn.net.cn

C.2.3. 消息转换器更改

Jackson2JsonMessageConverter现在可以从contentEncoding页眉。 有关更多信息,请参见Jackson2JsonMessageConverterspring-doc.cadn.net.cn

C.2.4. 流支持更改

RabbitStreamOperationsRabbitStreamTemplate已被弃用,取而代之的是RabbitStreamOperations2RabbitStreamTemplate2分别;他们回来了CompletableFuture而不是ListenableFuture. 有关更多信息,请参阅使用 RabbitMQ Stream 插件spring-doc.cadn.net.cn

C.2.5. 自 2.2 以来 2.3 中的更改

本节介绍版本 2.2 和版本 2.3 之间的更改。 有关以前版本中的更改,请参阅更改历史记录spring-doc.cadn.net.cn

连接工厂更改

现在提供了两个额外的连接工厂。 有关更多信息,请参阅选择连接工厂spring-doc.cadn.net.cn

@RabbitListener变化

您现在可以指定回复内容类型。 有关更多信息,请参阅 Reply ContentTypespring-doc.cadn.net.cn

消息转换器更改

Jackson2JMessageConverter现在可以反序列化抽象类(包括接口),如果ObjectMapper配置了自定义 deserializer。 有关更多信息,请参见Deserializing Abstract Classesspring-doc.cadn.net.cn

测试更改

新注释@SpringRabbitTest用于在您不使用SpringBootTest. 有关更多信息,请参阅 @SpringRabbitTestspring-doc.cadn.net.cn

RabbitTemplate 更改

模板的ReturnCallback已重构为ReturnsCallback以便在 Lambda 表达式中更简单地使用。 有关更多信息,请参阅 Correlated Publisher Confirms and Returnsspring-doc.cadn.net.cn

当使用 returns 和 correlated 确认时,CorrelationData现在需要一个唯一的id财产。 有关更多信息,请参阅 Correlated Publisher Confirms and Returnsspring-doc.cadn.net.cn

使用直接回复时,您现在可以配置模板,以便服务器不需要在回复中返回关联数据。 有关更多信息,请参阅 RabbitMQ Direct 回复spring-doc.cadn.net.cn

侦听器容器更改

新的 Listener Container 属性consumeDelay现已推出;在使用 RabbitMQ Sharding Plugin 时非常有用。spring-doc.cadn.net.cn

默认的JavaLangErrorHandler现在调用System.exit(99). 要恢复到之前的行为(不执行任何作),请添加 no-op 处理程序。spring-doc.cadn.net.cn

容器现在支持globalQos属性以应用prefetchCount全局的 channel,而不是 channel 上的每个使用者。spring-doc.cadn.net.cn

MessagePostProcessor 更改

压缩MessagePostProcessor现在使用逗号而不是冒号来分隔多个内容编码。 解压缩器可以处理这两种格式,但是,如果您使用此版本生成的消息被 2.2.12 之前的版本使用,则应将压缩器配置为使用旧的分隔符。 有关更多信息,请参阅修改消息 - 压缩等中的重要说明。spring-doc.cadn.net.cn

多个 Broker 支持改进
RepublishMessageRecoverer 更改

未提供支持 publisher 确认的此 recoverer 的新子类。 有关更多信息,请参见 Message Listeners and the Asynchronous Casespring-doc.cadn.net.cn

C.2.6. 自 2.1 以来 2.2 中的更改

本节介绍版本 2.1 和版本 2.2 之间的更改。spring-doc.cadn.net.cn

套件更改

以下类/接口已从org.springframework.amqp.rabbit.core.supportorg.springframework.amqp.rabbit.batch:spring-doc.cadn.net.cn

另外ListenerExecutionFailedException已从org.springframework.amqp.rabbit.listener.exceptionorg.springframework.amqp.rabbit.support.spring-doc.cadn.net.cn

依赖项更改

JUnit (4) 现在是可选依赖项,将不再显示为传递依赖项。spring-doc.cadn.net.cn

spring-rabbit-junitmodule 现在是spring-rabbit-test模块,以获得更好的目标应用程序开发体验,而此时只有一个spring-rabbit-test我们获得了 AMQP 组件的完整测试实用程序堆栈。spring-doc.cadn.net.cn

“Breaking” API 更改

JUnit (5)RabbitAvailableCondition.getBrokerRunning()现在返回一个BrokerRunningSupport实例而不是BrokerRunning,它依赖于 JUnit 4。 它具有相同的 API,因此只需更改任何引用的类名即可。 有关更多信息,请参阅 JUnit5 条件spring-doc.cadn.net.cn

ListenerContainer 更改

默认情况下,具有致命异常的消息现在会被拒绝并且不会重新排队,即使确认模式是手动的。 有关更多信息,请参阅异常处理spring-doc.cadn.net.cn

现在可以使用 Micrometer 监控侦听器性能Timers. 有关更多信息,请参阅监控侦听器性能spring-doc.cadn.net.cn

@RabbitListener 更改

现在,您可以配置executor在每个侦听器上,覆盖出厂配置,以便更轻松地识别与侦听器关联的线程。 您现在可以覆盖容器工厂的acknowledgeMode属性与注解的ackMode财产。 有关更多信息,请参阅覆盖 Container Factory 属性spring-doc.cadn.net.cn

使用批处理时,@RabbitListener方法现在可以在一次调用中接收一批完整的消息,而不是一次获取一条消息。spring-doc.cadn.net.cn

当一次接收一条批量消息时,最后一条消息具有isLastInBatchmessage 属性设置为 true。spring-doc.cadn.net.cn

此外,收到的批处理消息现在包含amqp_batchSize页眉。spring-doc.cadn.net.cn

侦听器还可以使用在SimpleMessageListenerContainer,即使该批次不是由生产者创建的。 有关更多信息,请参阅选择容器spring-doc.cadn.net.cn

Spring Data Projection 接口现在由Jackson2JsonMessageConverter. 有关更多信息,请参见使用 Spring Data Projection 接口spring-doc.cadn.net.cn

Jackson2JsonMessageConverter现在假设内容为 JSON,如果没有contentType属性,或者它是默认的 (application/octet-string). 看Message了解更多信息。spring-doc.cadn.net.cn

同样地。这Jackson2XmlMessageConverter现在假定内容为 XML(如果没有contentType属性,或者它是默认的 (application/octet-string). 看Jackson2XmlMessageConverter了解更多信息。spring-doc.cadn.net.cn

@RabbitListener方法返回一个结果,则 bean 和Method现在在 reply message 属性中可用。 这允许配置beforeSendReplyMessagePostProcessor例如,在回复中设置一个 Headers 以指示在服务器上调用了哪个方法。 有关更多信息,请参阅回复管理spring-doc.cadn.net.cn

您现在可以配置ReplyPostProcessor在发送回复消息之前对其进行修改。 有关更多信息,请参阅回复管理spring-doc.cadn.net.cn

AMQP 日志记录附加程序更改

Log4J 和 LogbackAmqpAppender现在支持verifyHostnameSSL 选项。spring-doc.cadn.net.cn

此外,这些 appender 现在可以配置为不将 MDC 条目添加为 headers。 这addMdcAsHeadersboolean 选项来配置此类行为。spring-doc.cadn.net.cn

appender 现在支持SaslConfig财产。spring-doc.cadn.net.cn

MessageListenerAdapter 更改

MessageListenerAdapter现在提供了一个新的buildListenerArguments(Object, Channel, Message)方法来构建要传递到 Target 侦听器的参数数组,并且旧的参数数组已弃用。 看MessageListenerAdapter了解更多信息。spring-doc.cadn.net.cn

Exchange/Queue 声明更改

ExchangeBuilderQueueBuilder用于创建的 Fluent APIExchangeQueue声明对象RabbitAdmin现在支持 “众所周知” 参数。 有关更多信息,请参阅适用于 Queues 和 Exchanges 的 Builder APIspring-doc.cadn.net.cn

RabbitAdmin具有新属性explicitDeclarationsOnly. 有关更多信息,请参阅 条件声明spring-doc.cadn.net.cn

连接工厂更改

CachingConnectionFactory具有新属性shuffleAddresses. 在提供代理节点地址列表时,该列表将在创建连接之前随机排列,以便尝试连接的顺序是随机的。 有关更多信息,请参阅连接到集群spring-doc.cadn.net.cn

现在,当使用 Publisher 确认并返回时,回调会在连接工厂的executor. 这避免了amqp-clientslibrary 中执行 rabbit作。 有关更多信息,请参阅 Correlated Publisher Confirms and Returnsspring-doc.cadn.net.cn

此外,发布者确认类型现在使用ConfirmTypeenum 而不是两个互斥的 setter 方法。spring-doc.cadn.net.cn

RabbitConnectionFactoryBean现在,启用 SSL 时,默认使用 TLS 1.2。 看RabbitConnectionFactoryBean和配置 SSL了解更多信息。spring-doc.cadn.net.cn

新的 MessagePostProcessor 类

DeflaterPostProcessorInflaterPostProcessor分别添加了以支持压缩和解压缩,当消息 content-encoding 设置为deflate.spring-doc.cadn.net.cn

其他更改

Declarablesobject(用于声明多个队列、交换、绑定)现在为每种类型都有一个过滤的 getter。 有关更多信息,请参见Declaring Collections of Exchanges, Queues, and Bindingsspring-doc.cadn.net.cn

您现在可以自定义每个Declarablebean 之前的RabbitAdmin处理其声明。 有关更多信息,请参见 Automatic Declaration of Exchanges, Queues, and Bindingsspring-doc.cadn.net.cn

singleActiveConsumer()已添加到QueueBuilder要设置x-single-active-consumerqueue 参数。 有关更多信息,请参阅适用于 Queues 和 Exchanges 的 Builder APIspring-doc.cadn.net.cn

值为Class<?>现在使用getName()而不是toString(). 有关更多信息,请参阅 消息属性转换器spring-doc.cadn.net.cn

现在支持恢复失败的创建者创建的批处理。 有关更多信息,请参阅使用 Batch 侦听器重试spring-doc.cadn.net.cn

C.2.7. 自 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

C.2.8. 2.0 自 1.7 以来的变化

CachingConnectionFactory

从版本 2.0.2 开始,您可以配置RabbitTemplate使用与 Listener 容器使用的连接不同的连接。 此更改可避免在生产者因任何原因被阻止时出现使用者死锁。 有关更多信息,请参阅使用单独的连接spring-doc.cadn.net.cn

AMQP 客户端库

Spring AMQP 现在使用新的 5.0.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默认情况下,也禁用了该选项。
一般更改

ExchangeBuilder现在默认构建 Durable Exchange。 这@Exchange注解@QeueueBinding默认情况下,还会声明 Durable Exchange。 这@Queue注解@RabbitListener默认情况下,如果已命名,则声明 Durable 队列,如果匿名,则声明 Non-Durable。 有关更多信息,请参阅适用于队列和交换的 Builder API注释驱动的侦听器终端节点spring-doc.cadn.net.cn

已删除的类

UniquelyNameQueue不再提供。 创建具有唯一名称的持久非自动删除队列是不常见的。 此类已被删除。 如果您需要其功能,请使用new Queue(UUID.randomUUID().toString()).spring-doc.cadn.net.cn

新建侦听器容器

DirectMessageListenerContainer已与现有的SimpleMessageListenerContainer. 有关选择要使用的容器以及如何配置它们的信息,请参阅选择容器Message Listener 容器配置spring-doc.cadn.net.cn

Log4j 附加程序

由于 log4j 的生命周期结束,此 appender 不再可用。 有关可用日志附加程序的信息,请参见Logging Subsystem AMQP Appendersspring-doc.cadn.net.cn

RabbitTemplate变化
以前,非事务性RabbitTemplate如果现有事务在事务侦听器容器线程上运行,则参与该事务。 这是一个严重的错误。 但是,用户可能依赖于此行为。 从版本 1.6.2 开始,您必须将channelTransactedboolean 值,以便它参与容器事务。

RabbitTemplate现在使用DirectReplyToMessageListenerContainer(默认情况下),而不是为每个请求创建一个新的使用者。 有关更多信息,请参阅 RabbitMQ Direct 回复spring-doc.cadn.net.cn

AsyncRabbitTemplate现在支持 Direct Reply-To。 有关更多信息,请参阅 Async Rabbit Templatespring-doc.cadn.net.cn

RabbitTemplateAsyncRabbitTemplate现在有receiveAndConvertconvertSendAndReceiveAsType采用ParameterizedTypeReference<T>参数,让调用方指定要将结果转换为的类型。 这对于复杂类型或当类型信息未在消息头中传达时特别有用。 它需要一个SmartMessageConverter例如Jackson2JsonMessageConverter. 请参见接收消息请求/回复消息、异步 Rabbit 模板MessageRabbitTemplate了解更多信息。spring-doc.cadn.net.cn

您现在可以使用RabbitTemplate在专用频道上执行多项作。 有关更多信息,请参阅 Scoped Operationsspring-doc.cadn.net.cn

侦听器适配器

一个方便的FunctionalInterface可用于将 lambda 与MessageListenerAdapter. 看MessageListenerAdapter了解更多信息。spring-doc.cadn.net.cn

侦听器容器更改
预取默认值

prefetch 默认值以前为 1,这可能导致高效消费者的利用率不足。 默认预取值现在是 250,在大多数常见情况下,这应该会让使用者忙碌起来,并且, 因此,可以提高吞吐量。spring-doc.cadn.net.cn

在某些情况下,prefetch 值应 低 — 例如,对于大型消息,尤其是在处理速度较慢的情况下(消息可能会累积 添加到客户端进程中的大量内存),并且如果需要严格的消息排序 (在这种情况下,prefetch 值应设置回 1)。 此外,对于低容量消息收发和多个使用者(包括单个侦听器容器实例中的并发),您可能希望减少预取,以便在使用者之间更均匀地分配消息。

有关预取的更多背景信息,请参阅这篇关于 RabbitMQ 中的使用者利用率的博文和这篇关于排队理论的博文。spring-doc.cadn.net.cn

消息计数

以前MessageProperties.getMessageCount()返回0对于容器发出的消息。 此属性仅在您使用basicGet(例如,从RabbitTemplate.receive()方法),现在初始化为null对于容器消息。spring-doc.cadn.net.cn

事务回滚行为

事务回滚时的消息重新排队现在是一致的,无论是否配置了事务管理器。 有关更多信息,请参阅 回滚已接收消息的说明spring-doc.cadn.net.cn

关闭行为

如果容器线程在shutdownTimeout,则默认情况下会强制关闭通道。 有关更多信息,请参阅 Message Listener Container Configuration (消息侦听器容器配置)。spring-doc.cadn.net.cn

接收消息后处理器

如果MessagePostProcessorafterReceiveMessagePostProcessorsproperty 返回null,则丢弃消息(并在适当时进行确认)。spring-doc.cadn.net.cn

连接工厂更改

connection 和 channel listener 接口现在提供了一种获取有关异常信息的机制。 有关更多信息,请参阅连接和通道侦听器和发布是异步的 — 如何检测成功和失败spring-doc.cadn.net.cn

新的ConnectionNameStrategy现在提供,以从AbstractConnectionFactory. 有关更多信息,请参阅连接和资源管理spring-doc.cadn.net.cn

重试更改

MissingMessageIdAdvice不再提供。 它的功能现在是内置的。 有关更多信息,请参阅同步作失败和重试选项spring-doc.cadn.net.cn

匿名队列命名

默认情况下,AnonymousQueues现在使用默认的Base64UrlNamingStrategy而不是简单的UUID字符串。 看AnonymousQueue了解更多信息。spring-doc.cadn.net.cn

@RabbitListener变化

您现在可以在@RabbitListener附注。 有关更多信息,请参阅 Annotation-driven Listener Endpointsspring-doc.cadn.net.cn

您现在可以配置@RabbitListener注解,以便将任何异常返回给发送者。 您还可以配置RabbitListenerErrorHandler处理异常。 有关更多信息,请参阅处理异常spring-doc.cadn.net.cn

现在,当您使用@QueueBinding注解。 也@QueueBinding.exchange()现在支持自定义 Exchange 类型,并默认声明 Durable Exchange。spring-doc.cadn.net.cn

您现在可以设置concurrency的 Listener 容器,而不必为不同的并发设置配置不同的容器工厂。spring-doc.cadn.net.cn

您现在可以设置autoStartupListener 容器的属性,覆盖容器工厂中的默认设置。spring-doc.cadn.net.cn

您现在可以设置接收之后和发送(回复)之前MessagePostProcessor实例中的RabbitListener容器工厂。spring-doc.cadn.net.cn

从版本 2.0.3 开始,@RabbitHandler类级别的注释@RabbitListener可以指定为默认值。 有关更多信息,请参阅 Multi-method Listenersspring-doc.cadn.net.cn

容器条件回滚

当使用外部事务管理器(例如 JDBC)时,当您为容器提供事务属性时,现在支持基于规则的回滚。 现在,当您使用交易通知时,它也更加灵活。 有关更多信息,请参阅条件回滚spring-doc.cadn.net.cn

删除 Jackson 1.x 支持

在以前的版本中已废弃,Jackson1.x转换器和相关组件现已删除。 您可以使用基于 Jackson 2.x 的类似组件。 有关更多信息,请参见Jackson2JsonMessageConverterspring-doc.cadn.net.cn

JSON 消息转换器

TypeId设置为Hashtable对于入站 JSON 消息,默认转换类型现在为LinkedHashMap. 以前,它是Hashtable. 要恢复到Hashtable,您可以使用setDefaultMapTypeDefaultClassMapper.spring-doc.cadn.net.cn

XML 解析器

解析时QueueExchangeXML 组件,解析器不再注册nameattribute 值作为 Bean 别名,如果id属性。 看关于idname属性了解更多信息。spring-doc.cadn.net.cn

阻止的连接

您现在可以将com.rabbitmq.client.BlockedListenerorg.springframework.amqp.rabbit.connection.Connection对象。 此外,ConnectionBlockedEventConnectionUnblockedEvent事件由ConnectionFactory当连接被 Broker 阻止或取消阻止时。spring-doc.cadn.net.cn

有关更多信息,请参阅连接和资源管理spring-doc.cadn.net.cn

C.2.9. 1.7 自 1.6 以来的变化

AMQP 客户端库

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

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

最低 Log4j 2 版本(对于AmqpAppender) 现在是2.7. 该框架不再与以前的版本兼容。 有关更多信息,请参见Logging Subsystem AMQP Appendersspring-doc.cadn.net.cn

Logback Appender

默认情况下,此 appender 不再捕获调用者数据(方法、行号)。 您可以通过设置includeCallerDataconfiguration 选项。 有关可用日志附加程序的信息,请参见Logging Subsystem AMQP Appendersspring-doc.cadn.net.cn

Spring 重试升级

最低 Spring Retry 版本现在是1.2. 该框架不再与以前的版本兼容。spring-doc.cadn.net.cn

关闭行为

您现在可以设置forceCloseChanneltrue这样,如果容器线程在shutdownTimeout、通道被强制关闭、 导致任何未确认的消息重新排队。 有关更多信息,请参阅 Message Listener Container Configuration (消息侦听器容器配置)。spring-doc.cadn.net.cn

FasterXML Jackson 升级

现在的最低 Jackson 版本是2.8. 该框架不再与以前的版本兼容。spring-doc.cadn.net.cn

JUnit@Rules

以前由框架内部使用的规则现在已在名为spring-rabbit-junit. 看JUnit4@Rules了解更多信息。spring-doc.cadn.net.cn

容器条件回滚

当您使用外部事务管理器(例如 JDBC)时,当您为容器提供事务属性时,现在支持基于规则的回滚。 现在,当您使用交易通知时,它也更加灵活。spring-doc.cadn.net.cn

连接命名策略

新的ConnectionNameStrategy现在提供,以从AbstractConnectionFactory. 有关更多信息,请参阅连接和资源管理spring-doc.cadn.net.cn

侦听器容器更改
事务回滚行为

现在,您可以将事务回滚时的消息重新排队配置为一致,无论是否配置了事务管理器。 有关更多信息,请参阅 回滚已接收消息的说明spring-doc.cadn.net.cn

C.2.10. 早期版本

请参阅 以前的版本 以了解以前版本中的更改。spring-doc.cadn.net.cn

C.2.11. 1.6 自 1.5 以来的变化

测试支持

现在提供了新的测试支持库。 有关更多信息,请参阅测试支持spring-doc.cadn.net.cn

架构工人

提供 Fluent API 以进行配置的生成器QueueExchange对象现在可用。 有关更多信息,请参阅适用于 Queues 和 Exchanges 的 Builder APIspring-doc.cadn.net.cn

命名空间更改
连接工厂

您现在可以添加thread-factory到连接工厂 bean 声明中——例如,将线程命名为 由amqp-client图书馆。 有关更多信息,请参阅连接和资源管理spring-doc.cadn.net.cn

当您使用CacheMode.CONNECTION,您现在可以限制允许的连接总数。 有关更多信息,请参阅连接和资源管理spring-doc.cadn.net.cn

队列定义

您现在可以为匿名队列提供命名策略。 看AnonymousQueue了解更多信息。spring-doc.cadn.net.cn

侦听器容器更改
空闲消息侦听器检测

您现在可以配置侦听器容器以发布ApplicationEvent实例。 有关更多信息,请参阅 Detecting Idle Asynchronous Consumerspring-doc.cadn.net.cn

不匹配队列检测

默认情况下,当侦听器容器启动时,如果检测到属性或参数不匹配的队列, 容器会记录异常,但会继续侦听。 容器现在具有一个名为mismatchedQueuesFatal,这会阻止容器(和上下文) 如果在启动过程中检测到问题,则启动 Starting。 如果稍后检测到问题,例如从连接故障中恢复后,它还会停止容器。 有关更多信息,请参阅 Message Listener Container Configuration (消息侦听器容器配置)。spring-doc.cadn.net.cn

侦听器容器日志记录

现在,侦听器容器提供了它的beanName到内部SimpleAsyncTaskExecutor作为threadNamePrefix. 它对日志分析很有用。spring-doc.cadn.net.cn

默认错误处理程序

默认错误处理程序 (ConditionalRejectingErrorHandler) 现在视为 Irrecoverable@RabbitListener异常为 Fatal。 有关更多信息,请参阅异常处理spring-doc.cadn.net.cn

AutoDeclareRabbitAdmin实例

请参阅 消息侦听器容器配置 (autoDeclare) 对该选项的语义进行一些更改,以便使用 之RabbitAdmin实例。spring-doc.cadn.net.cn

AmqpTemplate:超时接收

一些新的receive()方法与timeout已引入AmqpTemplate及其RabbitTemplate实现。 有关更多信息,请参阅轮询使用者spring-doc.cadn.net.cn

AsyncRabbitTemplate

新的AsyncRabbitTemplate已引入。 此模板提供了许多发送和接收方法,其中返回值是ListenableFuture,它可以 稍后用于同步或异步获取结果。 有关更多信息,请参阅 Async Rabbit Templatespring-doc.cadn.net.cn

RabbitTemplate变化

1.4.1 引入了在 broker 支持时使用 Direct reply-to 的功能。 这比对每个回复使用临时队列更有效。 此版本允许您覆盖此默认行为,并通过设置useTemporaryReplyQueuesproperty 设置为true. 有关更多信息,请参阅 RabbitMQ Direct 回复spring-doc.cadn.net.cn

RabbitTemplate现在支持user-id-expression (userIdExpression使用 Java 配置时)。 有关更多信息,请参阅经过验证的 User-ID RabbitMQ 文档经过验证的用户 IDspring-doc.cadn.net.cn

消息属性
CorrelationId

correlationIdmessage 属性现在可以是String. 有关更多信息,请参阅 消息属性转换器spring-doc.cadn.net.cn

长字符串标头

以前,DefaultMessagePropertiesConverter长度超过长字符串限制(默认为 1024)的 “converted” 标头 更改为DataInputStream(实际上,它引用了LongString实例的DataInputStream). 在输出时,此标头未被转换(除了转换为 String — 例如java.io.DataInputStream@1d057a39通过调用toString()在溪流上)。spring-doc.cadn.net.cn

在此版本中,长LongString实例现在保留为LongString实例。 您可以使用getBytes[],toString()getStream()方法。 一个大的传入LongString现在也可以在输出上正确地 “转换” 。spring-doc.cadn.net.cn

有关更多信息,请参阅 消息属性转换器spring-doc.cadn.net.cn

入站配送模式

deliveryMode属性不再映射到MessageProperties.deliveryMode. 如果相同的MessagePropertiesobject 用于发送出站消息。 相反,入站deliveryModeheader 映射到MessageProperties.receivedDeliveryMode.spring-doc.cadn.net.cn

有关更多信息,请参阅 消息属性转换器spring-doc.cadn.net.cn

使用带注释的端点时,标头在名为AmqpHeaders.RECEIVED_DELIVERY_MODE.spring-doc.cadn.net.cn

有关更多信息,请参阅带注释的端点方法签名spring-doc.cadn.net.cn

入站用户 ID

user_id属性不再映射到MessageProperties.userId. 如果相同的MessagePropertiesobject 用于发送出站消息。 相反,入站userIdheader 映射到MessageProperties.receivedUserId.spring-doc.cadn.net.cn

有关更多信息,请参阅 消息属性转换器spring-doc.cadn.net.cn

当您使用带注释的终端节点时,标头将在名为AmqpHeaders.RECEIVED_USER_ID.spring-doc.cadn.net.cn

有关更多信息,请参阅带注释的端点方法签名spring-doc.cadn.net.cn

RabbitAdmin变化
声明失败

以前,ignoreDeclarationFailures标志仅对IOException在频道上(例如 Mis-Matched 参数)。 它现在对任何异常(例如TimeoutException). 此外,一个DeclarationExceptionEvent现在,每当声明失败时都会发布。 这RabbitAdminLast Declaration 事件也可用作属性lastDeclarationExceptionEvent. 有关更多信息,请参阅 配置 Brokerspring-doc.cadn.net.cn

@RabbitListener变化
每个 bean 的多个容器

当您使用 Java 8 或更高版本时,您现在可以添加多个@RabbitListenerannotations 添加到@Bean类或 他们的方法。 使用 Java 7 或更早版本时,您可以使用@RabbitListenerscontainer 注解来提供相同的 功能性。 看@Repeatable @RabbitListener了解更多信息。spring-doc.cadn.net.cn

@SendToSPEL 表达式

@SendTo对于没有replyTo属性现在可以根据 请求/回复。 有关更多信息,请参阅回复管理spring-doc.cadn.net.cn

@QueueBinding改进

现在,您可以在@QueueBinding附注。 标头交换现在由@QueueBinding. 有关更多信息,请参阅 Annotation-driven Listener Endpointsspring-doc.cadn.net.cn

延迟消息交换

Spring AMQP 现在对 RabbitMQ Delayed Message Exchange 插件具有一流的支持。 有关更多信息,请参阅 Delayed Message Exchangespring-doc.cadn.net.cn

Exchange 内部标志

任何Exchange定义现在可以标记为internalRabbitAdmin在以下情况下将值传递给代理 声明交易所。 有关更多信息,请参阅 配置 Brokerspring-doc.cadn.net.cn

CachingConnectionFactory变化
CachingConnectionFactory缓存统计

CachingConnectionFactory现在在运行时和 JMX 上提供缓存属性。 有关更多信息,请参阅 Runtime Cache Properties (运行时缓存属性)。spring-doc.cadn.net.cn

访问底层 RabbitMQ 连接工厂

添加了一个新的 getter 以提供对底层工厂的访问。 例如,您可以使用此 getter 来添加自定义连接属性。 有关更多信息,请参阅添加自定义客户端连接属性spring-doc.cadn.net.cn

Channel Cache

默认通道缓存大小已从 1 增加到 25。 有关更多信息,请参阅连接和资源管理spring-doc.cadn.net.cn

此外,SimpleMessageListenerContainer不再将缓存大小调整为至少与数字一样大 之concurrentConsumers— 这是多余的,因为容器使用者通道永远不会被缓存。spring-doc.cadn.net.cn

RabbitConnectionFactoryBean

工厂 Bean 现在公开了一个属性,用于将 Client 端连接属性添加到由生成的 厂。spring-doc.cadn.net.cn

Java 反序列化

现在,您可以在使用 Java 反序列化时配置允许类的“允许列表”。 如果您接受包含来自 untrusted sources 的 untrusted sources。 有关更多信息,请参阅 Java 反序列化spring-doc.cadn.net.cn

JSON 格式MessageConverter

对 JSON 消息转换器的改进现在允许使用没有类型信息的消息 在消息标头中。 有关更多信息,请参见带注释方法的消息转换Jackson2JsonMessageConverterspring-doc.cadn.net.cn

日志记录 Appender
日志 4j 2

添加了 log4j 2 附加程序,现在可以使用addresses要连接的属性 发送到代理集群。spring-doc.cadn.net.cn

客户端连接属性

您现在可以将自定义客户端连接属性添加到 RabbitMQ 连接。spring-doc.cadn.net.cn

C.2.12. 自 1.4 以来 1.5 中的更改

spring-erlang不再受支持

spring-erlangjar 不再包含在分发中。 请改用 RabbitMQ REST APIspring-doc.cadn.net.cn

CachingConnectionFactory变化
中的 Empty addresses 属性CachingConnectionFactory

以前,如果连接工厂配置了主机和端口,但还为addresses,则忽略了 host 和 port。 现在,一个空的addressesString 的处理方式与null,并使用 host 和 port。spring-doc.cadn.net.cn

URI 构造函数

CachingConnectionFactory具有一个额外的构造函数,其中URI参数,以配置 broker 连接。spring-doc.cadn.net.cn

连接重置

一个名为resetConnection()已添加,以允许用户重置连接(或连接)。 例如,您可以使用此选项在故障转移到辅助代理后重新连接到主代理。 这确实会影响进程内作。 现有的destroy()method 的作用完全相同,但新 method 的名称不那么令人生畏。spring-doc.cadn.net.cn

用于控制容器队列声明行为的属性

当侦听器容器使用者启动时,他们尝试被动声明队列以确保它们可用 在经纪人上。 以前,如果这些声明失败(例如,因为队列不存在)或当 HA 队列 移动时,重试逻辑固定为每隔 5 秒进行三次重试尝试。 如果队列仍然存在,则行为由missingQueuesFatal属性(默认值:true). 此外,对于配置为从多个队列侦听的容器,如果只有一个队列子集可用,则使用者 以 60 秒的固定间隔重试缺少的队列。spring-doc.cadn.net.cn

declarationRetries,failedDeclarationRetryIntervalretryDeclarationInterval属性现在是可配置的。 有关更多信息,请参阅 Message Listener Container Configuration (消息侦听器容器配置)。spring-doc.cadn.net.cn

类套餐更改

RabbitGatewaySupportclass 已从o.s.amqp.rabbit.core.supporto.s.amqp.rabbit.core.spring-doc.cadn.net.cn

DefaultMessagePropertiesConverter变化

您现在可以配置DefaultMessagePropertiesConverter自 确定LongString即被转换 更改为String而不是DataInputStream. 转换器具有将该值作为限制的替代构造函数。 以前,此限制是硬编码为1024字节。 (在 1.4.4 中也可用)。spring-doc.cadn.net.cn

@RabbitListener改进
@QueueBinding@RabbitListener

bindings属性已添加到@RabbitListener注解与queues属性以允许指定queueexchangebindingfor declaration 由RabbitAdmin上 经纪人。spring-doc.cadn.net.cn

SPEL 输入@SendTo

默认回复地址 (@SendTo) 的@RabbitListener现在可以是 SpEL 表达式。spring-doc.cadn.net.cn

通过属性创建多个队列名称

现在,您可以结合使用 SPEL 和属性占位符来为侦听器指定多个队列。spring-doc.cadn.net.cn

自动交换、排队和绑定声明

现在,您可以声明定义这些实体集合的 bean,并且RabbitAdmin添加 contents 添加到它在建立连接时声明的实体列表中。 有关更多信息,请参见Declaring Collections of Exchanges, Queues, and Bindingsspring-doc.cadn.net.cn

RabbitTemplate变化
reply-address添加

reply-address属性已添加到<rabbit-template>组件作为替代方案reply-queue. 有关更多信息,请参阅请求/回复消息。 (在 1.4.4 中也可用作RabbitTemplate).spring-doc.cadn.net.cn

阻塞receive方法

RabbitTemplate现在支持阻止receiveconvertAndReceive方法。 有关更多信息,请参阅轮询使用者spring-doc.cadn.net.cn

强制使用sendAndReceive方法

mandatory标志sendAndReceiveconvertSendAndReceive方法、调用线程 抛出一个AmqpMessageReturnedException如果请求消息无法传递。 有关更多信息,请参阅 Reply Timeout (回复超时)。spring-doc.cadn.net.cn

不正确的回复侦听器配置

框架会尝试在使用命名回复队列时验证回复侦听器容器的配置是否正确。spring-doc.cadn.net.cn

有关更多信息,请参阅 Reply Listener Containerspring-doc.cadn.net.cn

RabbitManagementTemplate添加

RabbitManagementTemplate引入了 RabbitMQ Broker 的 Management 插件提供的 REST API 来监控和配置 RabbitMQ Broker。 有关更多信息,请参阅 RabbitMQ REST APIspring-doc.cadn.net.cn

侦听器容器 Bean 名称 (XML)

id属性<listener-container/>元素。 从此版本开始,id<listener/>child 元素单独用于命名为每个侦听器元素创建的侦听器容器 Bean。spring-doc.cadn.net.cn

应用正常的 Spring bean 名称覆盖。 如果稍后<listener/>使用相同的id作为现有 Bean,新定义将覆盖现有 Bean。 以前,bean 名称是由id的属性<listener-container/><listener/>元素。spring-doc.cadn.net.cn

迁移到此版本时,如果您已id属性<listener-container/>元素中,删除它们并设置id对孩子<listener/>元素。spring-doc.cadn.net.cn

但是,为了支持将容器作为一个组启动和停止,新的group属性。 定义此属性后,此元素创建的容器将添加到具有此名称的 Bean中,类型为Collection<SimpleMessageListenerContainer>. 您可以迭代此组以启动和停止容器。spring-doc.cadn.net.cn

类级别@RabbitListener

@RabbitListener现在可以在类级别应用 Annotation。 与新的@RabbitHandlermethod 注解,这允许您根据有效负载类型选择处理程序方法。 有关更多信息,请参阅 Multi-method Listenersspring-doc.cadn.net.cn

SimpleMessageListenerContainer: BackOff 支持

SimpleMessageListenerContainer现在可以提供BackOff的实例consumer启动恢复。 有关更多信息,请参阅 Message Listener Container Configuration (消息侦听器容器配置)。spring-doc.cadn.net.cn

通道关闭日志记录

引入了一种控制 channel closure 的对数级别的机制。 请参见记录通道关闭事件spring-doc.cadn.net.cn

应用程序事件

SimpleMessageListenerContainer现在,当使用者发生故障时,它会发出应用程序事件。 有关更多信息,请参阅使用者事件spring-doc.cadn.net.cn

Consumer 标签配置

以前,异步使用者的使用者标签是由 Broker 生成的。 在此版本中,现在可以为侦听器容器提供命名策略。 请参阅 Consumer Tagsspring-doc.cadn.net.cn

MessageListenerAdapter

MessageListenerAdapter现在支持将队列名称(或使用者标签)映射到方法名称,以确定 根据从中接收消息的队列调用哪个委托方法。spring-doc.cadn.net.cn

LocalizedQueueConnectionFactory添加

LocalizedQueueConnectionFactory是一个新的连接工厂,它连接到镜像队列实际所在的集群中的节点。spring-doc.cadn.net.cn

匿名队列命名

从版本 1.5.3 开始,您现在可以控制AnonymousQueue生成名称。 看AnonymousQueue了解更多信息。spring-doc.cadn.net.cn

C.2.13. 自 1.3 以来 1.4 中的更改

@RabbitListener注解

POJO 侦听器可以用@RabbitListener,由@EnableRabbit<rabbit:annotation-driven />. 此功能需要 Spring Framework 4.1。 有关更多信息,请参阅 Annotation-driven Listener Endpointsspring-doc.cadn.net.cn

RabbitMessagingTemplate添加

新的RabbitMessagingTemplate允许您使用spring-messaging Message实例。 在内部,它使用RabbitTemplate,您可以正常配置。 此功能需要 Spring Framework 4.1。 有关更多信息,请参阅消息收发集成spring-doc.cadn.net.cn

侦听器容器missingQueuesFatal属性

1.3.5 引入了missingQueuesFatal属性SimpleMessageListenerContainer. 现在,这在侦听器容器命名空间元素上可用。 请参阅 消息侦听器容器配置spring-doc.cadn.net.cn

RabbitTemplate (兔模板)ConfirmCallback接口

confirmmethod 有一个名为cause. 如果可用,此参数包含否定确认 (nack) 的原因。 请参阅 相关发布者确认和返回spring-doc.cadn.net.cn

RabbitConnectionFactoryBean添加

RabbitConnectionFactoryBean创建底层 RabbitMQConnectionFactoryCachingConnectionFactory. 这允许使用 Spring 的依赖项注入配置 SSL 选项。 请参阅配置底层客户端连接工厂spring-doc.cadn.net.cn

CachingConnectionFactory

CachingConnectionFactory现在让connectionTimeout设置为命名空间中的属性或属性。 它在底层 RabbitMQ 上设置属性ConnectionFactory. 请参阅配置底层客户端连接工厂spring-doc.cadn.net.cn

Log Appender

Logback 软件org.springframework.amqp.rabbit.logback.AmqpAppender已引入。 它提供类似于org.springframework.amqp.rabbit.log4j.AmqpAppender. 有关更多信息,请参阅这些类的 JavaDoc。spring-doc.cadn.net.cn

The Log4jAmqpAppender现在支持deliveryMode属性 (PERSISTENTNON_PERSISTENT违约:PERSISTENT). 以前,所有 log4j 消息都是PERSISTENT.spring-doc.cadn.net.cn

appender 还支持修改Messagebefore sending — 例如,允许添加自定义标头。 子类应覆盖postProcessMessageBeforeSend().spring-doc.cadn.net.cn

侦听器队列

现在,默认情况下,侦听器容器会在启动期间重新声明任何缺失的队列。 新的auto-declare属性已添加到<rabbit:listener-container>来防止这些重新声明。 看auto-delete队列.spring-doc.cadn.net.cn

RabbitTemplate:mandatoryconnectionFactorySelector表达 式

mandatoryExpression,sendConnectionFactorySelectorExpressionreceiveConnectionFactorySelectorExpressionSpEL 表达式的属性已添加到RabbitTemplate. 这mandatoryExpression用于评估mandatoryboolean 值,当ReturnCallback正在使用中。 请参阅 相关发布者确认和返回。 这sendConnectionFactorySelectorExpressionreceiveConnectionFactorySelectorExpressionAbstractRoutingConnectionFactory,以确定lookupKey对于目标ConnectionFactory在每个 AMQP 协议交互作的运行时。 请参阅 Routing Connection Factoryspring-doc.cadn.net.cn

侦听器和路由连接工厂

您可以配置SimpleMessageListenerContainer使用路由连接工厂,以启用基于队列名称的连接选择。 请参阅 Routing Connection Factoryspring-doc.cadn.net.cn

RabbitTemplate:RecoveryCallback选择

recoveryCallback属性,以便在retryTemplate.execute(). 请参阅添加重试功能spring-doc.cadn.net.cn

MessageConversionException改变

此异常现在是AmqpException. 请考虑以下代码:spring-doc.cadn.net.cn

try {
    template.convertAndSend("thing1", "thing2", "cat");
}
catch (AmqpException e) {
	...
}
catch (MessageConversionException e) {
	...
}

第二个 catch 块不再可访问,需要移动到 catch-all 上方AmqpExceptioncatch 块。spring-doc.cadn.net.cn

RabbitMQ 3.4 兼容性

Spring AMQP 现在与 RabbitMQ 3.4 兼容,包括直接回复。 有关更多信息,请参阅兼容性RabbitMQ Direct 回复spring-doc.cadn.net.cn

ContentTypeDelegatingMessageConverter添加

ContentTypeDelegatingMessageConverter来选择MessageConverter使用,基于contentType属性在MessageProperties. 有关更多信息,请参阅 消息转换器spring-doc.cadn.net.cn

C.2.14. 1.3 自 1.2 以来的变化

侦听器并发

侦听器容器现在支持根据工作负载动态扩展使用者数量,或者您可以在不停止容器的情况下以编程方式更改并发。 请参阅 侦听器并发spring-doc.cadn.net.cn

侦听器队列

侦听器容器现在允许在运行时修改它侦听的队列。 此外,如果容器的至少一个已配置队列可供使用,则容器现在会启动。 请参阅 侦听器容器队列spring-doc.cadn.net.cn

此侦听器容器现在在启动期间重新声明任何自动删除队列。 看auto-delete队列.spring-doc.cadn.net.cn

消费者优先

侦听器容器现在支持使用者参数,让x-priority参数。 请参阅 Consumer Priorityspring-doc.cadn.net.cn

专属消费者

您现在可以配置SimpleMessageListenerContainer使用单个exclusiveconsumer,防止其他使用者侦听队列。 请参阅 Exclusive Consumerspring-doc.cadn.net.cn

兔子管理员

现在,您可以让 broker 生成队列名称,而不管durable,autoDeleteexclusive设置。 请参见配置代理spring-doc.cadn.net.cn

直接交换绑定

以前,省略key属性binding元素direct-exchange配置导致 queue 或 exchange 绑定了一个空字符串作为路由键。 现在它与提供的QueueExchange. 如果希望绑定空字符串路由密钥,则需要指定key="".spring-doc.cadn.net.cn

AmqpTemplate变化

AmqpTemplate现在提供了几个同步的receiveAndReply方法。 这些由RabbitTemplate. 有关更多信息,请参阅接收消息spring-doc.cadn.net.cn

RabbitTemplate现在支持配置RetryTemplate在代理不可用时尝试重试(使用可选的 back-off 策略)。 有关更多信息,请参阅添加重试功能spring-doc.cadn.net.cn

缓存连接工厂

您现在可以将缓存连接工厂配置为缓存Connection实例及其Channel实例,而不是使用单个连接和仅缓存Channel实例。 请参阅连接和资源管理spring-doc.cadn.net.cn

绑定参数

<binding><exchange>现在支持解析<binding-arguments>sub-元素。 您现在可以配置<binding><headers-exchange>替换为key/value属性对(在单个标头上匹配)或使用<binding-arguments>子元素(允许在多个标头上进行匹配)。 这些选项是互斥的。 请参阅 Headers Exchangespring-doc.cadn.net.cn

路由连接工厂

新的SimpleRoutingConnectionFactory已引入。 它允许配置ConnectionFactoriesmapping,以确定目标ConnectionFactory在运行时使用。 请参阅 Routing Connection Factoryspring-doc.cadn.net.cn

MessageBuilderMessagePropertiesBuilder

现在提供了用于构建消息或消息属性的“Fluent API”。 请参阅 Message Builder APIspring-doc.cadn.net.cn

RetryInterceptorBuilder改变

现在提供了用于构建侦听器容器重试侦听器的“Fluent API”。 请参阅 同步作失败 和 重试选项spring-doc.cadn.net.cn

RepublishMessageRecoverer添加

这个新的MessageRecoverer以允许在重试用尽时将失败的消息发布到另一个队列(包括 Headers 中的堆栈跟踪信息)。 请参阅 消息侦听器和异步情况spring-doc.cadn.net.cn

默认错误处理程序(自 1.3.2 起)

默认的ConditionalRejectingErrorHandler已添加到侦听器容器中。 此错误处理程序检测致命的消息转换问题,并指示容器拒绝该消息,以防止代理不断重新传送不可转换的消息。 请参见异常处理spring-doc.cadn.net.cn

侦听器容器 'missingQueuesFatal' 属性(自 1.3.5 起)

SimpleMessageListenerContainer现在有一个名为missingQueuesFatal(默认:true). 以前,缺少队列总是致命的。 请参阅 消息侦听器容器配置spring-doc.cadn.net.cn

C.2.15. 自 1.1 以来对 1.2 的更改

RabbitMQ 版本

Spring AMQP 现在默认使用 RabbitMQ 3.1.x(但保留了与早期版本的兼容性)。 对于 RabbitMQ 3.1.x 不再支持的功能,添加了某些弃用 — 联合交换和immediate属性RabbitTemplate.spring-doc.cadn.net.cn

兔子管理员

RabbitAdmin现在提供了一个选项,允许 Exchange、Queue 和 Binding 声明在声明失败时继续。 以前,所有声明都会在失败时停止。 通过设置ignore-declaration-exceptions,则会记录此类异常(在WARN级别),但进一步的声明仍在继续。 这可能有用的一个示例是,当队列声明由于略有不同而失败时ttl设置,通常会阻止其他声明继续进行。spring-doc.cadn.net.cn

RabbitAdmin现在提供了一个名为getQueueProperties(). 您可以使用此命令来确定代理上是否存在队列(返回null对于不存在的队列)。 此外,它还返回队列中的当前消息数以及当前使用者数。spring-doc.cadn.net.cn

Rabbit 模板

以前,当…​sendAndReceive()方法与固定回复队列一起使用,两个自定义标头用于关联数据以及保留和恢复回复队列信息。 在此版本中,标准 message 属性 (correlationId),但您可以指定要改用的自定义属性。 此外,嵌套的replyTo信息现在保留在模板内部,而不是使用自定义标头。spring-doc.cadn.net.cn

immediate属性已弃用。 使用 RabbitMQ 3.0.x 或更高版本时,不得设置此属性。spring-doc.cadn.net.cn

JSON 消息转换器

Jackson 2.xMessageConverter现在提供了 Jackson 1.x 的现有转换器。spring-doc.cadn.net.cn

自动声明队列和其他项目

以前,在声明 queues、exchanges 和 bindings 时,您无法定义用于声明的连接工厂。 每RabbitAdmin使用其 Connection 声明所有组件。spring-doc.cadn.net.cn

从此版本开始,您现在可以将声明限制为特定的RabbitAdmin实例。 请参见 条件声明spring-doc.cadn.net.cn

AMQP 远程处理

现在提供了使用 Spring 远程技术的工具,使用 AMQP 作为 RPC 调用的传输。 有关详细信息,请参阅远程处理spring-doc.cadn.net.cn

请求的心跳

一些用户要求提供底层客户端连接工厂的requestedHeartBeats要在 Spring AMQP 上公开的属性CachingConnectionFactory. 此功能现已推出。 以前,有必要将 AMQP 客户端工厂配置为单独的 bean,并在CachingConnectionFactory.spring-doc.cadn.net.cn

C.2.16. 自 1.0 以来对 1.1 的更改

常规

Spring-AMQP 现在是用 Gradle 构建的。spring-doc.cadn.net.cn

添加对发布者确认和返回的支持。spring-doc.cadn.net.cn

添加了对 HA 队列和代理故障转移的支持。spring-doc.cadn.net.cn

添加了对死信交换和死信队列的支持。spring-doc.cadn.net.cn

AMQP Log4j 附加程序

添加了一个选项,以支持向记录的消息添加消息 ID。spring-doc.cadn.net.cn

添加一个选项以允许指定Charset转换时使用的名称Stringbyte[].spring-doc.cadn.net.cn