此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Integration 6.3.1！Spring中文文档

此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Integration 6.3.1！Spring中文文档

对于那些已经熟悉 Spring Integration 的人，本章简要概述了 6.2 版的新功能。Spring中文文档

如果您对早期版本中引入的更改和功能感兴趣，请参阅更改历史记录。Spring中文文档

Spring Integration 6.2 有哪些新功能？

如果对更多详细信息感兴趣，请参阅在 6.2 开发过程中解决的问题跟踪器票证。Spring中文文档

通常，项目已移至最新的依赖项版本。Spring中文文档

新组件

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中文文档