对于最新的稳定版本,请使用 Spring Integration 6.3.1! |
对于最新的稳定版本,请使用 Spring Integration 6.3.1! |
新组件
集成模式
引入了抽象来指示 Spring Integration 组件属于哪个企业集成模式 (an ) 和类别。
请参阅其 JavaDocs 和 Integration Graph,了解有关此抽象及其用例的更多信息。IntegrationPattern
IntegrationPatternType
ReactiveMessageHandler
现在在框架中原生支持。
有关更多信息,请参见 ReactiveMessageHandler。ReactiveMessageHandler
ReactiveMessageSourceProducer
是将提供的包装成按需调用的响应式实现。
有关详细信息,请参阅响应式流支持。ReactiveMessageSourceProducer
MessageProducerSupport
MessageSource
Flux
receive()
Java DSL 扩展
引入了一个新的 API,允许使用自定义或组合的 EIP 运算符扩展现有的 Java DSL。
这也可用于为任何开箱即用的扩展引入定制器。
有关详细信息,请参阅 DSL 扩展。IntegrationFlowExtension
IntegrationComponentSpec
Kotlin DSL
引入了用于集成流配置的 Kotlin DSL。 有关详细信息,请参阅 Kotlin DSL 章节。
ReactiveRequestHandlerAdvice
提供 A 用于自定义来自消息处理程序的回复。
有关详细信息,请参阅反应性建议。ReactiveRequestHandlerAdvice
Mono
句柄消息建议适配器
提供 A 来包装任何用于应用而不是默认行为。
有关详细信息,请参阅处理消息建议。HandleMessageAdviceAdapter
MethodInterceptor
MessageHandler.handleMessage()
AbstractReplyProducingMessageHandler.RequestHandler.handleRequestMessage()
MongoDB 反应式通道适配器
该模块现在为 Spring Data 中的 Reactive MongoDb 驱动程序支持提供通道适配器实现。
此外,MongoDb 更改流支持的响应式实现也随 .
有关更多信息,请参阅 MongoDB 支持。spring-integration-mongodb
MongoDbChangeStreamMessageProducer
接收消息建议
一个特殊的已经引入到代理正好或.
有关详细信息,请参阅智能轮询。ReceiveMessageAdvice
MessageSource.receive()
PollableChannel.receive()
一般更改
默认情况下,网关代理现在不代理方法。
有关详细信息,请参阅调用默认
方法。default
内部组件(如 )现在在积分图中表示时具有缩短的名称。
有关更多信息,请参见集成图。_org.springframework.integration.errorLogger
在聚合器中,当返回 时,如果 与组第一条消息中的标头匹配,则对输出消息执行 。
有关详细信息,请参阅聚合器编程模型。MessageGroupProcessor
Message
MessageBuilder.popSequenceDetails()
sequenceDetails
Java DSL 中添加了一个基于 和 的新运算符。
当我们将子流配置为代理支持的渠道(如 等)的 pub-sub 订阅者时,这种流畅的 API 具有其优势。
有关详细信息,请参阅子流支持。publishSubscribeChannel()
BroadcastCapableChannel
BroadcastPublishSubscribeSpec
SubscribableJmsChannel
SubscribableRedisChannel
Spring Integration 中的事务支持现在还包括用于配置 if a 或 实现生成要发送的有效负载的反应式类型的选项。
有关详细信息,请参阅。
另请参阅反应式事务。ReactiveTransactionManager
MessageSource
MessageHandler
TransactionInterceptorBuilder
Java DSL 中添加了一个新运算符,用于在不创建显式通道的情况下注册实例。
有关更多信息,请参见运算符 intercept()。intercept()
ChannelInterceptor
具有比较新旧值的新机制。
有关详细信息,请参阅幂等接收方企业集成模式。MessageStoreSelector
基类现在有一个 API,允许实现消息驱动的生产者端点,这些端点通过反应式 .
有关详细信息,请参阅响应式流支持。MessageProducerSupport
subscribeToPublisher(Publisher<? extends Message<?>>)
Publisher
AMQP 更改
出站通道适配器具有一个新属性,允许在一次调用范围内发送多条消息。
有关详细信息,请参阅 AMQP 出站通道适配器。multiSend
RabbitTemplate
入站通道适配器现在支持属性设置为 的侦听器容器。
请参阅 AMQP 入站通道适配器consumerBatchEnabled
true
HTTP 更改
上的属性已被弃用,取而代之的是新引入的 .
有关更多信息,请参阅 JavaDocs 和控制 URI 编码。
这也会影响相应的 Java DSL 和 XML 配置。
相同的选项将添加到 .encodeUri
AbstractHttpRequestExecutingMessageHandler
encodingMode
DefaultUriBuilderFactory.EncodingMode
WebFluxRequestExecutingMessageHandler
AbstractWebServiceOutboundGateway
Web 服务更改
添加了对 Web 服务组件的 Java DSL 支持。
上的属性已被弃用,取而代之的是新引入的 - 类似于上面的 HTTP 更改。
有关更多信息,请参见 Web 服务支持。encodeUri
AbstractWebServiceOutboundGateway
encodingMode
TCP 更改
默认情况下,在当前连接失败之前,不再进行故障回复。
有关更多信息,请参见 TCP 故障转移客户端连接工厂。FailoverClientConnectionFactory
现在支持异步请求/回复。
有关详细信息,请参阅 TCP 网关。TcpOutboundGateway
现在,您可以配置客户端连接以对新连接执行一些任意测试。 有关详细信息,请参阅测试连接。
RSocket 更改
添加了一个选项,其含义是将传入解码为单个单元或对其中的每个事件应用解码。
有关详细信息,请参阅 RSocket 入站网关。decodeFluxAsUnit
RSocketInboundGateway
Flux
Zookeeper 更改
A(及其 XML)公开了一个选项,用于对配置进行更多控制。
有关详细信息,请参阅领导事件处理。LeaderInitiatorFactoryBean
<int-zk:leader-listener>
candidate
Candidate
MQTT 更改
现在可以将入站通道适配器配置为让用户控制何时确认消息已传递。 有关详细信息,请参阅手动确认。
现在,出站适配器会在无法创建连接或丢失连接时发布。
以前,只有入站适配器这样做。
请参阅 MQTT 事件。MqttConnectionFailedEvent
文件更改
该模式不再需要 Jackson 处理器(或类似)依赖项。
它使用 a 作为实例的简单字符串表示形式。
有关详细信息,请参阅 FileSplitter。FileSplitter
markersJson
SimpleJsonSerializer
FileSplitter.FileMarker