此版本仍在开发中,尚未被视为稳定版。如需最新稳定版本,请使用 Spring Integration 7.0.4!spring-doc.cadn.net.cn

6.1 与 6.2 版本之间的变更

新组件

Debezium 入站通道适配器

基于 Debezium 引擎的变更数据捕获 (CDC) 通道适配器,用于捕获数据库变更事件,将其转换为消息并流式传输到输出通道。 有关更多信息,请参阅 Debezium 支持。spring-doc.cadn.net.cn

常规变更

  • <poller>和@Poller注解的XML配置现在支持ISO 8601时长格式,用于fixed-delay、fixed-rate和initial-delay选项。 有关更多信息,请参阅轮询消费者。spring-doc.cadn.net.cn

  • Java、Groovy 和 Kotlin DSL 现在在 IntegrationFlowDefinition 中提供了特定上下文的 Consumer 参数方法,用于使用一个构建器和可读的选项来配置端点及其处理器。 例如,请参见 Java DSL 章节 中的 transformWith() 和 splitWith()。spring-doc.cadn.net.cn

  • 已引入一个新的spring.integration.endpoints.defaultTimeout全局属性,用于覆盖应用程序中所有端点的默认30秒超时时间。 有关更多信息,请参阅全局属性。spring-doc.cadn.net.cn

  • Java DSL 提供的@MessagingGateway和GatewayEndpointSpec现在会暴露MessagingGatewaySupport内部MethodInvocationGateway扩展的errorOnTimeout属性。 有关更多信息,请参阅当没有响应到达时的网关行为。spring-doc.cadn.net.cn

  • The LockRegistry 提供类似模板的 API,用于在锁定状态下执行提供的任务。 有关更多信息,请参阅 分布式锁。spring-doc.cadn.net.cn

  • 轮询端点的默认触发器现在是一个带有1秒固定延迟周期的PeriodicTrigger实例;此前,默认值为10毫秒。 有关更多信息,请参阅轮询消费者。spring-doc.cadn.net.cn

WebSockets 变更

  • 对于服务器和客户端 WebSocket 容器,发送缓冲区溢出策略现在可以在 IntegrationWebSocketContainer 中配置,也可以通过 XML 中的 send-buffer-overflow-strategy 进行配置。 该策略用于确定当会话的出站消息缓冲区达到配置限制时的行为。 有关更多信息,请参阅 WebSocket 支持。spring-doc.cadn.net.cn

Apache Kafka 支持变更

The KafkaMessageSource 现在从消费者属性中提取 ErrorHandlingDeserializer 配置,并重新抛出从失败的记录头中提取的 DeserializationException。 有关更多信息,请参阅 Kafka 入站通道适配器。spring-doc.cadn.net.cn

JDBC 支持变更

JdbcMessageStore、JdbcChannelMessageStore、JdbcMetadataStore和DefaultLockRepository实现SmartLifecycle,并在start()方法中对各自表执行SELECT COUNT查询,以确保根据提供的表前缀,所需表存在于目标数据库中。 现在,PostgresChannelMessageStoreQueryProvider为轮询查询提供了单个DELETE…​RETURNING语句。 为此,ChannelMessageStoreQueryProvider暴露了isSingleStatementForPoll选项,该选项从JdbcChannelMessageStore中获取。 有关更多信息,请参阅JDBC 消息存储。spring-doc.cadn.net.cn

MongoDB 支持变更

在AbstractConfigurableMongoDbMessageStore中引入了一种新选项setCreateIndexes(boolean),用于禁用自动索引创建。 有关示例,请参阅MongoDB 消息存储。spring-doc.cadn.net.cn

远程文件支持变更

FtpLastModifiedFileListFilter, SftpLastModifiedFileListFilter and SmbLastModifiedFileListFilter 已引入,分别用于为 FTP、SFTP 和 SMB 实现基于最后修改时间的文件过滤策略。 有关更多信息,请参见 FTP 入站通道适配器、SFTP 入站通道适配器 以及 SMB 入站通道适配器。spring-doc.cadn.net.cn

SFTP 支持变更

引入了一个新的 DefaultSftpSessionFactory.createSftpClient(…​) 方法,以在重写时支持自定义的 SftpClient。 有关更多信息,请参阅 SFTP Session Factory。spring-doc.cadn.net.cn

安全支持变更

spring-integration-security模块中的最后一个类已被弃用,类似类已移至spring-security-messaging模块。 有关更多信息,请参阅Spring Integration 中的安全性。spring-doc.cadn.net.cn