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