Changes between 5.2 and 5.3
New Components
Integration Pattern
IntegrationPattern
抽象已被引入,以指示 Spring Integration 组件所属的企业集成模式(IntegrationPatternType
)和类别。有关此抽象及其用例的更多信息,请参阅其 Java 文档和 Integration Graph。
ReactiveMessageHandler
ReactiveMessageHandler
现在在该框架中得到本机支持。有关更多信息,请参见 ReactiveMessageHandler。
ReactiveMessageSourceProducer
ReactiveMessageSourceProducer
是 MessageProducerSupport
的反应式实现,可将提供的 MessageSource
包装到 Flux
中,以按需进行 receive()
调用。有关详细信息,请参阅 Reactive Streams Support。
Java DSL Extensions
已引入一个新的 IntegrationFlowExtension
API,用于允许使用自定义或组合 EIP 操作符扩展现有 Java DSL。这也是为任何开箱即用的 IntegrationComponentSpec
扩展引入自定义器的机会。有关更多信息,请参见 DSL Extensions。
Kotlin DSL
已引入用于集成流配置的 Kotlin DSL。有关详细信息,请参阅 Kotlin DSL Chapter。
ReactiveRequestHandlerAdvice
提供了一个 ReactiveRequestHandlerAdvice
来定制消息处理程序的 Mono
回复。有关详细信息,请参阅 Reactive Advice。
HandleMessageAdviceAdapter
提供了一个 HandleMessageAdviceAdapter
来包装任何 MethodInterceptor
,以在 MessageHandler.handleMessage()
上应用,而不是默认 AbstractReplyProducingMessageHandler.RequestHandler.handleRequestMessage()
行为。有关详细信息,请参阅 Handling Message Advice。
MongoDB Reactive Channel Adapters
spring-integration-mongodb
模块现在提供了适用于 Spring Data 中的 Reactive MongoDb 驱动程序支持的通道适配器实现。此外,MongoDbChangeStreamMessageProducer
中还提供了对 MongoDb 变更流支持的反应式实现。有关详细信息,请参阅 MongoDB Support。
ReceiveMessageAdvice
已引入一个特殊的 ReceiveMessageAdvice
来具体代理 MessageSource.receive()
或 PollableChannel.receive()
。有关更多信息,请参见 Smart Polling。
General Changes
此网关代理现在默认不会代理 default
方法。有关详细信息,请参阅 xref:gateway.adoc#gateway-calling-default-methods[Invoking default
方法。
内部组件(例如 _org.springframework.integration.errorLogger
)现在在其在集成图中表示时将拥有一个缩写名称。有关更多信息,请参见 Integration Graph。
在聚合器中,当 MessageGroupProcessor
返回一个 Message
时,如果 sequenceDetails
与组中第一条消息的标头匹配,则在输出消息上执行 MessageBuilder.popSequenceDetails()
。有关更多信息,请参见 Aggregator Programming Model。
一个基于 BroadcastCapableChannel`和 `BroadcastPublishSubscribeSpec`的新 `publishSubscribeChannel()`运算符已添加到 Java DSL。在将子流配置为像 `SubscribableJmsChannel
、`SubscribableRedisChannel`等经纪人支持的通道的发布订阅者时,此流畅 API 具有优势。请参阅 Sub-flows support以了解更多信息。
Spring Integration 中的事务支持现在还包括如果 MessageSource
或 MessageHandler
实现为要发送有效负载的反应式类型,则配置 ReactiveTransactionManager
的选项。有关更多信息,请参见 TransactionInterceptorBuilder
。另外,请参见 Reactive Transactions。
已将用于注册 ChannelInterceptor
实例的新 intercept()
运算符添加到 Java DSL 中,而无需创建显式通道。有关详细信息,请参阅 Operator intercept()。
MessageStoreSelector
有一种比较旧值和新值的新机制。有关详细信息,请参阅 Idempotent Receiver Enterprise Integration Pattern。
MessageProducerSupport
基类现在有一个 subscribeToPublisher(Publisher<? extends Message<?>>)
API,允许实现通过反应式 Publisher
发出消息的消息驱动生产者端点。有关详细信息,请参阅 Reactive Streams Support。
AMQP Changes
出站通道适配器有一个新属性 multiSend
,允许在一个 RabbitTemplate
调用范围内发送多条消息。有关详细信息,请参阅 AMQP Outbound Channel Adapter。
入站通道适配器现在支持将 consumerBatchEnabled
属性设置为 true
的侦听器容器。有关详细信息,请参阅 AMQP Inbound Channel Adapter。
HTTP Changes
AbstractHttpRequestExecutingMessageHandler
上的 encodeUri
属性已被弃用,取而代之的是新引入的 encodingMode
。有关更多信息,请参见 DefaultUriBuilderFactory.EncodingMode
JavaDocs 和 Controlling URI Encoding。这也影响 WebFluxRequestExecutingMessageHandler
、各自的 Java DSL 和 XML 配置。相同的选项添加到 AbstractWebServiceOutboundGateway
中。
Web Services Changes
已为 Web 服务组件添加了 Java DSL 支持。AbstractWebServiceOutboundGateway
上的 encodeUri
属性已被弃用,取而代之的是新引入的 encodingMode
- 类似于上述 HTTP 更改。有关详细信息,请参阅 Web Services Support。
TCP Changes
默认情况下,FailoverClientConnectionFactory
不再进行故障回退,直到当前连接出现故障。有关更多信息,请参见 TCP Failover Client Connection Factory。
TcpOutboundGateway
现支持异步请求/回复。有关更多信息,请访问 TCP Gateways。
现在,你可以将某个任意测试配置到用于执行新连接的客户端连接中。有关更多信息,请访问 Testing Connections。
RSocket Changes
已将 decodeFluxAsUnit
选项添加到 RSocketInboundGateway
中,其含义是解码传入的 Flux
为一个单元,或对其中的每个事件应用解码。有关更多信息,请参见 RSocket Inbound Gateway。
Zookeeper Changes
LeaderInitiatorFactoryBean
(以及其 XML <int-zk:leader-listener>
)公开了一个 candidate
选项,以便对 Candidate
配置进行更多控制。有关更多信息,请参见 Leadership event handling。
MQTT Changes
现在可以配置入站通道适配器以提供用户控制权,以便在消息被确认已交付时进行控制。有关更多信息,请参见 Manual Acks。
现在,在无法创建连接或连接丢失时,出站适配器将发布 MqttConnectionFailedEvent
。以前,只有入站适配器这样做。请参阅 MQTT Events。
(S)FTP Changes
除了 File
、byte[]
、String
和 InputStream
,FileTransferringMessageHandler
(例如对于 FTP 和 SFTP)现在还支持一个 org.springframework.core.io.Resource
。有关更多信息,请参阅 SFTP Support 和 FTP Support。
File Changes
对于 markersJson
模式,FileSplitter
不再需要 Jackson 处理器(或类似项)依赖项。它使用 SimpleJsonSerializer
来对 FileSplitter.FileMarker
实例进行直接字符串表示。有关更多信息,请访问 FileSplitter。