4.0 和 4.1 之间的更改
新组件
版本 4.1 添加了许多新组件。
Promise<?> 网关
消息传递网关方法现在支持 ReactorPromise
return 类型。
请参阅 异步网关。
WebSocket 支持
这WebSocket
模块现已推出。
它完全基于 Spring WebSocket 和 Spring 消息传递模块,并提供了一个<inbound-channel-adapter>
以及一个<outbound-channel-adapter>
.
有关更多信息,请参阅 WebSockets 支持。
Scatter-Gather 企业集成模式
我们实施了 scatter-gather 企业集成模式。 有关更多信息,请参阅 Scatter-Gather 。
Routing Slip Pattern
我们添加了路由滑 EIP 模式实现。 有关更多信息,请参阅路由单。
幂等接收器模式
我们添加了幂等接收器企业集成模式实现,方法是将<idempotent-receiver>
组件或IdempotentReceiverInterceptor
和IdempotentReceiver
Java 配置的注释。
有关更多信息,请参阅 Idempotent Receiver Enterprise Integration Pattern 和 Javadoc。
福音JsonObjectMapper
我们添加了 BoonJsonObjectMapper
对于 JSON 转换器。
有关更多信息,请参阅 Transformer 。
Redis 队列网关
我们添加了<redis-queue-inbound-gateway>
和<redis-queue-outbound-gateway>
组件。
请参阅 Redis 队列入站网关和 Redis 队列出站网关。
PollSkipAdvice
我们添加了PollSkipAdvice
,您可以在<advice-chain>
的<poller>
确定当前轮询是否应由您实施的某个条件来抑制(跳过)PollSkipStrategy
.
有关更多信息,请参阅 轮询器。
一般更改
本节介绍从版本 4.0 到版本 4.1 的一般更改。
AMQP 入站终端节点,通道
使用消息侦听器容器(入站终端节点和通道)的元素现在支持missing-queues-fatal
属性。
有关更多信息,请参阅 AMQP 支持。
AMQP 出站终端节点
AMQP 出站终端节点支持名为lazy-connect
(默认:true
).
什么时候true
,则在第一条消息到达之前,不会建立与代理的连接(假设没有入站终端节点,这些终端节点始终在启动期间尝试建立连接)。
当设置为false
,则会在应用程序启动期间尝试建立连接。
有关更多信息,请参阅 AMQP 支持。
Http 入站通道适配器和状态代码
这<http:inbound-channel-adapter>
现在可以使用status-code-expression
以覆盖默认值200 OK
地位。
有关更多信息,请参阅 HTTP 命名空间支持。
MQTT 适配器更改
您现在可以将 MQTT 通道适配器配置为连接到多个服务器,例如,支持高可用性 (HA)。 有关更多信息,请参阅 MQTT 支持。
MQTT 消息驱动的通道适配器现在支持为每个订阅指定 QoS 设置。 有关更多信息,请参见入站 (消息驱动) 通道适配器。
MQTT 出站通道适配器现在支持异步发送,从而避免在确认交付之前阻塞。 有关更多信息,请参阅 Outbound Channel Adapter 。
现在可以在运行时以编程方式订阅和取消订阅主题。 有关更多信息,请参见入站 (消息驱动) 通道适配器。
FTP 和 SFTP 适配器更改
FTP 和 SFTP 出站通道适配器现在支持附加到远程文件,并在远程文件已存在时执行特定作。
远程文件模板现在也支持此功能,以及rmdir()
和exists()
.
此外,远程文件模板还提供对底层客户端对象的访问,从而允许访问低级 API。
有关更多信息,请参阅 FTP/FTPS 适配器和 SFTP 适配器。
Splitter 和 Iterator
Splitter
组件现在支持Iterator
作为生成输出消息的结果对象。
有关更多信息,请参阅 Splitter 。
聚合
Aggregator
instancess 现在支持新属性expire-groups-upon-timeout
.
有关更多信息,请参阅 Aggregator。
内容丰富器改进
我们添加了一个null-result-expression
属性,如果<enricher>
返回null
.
您可以将其添加到<header>
和<property>
.
有关更多信息,请参阅 内容扩充器 。
我们添加了一个error-channel
属性,该属性用于处理错误流,如果Exception
发生在request-channel
.
这样,您就可以返回用于扩充的替代对象。
有关更多信息,请参阅 内容扩充器 。
Header Channel Registry
这<header-enricher/>
元素的<header-channels-to-string/>
子元素现在可以覆盖 Header Channel Registry 保留通道映射的默认时间。
有关更多信息,请参阅 Header Channel Registry 。
有序关机
我们对 orderly shutdown 算法进行了改进。 有关更多信息,请参见 Orderly Shutdown。
管理RecipientListRouter
这RecipientListRouter
现在提供了多个管理作,用于在运行时配置收件人。
这样,您现在可以配置<recipient-list-router>
没有<recipient>
从一开始。
看RecipientListRouterManagement
了解更多信息。
AbstractHeaderMapper:NON_STANDARD_HEADERS token
这AbstractHeaderMapper
implementation 现在提供额外的NON_STANDARD_HEADERS
token 映射任何用户定义的标头,默认情况下不会映射这些标头。
有关更多信息,请参阅 AMQP 消息标头。
AMQP 通道:template-channel-transacted
我们引入了template-channel-transacted
属性MessageChannel
实例。
有关更多信息,请参见 AMQP 支持的消息通道。
Syslog 适配器
默认 syslog 消息转换器现在可以选择在有效负载中保留原始消息,同时仍设置标头。 有关更多信息,请参阅 Syslog 入站通道适配器。
聚合商建议链
Aggregator
和Resequencer
现在支持<expire-advice-chain/>
和<expire-transactional/>
子元素来通知forceComplete
操作。
有关更多信息,请参阅使用 XML 配置聚合器。
Resequencer 更改
当 resequencer 中的消息组超时时(使用group-timeout
或MessageGroupStoreReaper
),现在默认情况下,将立即丢弃延迟到达的消息。
请参阅 Resequencer。
可选的 POJO 方法参数
Spring 集成现在始终如一地处理 Java 8 的Optional
类型。
请参阅配置 Service Activator。
QueueChannel
backed Queue 类型
这QueueChannel
支持Queue type
已从BlockingQueue
到更通用的Queue
.
此更改允许使用任何外部Queue
实现(例如,Reactor 的PersistentQueue
).
看QueueChannel
配置.
ChannelInterceptor
变化
这ChannelInterceptor
现在支持额外的afterSendCompletion()
和afterReceiveCompletion()
方法。
请参见Channel Interceptor。