新组件

Debezium 入站通道适配器

基于 Debezium 引擎的变更数据捕获 （CDC） 通道适配器，允许捕获数据库变更事件，将它们转换为消息并将其流式传输到出站通道。 有关详细信息，请参阅 Debezium 支持。Spring中文文档

一般更改

  • 的 XML 配置和批注现在支持 和 选项的 ISO 8601 持续时间格式。 有关详细信息，请参阅轮询使用者。<poller>@Pollerfixed-delayfixed-rateinitial-delaySpring中文文档

  • Java、Groovy 和 Kotlin DSL 现在具有特定于上下文的方法，只需一个参数即可使用一个构建器和可读选项来配置端点及其处理程序。 例如，请参见 Java DSL 章节中的 。IntegrationFlowDefinitionConsumertransformWith()splitWith()Spring中文文档

  • 引入了一个新的全局属性，用于覆盖应用程序中所有终结点的默认 30 秒超时。 有关详细信息，请参阅全局属性。spring.integration.endpoints.defaultTimeoutSpring中文文档

  • Java DSL 提供的 and 现在公开了 . 有关详细信息，请参阅未响应到达时的网关行为。@MessagingGatewayGatewayEndpointSpecerrorOnTimeoutMethodInvocationGatewayMessagingGatewaySupportSpring中文文档

  • 提供类似模板的 API，用于在锁定时执行提供的任务。 有关详细信息，请参阅分布式锁。LockRegistrySpring中文文档

  • 轮询终端节点的默认触发器现在是具有 1 秒固定延迟期的实例;以前，默认值为 10 毫秒。 有关详细信息，请参阅轮询使用者。PeriodicTriggerSpring中文文档

WebSockets 更改

  • 对于服务器和客户端 WebSocket 容器，发送缓冲区溢出策略现在可以通过 在 XML 中配置。 此策略确定会话的出站消息缓冲区达到配置限制时的行为。 有关详细信息，请参阅 WebSockets 支持。IntegrationWebSocketContainersend-buffer-overflow-strategySpring中文文档

Apache Kafka 支持更改

现在从使用者属性中提取配置，并重新抛出从失败的记录标头中提取的配置。 有关详细信息，请参阅 Kafka 入站通道适配器。KafkaMessageSourceErrorHandlingDeserializerDeserializationExceptionSpring中文文档

JDBC 支持更改

、 和 在方法中对各自的表执行查询，以确保所需的表（根据提供的前缀）存在于目标数据库中。 现在为轮询查询提供单一语句。 为此，公开选项是从 . 有关更多信息，请参阅 JDBC 消息存储库。JdbcMessageStoreJdbcChannelMessageStoreJdbcMetadataStoreDefaultLockRepositorySmartLifecycleSELECT COUNTstart()PostgresChannelMessageStoreQueryProviderDELETE…​RETURNINGChannelMessageStoreQueryProviderisSingleStatementForPollJdbcChannelMessageStoreSpring中文文档

MongoDB 支持更改

引入了一个新选项来禁用自动索引创建。 有关示例，请参阅 MongoDB 消息存储库。setCreateIndexes(boolean)AbstractConfigurableMongoDbMessageStoreSpring中文文档

远程文件支持更改

FtpLastModifiedFileListFilter，并已引入以允许分别基于上次修改的策略对 和 进行文件过滤。 有关详细信息，请参阅 FTP 入站通道适配器、SFTP 入站通道适配器和 SMB 入站通道适配器。SftpLastModifiedFileListFilterSmbLastModifiedFileListFilterFTPSFTPSMBSpring中文文档

SFTP 支持更改

引入了一种新方法，用于在重写时支持自定义。 有关详细信息，请参阅 SFTP 会话工厂。DefaultSftpSessionFactory.createSftpClient(…​)SftpClientSpring中文文档

安全支持更改

模块中的最后一个类已被弃用，取而代之的是移动到模块中的类似类。 有关更多信息，请参见 Spring Integration 中的安全性。spring-integration-securitySecurityContextPropagationChannelInterceptorspring-security-messagingSpring中文文档