对于最新的稳定版本,请使用 Spring Integration 6.4.0! |
新增功能
对于那些已经熟悉 Spring 集成的人来说,本章简要概述了 6.2 版的新功能。
如果您对早期版本中引入的更改和功能感兴趣,请参阅更改历史记录。
Spring Integration 6.2 中有哪些新功能?
如果您对更多详细信息感兴趣,请参阅在 6.2 开发过程中解决的问题跟踪器ticket。
总的来说,项目已移至最新的依赖项版本。
新组件
Debezium 入站通道适配器
基于 Debezium 引擎的变更数据捕获 (CDC) 通道适配器,允许捕获数据库更改事件,将其转换为 Messages 并将其流式传输到出站通道。 有关更多信息,请参阅 Debezium 支持。
一般更改
-
的 XML 配置和 注释现在支持 和 选项的 ISO 8601 持续时间格式。 有关更多信息,请参阅轮询使用者。
<poller>
@Poller
fixed-delay
fixed-rate
initial-delay
-
Java、Groovy 和 Kotlin DSL 现在具有特定于上下文的方法,其中包含单个参数,用于使用一个构建器和可读选项配置端点及其处理程序。 例如,请参见 Java DSL 章节中的 。
IntegrationFlowDefinition
Consumer
transformWith()
splitWith()
-
引入了一个新的全局属性,用于覆盖应用程序中所有端点的默认 30 秒超时。 有关更多信息,请参阅全局属性。
spring.integration.endpoints.defaultTimeout
-
Java DSL 提供的 and 现在公开了 . 有关更多信息,请参阅未到达响应时的网关行为。
@MessagingGateway
GatewayEndpointSpec
errorOnTimeout
MethodInvocationGateway
MessagingGatewaySupport
-
提供类似模板的 API,用于在锁定时执行提供的任务。 有关更多信息,请参见分布式锁。
LockRegistry
-
轮询终端节点的默认触发器现在是具有 1 秒固定延迟期的实例;以前,默认值为 10 毫秒。 有关更多信息,请参阅轮询使用者。
PeriodicTrigger
WebSockets 更改
-
对于服务器和客户端 WebSocket 容器,现在可以通过 在 XML 中和 XML 中配置发送缓冲区溢出策略。 此策略确定会话的出站消息缓冲区达到配置的限制时的行为。 有关更多信息,请参阅 WebSockets 支持。
IntegrationWebSocketContainer
send-buffer-overflow-strategy
Apache Kafka 支持更改
现在,从使用者属性中提取配置,并重新引发从失败的记录标头中提取的配置。
有关更多信息,请参阅 Kafka 入站通道适配器。KafkaMessageSource
ErrorHandlingDeserializer
DeserializationException
JDBC 支持更改
的 , , , 和 在方法中对各自的表实施并执行查询,以确保目标数据库中存在所需的表(根据提供的前缀)。
现在提供用于轮询查询的单个语句。
为此,从 .
有关更多信息,请参阅 JDBC Message Store。JdbcMessageStore
JdbcChannelMessageStore
JdbcMetadataStore
DefaultLockRepository
SmartLifecycle
SELECT COUNT
start()
PostgresChannelMessageStoreQueryProvider
DELETE…RETURNING
ChannelMessageStoreQueryProvider
isSingleStatementForPoll
JdbcChannelMessageStore
MongoDB 支持更改
中引入了一个新选项,用于禁用自动索引创建。
有关示例,请参阅 MongoDB Message Store。setCreateIndexes(boolean)
AbstractConfigurableMongoDbMessageStore
远程文件支持更改
FtpLastModifiedFileListFilter
,并且已引入以允许根据上次修改的策略分别对 和 进行文件筛选。
有关更多信息,请参阅 FTP 入站通道适配器、SFTP 入站通道适配器和 SMB 入站通道适配器。SftpLastModifiedFileListFilter
SmbLastModifiedFileListFilter
FTP
SFTP
SMB
SFTP 支持更改
引入了一种新方法,用于在覆盖时支持自定义。
有关更多信息,请参阅 SFTP Session Factory 。DefaultSftpSessionFactory.createSftpClient(…)
SftpClient
安全支持更改
module 中的最后一个类已被弃用,取而代之的是移动到 module 的类似类。
有关更多信息,请参见 Spring Integration 中的安全性。spring-integration-security
SecurityContextPropagationChannelInterceptor
spring-security-messaging