新组件
添加了用于集成流定义的 Groovy DSL 实现。 有关详细信息,请参阅 Groovy DSL。
MQTT 客户端管理器
添加了新的 MQTT,以支持跨不同通道适配器的可重用 MQTT 连接。
有关更多信息,请参阅共享 MQTT 客户端支持。ClientManager
GraphQL 支持
添加了 GraphQL 支持。 有关详细信息,请参阅 GraphQL 支持。
Apache Camel 支持
引入了对 Apache Camel 路由的支持。 有关详细信息,请参阅 Apache Camel 支持。
Hazelcast 支持
Hazelcast Spring Integration Extensions 项目已作为模块迁移。
有关详细信息,请参阅 Hazelcast 支持。spring-integration-hazelcast
SMB 支持
已从 Spring Integration Extensions 项目添加了 SMB 支持。
Java DSL(参见工厂)也已添加到此模块中。
介绍了 an 和 实现。
有关详细信息,请参阅 SMB 支持。org.springframework.integration.smb.dsl.Smb
SmbStreamingMessageSource
SmbOutboundGateway
PostgreSQL 推送通知
A 允许在将新消息添加到 .PostgresSubscribableChannel
PostgresChannelMessageTableSubscriber
JdbcChannelMessageStore
有关更多信息,请参阅 PostgreSQL:接收推送通知。
RabbitMQ Stream Queue 支持
AMQP 模块已得到增强,可支持使用 RabbitMQ 流队列的入站和出站通道适配器。 有关更多信息,请参阅 RabbitMQ 流队列支持。
阿帕奇 MINA SFTP
SFTP 模块已经从过时的 JCraft JSch 库完全重新设计为 Apache MINA 项目中更强大、更现代的模块。org.apache.sshd:sshd-sftp
有关详细信息,请参阅 SFTP 适配器。
千分尺观察
现在支持使用 Micrometer 启用计时器观察和跟踪。 有关详细信息,请参阅千分尺观察。
GraalVM 多语言支持
脚本模块现在提供了基于 GraalVM 多语言支持的实现。
JavaScript 支持现在基于此执行器,因为它的 JSR223 实现已自行从 Java 中删除。
有关详细信息,请参阅脚本支持。PolyglotScriptExecutor
Apache Cassandra 支持
Apache Cassandra Spring Integration Extensions 项目已作为模块迁移。
有关详细信息,请参阅 Apache Cassandra 支持。spring-integration-cassandra
原生图像
提供了创建 GraalVM 本机映像的支持。 有关详细信息,请参阅本机映像支持。
一般更改
消息传递注释现在已使用,并且可以在同一服务方法上多次声明相同的类型。
消息传递注释不再需要属性作为数组。@Repeatable
poller
@Poller
有关详细信息,请参阅注释支持。
为方便起见,用于 的 XML 和 Java DSL 基于 ,现在设置了一个 ,因此收集器部分可以依赖默认的关联策略。RecipientListRouter
applySequence = true
有关详细信息,请参阅 Scatter-Gather。
对 .
现在,设置 a 也会将属性重置为 ,因此不会尝试从其键解析通道,但逻辑会立即回退到将消息发送到 .AbstractMappingMessageRouter
defaultOutputChannel
channelKeyFallback
false
defaultOutputChannel
有关详细信息,请参阅路由器选项。
现在不会在输出上拆分 (除非它是 ) 的结果,而是发出包含整个集合作为有效负载的单个消息。AggregatingMessageHandler
Collection<Message<?>>
MessageGroupProcessor
SimpleMessageGroupProcessor
有关详细信息,请参阅聚合器。
工厂现在被标记为已弃用,以支持界面本身中可用的 Fluent API。
工厂类将在将来的版本中删除。IntegrationFlows
IntegrationFlow
有关更多信息,请参见 Java DSL。
从 Spring Framework 开始已弃用。
所有 Spring Integration 异步 API 都已迁移到 .org.springframework.util.concurrent.ListenableFuture
6.0
CompletableFuture
Messaging Gateway 接口方法现在可以返回,并正确异步执行下游流。Future<Void>
Mono<Void>
除了注释外,界面还可以标记为 .@MessagingGateway
@Primary
@MessagingGateway
接口现在可以用作配置资源。@Import
网关代理 Bean 的缺省命名策略可以通过属性进行定制。
如果存在 bean,则在回退到 .@IntegrationComponentScan.nameGenerator()
AnnotationConfigUtils.CONFIGURATION_BEAN_NAME_GENERATOR
AnnotationBeanNameGenerator
有关详细信息,请参阅 Messaging Gateway。
现在,框架将 Bean 声明为 的实例,而不是之前已弃用的 。integrationGlobalProperties
org.springframework.integration.context.IntegrationProperties
java.util.Properties
如果查询未返回任何记录,则生成集合作为回复的消息处理程序(例如,和其他基于数据库的网关)现在将返回空的结果列表。
以前,返回结束流或引发异常,具体取决于 .JpaOutboundGateway
JdbcOutboundGateway
null
requiresReply
RMI 移除
该模块在以前的版本中被弃用后已完全删除。
没有替代品:建议迁移到更安全的网络和应用程序协议,例如 WebSockets、RSockets、gRPC 或 REST。spring-integration-rmi
GemFire 去除
该模块已被完全删除,因为 VMware GemFire 或 Apache Geode 不支持 Spring Data。spring-integration-gemfire
2022.0.0
HTTP 更改
表达式计算上下文的变量(在 中公开)现在是一个变量,用于携带客户端设置的 cookie 的所有值。
有关详细信息,请参阅 HTTP 支持。#cookies
HttpRequestHandlingEndpointSupport
MultiValueMap
Apache Kafka 更改
在入站网关或消息驱动的通道适配器上提供 a 时,如果还提供了 an,则会自动配置 an。RetryTemplate
errorChannel
ErrorMessageSendingRecoverer
此外,还提供了新的;这可以与 A 一起使用,以避免长时间聚合重试延迟导致分区重新平衡的问题。KafkaErrorMessageSendingRecoverer
DefaultErrorHandler
有关更多信息,请参见 Spring for Apache Kafka 支持。
JDBC 更改
现在可以提供 a 而不是依赖于应用程序上下文中的主 bean。DefaultLockRepository
PlatformTransactionManager
有关更多信息,请参阅 JDBC Lock Registry。
TCP/IP 更改
默认情况下,and 的属性现在设置为 and 的属性,以避免在未配置 DNS 的环境中出现延迟。lookupHost
AbstractConnectionFactory
DatagramPacketMessageMapper
false
有关详细信息,请参阅 TCP 和 UDP 支持。
JMS 更改
现在创建一个 instead of if 选项设置为 。JmsOutboundGateway
TemporaryTopic
TemporaryQueue
replyPubSubDomain
true
有关更多信息,请参阅 JMS 支持。
安全更改
及其注释和 XML 配置已被弃用,取而代之的是 。ChannelSecurityInterceptor
@SecuredChannel
<secured-channels>
AuthorizationChannelInterceptor
有关详细信息,请参阅安全支持。
Webflux 请求属性支持
添加了对 的 Webclient 请求属性支持。WebFluxRequestExecutingMessageHandler
有关详细信息,请参阅 WebFlux 请求属性。