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

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

新组件

集成模式

引入了抽象来指示 Spring Integration 组件属于哪个企业集成模式 (an ) 和类别。 请参阅其 JavaDocs 和 Integration Graph,了解有关此抽象及其用例的更多信息。IntegrationPatternIntegrationPatternTypeSpring中文文档

ReactiveMessageHandler

现在在框架中原生支持。 有关更多信息,请参见 ReactiveMessageHandlerReactiveMessageHandlerSpring中文文档

ReactiveMessageSourceProducer

是将提供的包装成按需调用的响应式实现。 有关详细信息,请参阅响应式流支持ReactiveMessageSourceProducerMessageProducerSupportMessageSourceFluxreceive()Spring中文文档

Java DSL 扩展

引入了一个新的 API,允许使用自定义或组合的 EIP 运算符扩展现有的 Java DSL。 这也可用于为任何开箱即用的扩展引入定制器。 有关详细信息,请参阅 DSL 扩展IntegrationFlowExtensionIntegrationComponentSpecSpring中文文档

Kotlin DSL

引入了用于集成流配置的 Kotlin DSL。 有关详细信息,请参阅 Kotlin DSL 章节Spring中文文档

ReactiveRequestHandlerAdvice

提供 A 用于自定义来自消息处理程序的回复。 有关详细信息,请参阅反应性建议ReactiveRequestHandlerAdviceMonoSpring中文文档

句柄消息建议适配器

提供 A 来包装任何用于应用而不是默认行为。 有关详细信息,请参阅处理消息建议HandleMessageAdviceAdapterMethodInterceptorMessageHandler.handleMessage()AbstractReplyProducingMessageHandler.RequestHandler.handleRequestMessage()Spring中文文档

MongoDB 反应式通道适配器

该模块现在为 Spring Data 中的 Reactive MongoDb 驱动程序支持提供通道适配器实现。 此外,MongoDb 更改流支持的响应式实现也随 . 有关更多信息,请参阅 MongoDB 支持spring-integration-mongodbMongoDbChangeStreamMessageProducerSpring中文文档

接收消息建议

一个特殊的已经引入到代理正好或. 有关详细信息,请参阅智能轮询ReceiveMessageAdviceMessageSource.receive()PollableChannel.receive()Spring中文文档

一般更改

默认情况下,网关代理现在不代理方法。 有关详细信息,请参阅调用默认方法defaultSpring中文文档

内部组件(如 )现在在积分图中表示时具有缩短的名称。 有关更多信息,请参见集成图_org.springframework.integration.errorLoggerSpring中文文档

在聚合器中,当返回 时,如果 与组第一条消息中的标头匹配,则对输出消息执行 。 有关详细信息,请参阅聚合器编程模型MessageGroupProcessorMessageMessageBuilder.popSequenceDetails()sequenceDetailsSpring中文文档

Java DSL 中添加了一个基于 和 的新运算符。 当我们将子流配置为代理支持的渠道(如 等)的 pub-sub 订阅者时,这种流畅的 API 具有其优势。 有关详细信息,请参阅子流支持publishSubscribeChannel()BroadcastCapableChannelBroadcastPublishSubscribeSpecSubscribableJmsChannelSubscribableRedisChannelSpring中文文档

Spring Integration 中的事务支持现在还包括用于配置 if a 或 实现生成要发送的有效负载的反应式类型的选项。 有关详细信息,请参阅。 另请参阅反应式事务ReactiveTransactionManagerMessageSourceMessageHandlerTransactionInterceptorBuilderSpring中文文档

Java DSL 中添加了一个新运算符,用于在不创建显式通道的情况下注册实例。 有关更多信息,请参见运算符 intercept()。intercept()ChannelInterceptorSpring中文文档

具有比较新旧值的新机制。 有关详细信息,请参阅幂等接收方企业集成模式MessageStoreSelectorSpring中文文档

基类现在有一个 API,允许实现消息驱动的生产者端点,这些端点通过反应式 . 有关详细信息,请参阅响应式流支持MessageProducerSupportsubscribeToPublisher(Publisher<? extends Message<?>>)PublisherSpring中文文档

AMQP 更改

出站通道适配器具有一个新属性,允许在一次调用范围内发送多条消息。 有关详细信息,请参阅 AMQP 出站通道适配器multiSendRabbitTemplateSpring中文文档

入站通道适配器现在支持属性设置为 的侦听器容器。 请参阅 AMQP 入站通道适配器consumerBatchEnabledtrueSpring中文文档

HTTP 更改

上的属性已被弃用,取而代之的是新引入的 . 有关更多信息,请参阅 JavaDocs 和控制 URI 编码。 这也会影响相应的 Java DSL 和 XML 配置。 相同的选项将添加到 .encodeUriAbstractHttpRequestExecutingMessageHandlerencodingModeDefaultUriBuilderFactory.EncodingModeWebFluxRequestExecutingMessageHandlerAbstractWebServiceOutboundGatewaySpring中文文档

Web 服务更改

添加了对 Web 服务组件的 Java DSL 支持。 上的属性已被弃用,取而代之的是新引入的 - 类似于上面的 HTTP 更改。 有关更多信息,请参见 Web 服务支持encodeUriAbstractWebServiceOutboundGatewayencodingModeSpring中文文档

TCP 更改

默认情况下,在当前连接失败之前,不再进行故障回复。 有关更多信息,请参见 TCP 故障转移客户端连接工厂FailoverClientConnectionFactorySpring中文文档

现在支持异步请求/回复。 有关详细信息,请参阅 TCP 网关TcpOutboundGatewaySpring中文文档

现在,您可以配置客户端连接以对新连接执行一些任意测试。 有关详细信息,请参阅测试连接Spring中文文档

RSocket 更改

添加了一个选项,其含义是将传入解码为单个单元或对其中的每个事件应用解码。 有关详细信息,请参阅 RSocket 入站网关decodeFluxAsUnitRSocketInboundGatewayFluxSpring中文文档

Zookeeper 更改

A(及其 XML)公开了一个选项,用于对配置进行更多控制。 有关详细信息,请参阅领导事件处理LeaderInitiatorFactoryBean<int-zk:leader-listener>candidateCandidateSpring中文文档

MQTT 更改

现在可以将入站通道适配器配置为让用户控制何时确认消息已传递。 有关详细信息,请参阅手动确认Spring中文文档

现在,出站适配器会在无法创建连接或丢失连接时发布。 以前,只有入站适配器这样做。 请参阅 MQTT 事件MqttConnectionFailedEventSpring中文文档

(小)FTP 更改

(例如,对于 FTP 和 SFTP)除了 、 之外,现在还支持 . 有关详细信息,请参阅 SFTP 支持FTP 支持FileTransferringMessageHandlerFilebyte[]StringInputStreamorg.springframework.core.io.ResourceSpring中文文档

文件更改

该模式不再需要 Jackson 处理器(或类似)依赖项。 它使用 a 作为实例的简单字符串表示形式。 有关详细信息,请参阅 FileSplitterFileSplittermarkersJsonSimpleJsonSerializerFileSplitter.FileMarkerSpring中文文档