Changes between 4.3 and 5.0
请参见 Migration Guide 了解可能影响您应用程序的重要更改。您可以在 wiki 上找到从 2.1 返回的所有版本的迁移指南。
New Components
版本 5.0 添加了许多新组件。
Java DSL
单独的 Spring Integration Java DSL 现已合并到核心 Spring Integration 项目中。IntegrationComponentSpec
通道适配器和网关的实现分配给它们各自的模块。有关 Java DSL 支持的更多信息,请参见 Java DSL。另请参阅 4.3 to 5.0 Migration Guide 中关于迁移到 Spring Integration 5.0 所需步骤的信息。
Testing Support
我们创建了一个新的 Spring Integration 测试框架来帮助测试 Spring Integration 应用程序。现在,借助测试类上的 @SpringIntegrationTest
注解和 MockIntegration
工厂,你可以让用于集成流的 JUnit 测试变得更容易。
有关更多信息,请参阅 Testing support。
MongoDB Outbound Gateway
新的 MongoDbOutboundGateway
允许你通过向其请求通道发送消息,按需对数据库进行查询。
有关更多信息,请参见 MongoDB Outbound Gateway。
WebFlux Gateways and Channel Adapters
我们为 Spring WebFlux 框架网关和通道适配器引入了新的 WebFlux 支持模块。
有关更多信息,请参阅 WebFlux Support。
Content Type Conversion
现在我们为服务方法调用使用基于 InvocableHandlerMethod
的新基础设施,我们可以从有效负载执行 contentType
转换到目标方法参数。
有关更多信息,请参见 Content Type Conversion。
ErrorMessagePublisher
and ErrorMessageStrategy
我们添加了 ErrorMessagePublisher
和 ErrorMessageStrategy
以创建 ErrorMessage
实例。
有关更多信息,请参见 Error Handling。
JDBC Metadata Store
我们为 MetadataStore
实现添加了 JDBC 实现。当您需要确保元数据的交易边界时,它非常有用。
有关更多信息,请参见 JDBC Metadata Store。
General Changes
现在,Spring Integration 完全基于 Spring Framework 5.0
和 Project Reactor 3.1
。不再支持以前版本的 Project Reactor。
Core Changes
对于 @Poller
注释,现在提供了 errorChannel
属性,以便更轻松地配置底层的 MessagePublishingErrorHandler
。有关更多信息,请参阅 Annotation Support。
所有基于 AbstractReplyProducingMessageHandler
的请求应答端点现在都可以启动事务,因此,可以使整个下游流具有事务性。有关更多信息,请参阅 Transaction Support。
SmartLifecycleRoleController
现在提供获取角色中端点状态的方法。有关更多信息,请参见 Endpoint Roles。
现在,默认情况下,POJO 方法将使用 InvocableHandlerMethod
进行调用,但您可以将其配置为像以前一样使用 SpEL。有关详细信息,请参阅 POJO Method invocation。
当针对 POJO 方法作为消息处理程序时,您现在可以用 @Default
注释标记其中一个服务方法,以提供非匹配条件的回调机制。有关详细信息,请参阅 Configuring Service Activator。
我们增加了一个简单的 PassThroughTransactionSynchronizationFactory
来始终将轮询消息存储在当前事务上下文中。该消息用作包装事务完成期间引发的任何原始异常的 MessagingException
的 failedMessage
属性。有关详细信息,请参阅 Transaction Synchronization。
基于聚合器表达式的 ReleaseStrategy
现在针对 MessageGroup
而不是仅仅针对 Message<?>
的集合来估算表达式。有关详细信息,请参阅 Aggregators and Spring Expression Language (SpEL)。
现在,您可以为 ObjectToMapTransformer
提供自定义的 JsonObjectMapper
。
@GlobalChannelInterceptor
注释和 <int:channel-interceptor>
现在支持用于组件名称匹配的否定模式(通过在前面添加 !
)。有关详细信息,请参阅 Global Channel Interceptor Configuration。
当候选对象未能获取锁定时,LockRegistryLeaderInitiator
将通过 DefaultLeaderEventPublisher
发射一个新的 OnFailedToAcquireMutexEvent
。有关详细信息,请参阅 Leadership Event Handling
。
Gateway Changes
当网关方法具有 void
返回类型且提供错误通道时,现在网关可以正确设置 errorChannel
头。之前该头没有填充。这导致同步下游流(在调用线程上运行)将异常发送到已配置的通道,而异步下游流上的异常将被发送到默认的 errorChannel
。
RequestReplyExchanger
接口现在具有 throws MessagingException
从句,以满足建议的消息交换约定。
你现在可以使用 SpEL 表达式指定请求和应答超时。有关更多信息,请参阅 Messaging Gateways。
Aggregator Performance Changes
现在,聚合器默认使用 SimpleSequenceSizeReleaseStrategy
,这种方式更高效,尤其是在处理大型组时。现在,计划在 empty-group-min-timeout
后删除空组。有关详细信息,请参阅 Aggregator。
Splitter Changes
拆分器组件现在可以处理和拆分Java Stream`和Reactive Streams `Publisher`对象。如果输出通道是`ReactiveStreamsSubscribableChannel
,则`AbstractMessageSplitter`为后续迭代构建`Flux`,而不是常规`Iterator`,与被拆分的对象无关。此外,`AbstractMessageSplitter`提供了`protected obtainSizeIfPossible()`方法来判断`Iterable`和`Iterator`对象的大小,如果可能的话。有关更多信息,请参见Splitter。
JMS Changes
以前,Spring Integration JMS XML 配置为 JMS 连接工厂使用默认的 bean 名称 connectionFactory
,允许在组件定义中省略该属性。我们将其重命名为 jmsConnectionFactory
,这是 Spring Boot 在自动配置 JMS 连接工厂 bean 时使用的 bean 名称。
如果您的应用程序依赖于先前的行为,则可以将您的`connectionFactory`bean重命名为`jmsConnectionFactory`或使用其当前名称专门配置您的组件以使用您的bean。有关更多信息,请参见JMS Support。
Mail Changes
一些 IMAP 邮件内容渲染的不一致问题已经得到解决。有关更多信息,请参阅 xref:mail.adoc#imap-format-important[the note in the “Mail-receiving Channel Adapter” 部分。
Feed Changes
我们引入了`FeedEntryMessageSource`的新`Resource`属性,替代了ROME中已弃用的`com.rometools.fetcher.FeedFetcher`。有关更多信息,请参见Feed Adapter。
File Changes
我们引入了新的 FileHeaders.RELATIVE_PATH 消息头,用于在 FileReadingMessageSource 中表示相对路径。
现在,尾适配器支持 idleEventInterval,以便在该期间文件中没有数据时发出事件。
FileWritingMessageHandler 的刷新谓词现在有一个附加参数。
文件出站通道适配器和网关 (FileWritingMessageHandler) 现在支持 REPLACE_IF_MODIFIED FileExistsMode。
它们现在还支持对新写入文件设置文件权限。
现在可以使用新的 FileSystemMarkerFilePresentFileListFilter
。有关详细信息,请参阅 Dealing With Incomplete Data。
FileSplitter 现在提供了一个 firstLineAsHeader 选项,以便将第一行内容作为标题添加到为剩余行发出的消息中。
有关更多信息,请参见 File Support。
FTP and SFTP Changes
入站通道适配器现在有一个名为 max-fetch-size 的属性,此属性用于在本地目录中当前没有文件时限制轮询期间获取的文件数量。默认情况下,它们还使用 local-filter 中的 FileSystemPersistentAcceptOnceFileListFilter 进行配置。
此外,可以通过设置新引入的 scanner 属性为入站通道适配器提供自定义 DirectoryScanner 实现。
现在,您可以将正则表达式和模式过滤器配置为始终传递目录。当您在出站网关中使用递归时,此功能非常有用。
默认情况下,现在所有入站通道适配器(基于流和基于同步)都使用适当的 AbstractPersistentAcceptOnceFileListFilter 实现来防止远程文件重复下载。
现在,FTP 和 SFTP 出站网关在获取远程文件时支持 REPLACE_IF_MODIFIED FileExistsMode。
现在,FTP 和 SFTP 流入站通道适配器在消息头中添加远程文件信息。
FTP 和 SFTP 外出通道适配器(还有 outbound 网关的 PUT
命令)现在也支持 InputStream
作为 payload
。
入站通道适配器现在可以使用新引入的`RecursiveDirectoryScanner`在本地构建文件树。有关注入,请查看FTP Inbound Channel Adapter部分中的`scanner`选项。另外,您现在可以将这些适配器切换到`WatchService`。
我们向 AbstractRemoteFileOutboundGateway
添加了 NLST
命令来执行远程命令列出文件名称。
你现在可以通过 workingDirExpression
向 FtpOutboundGateway
提供,以更改当前请求消息的 FTP 客户端工作目录。
RemoteFileTemplate
现在随 invoke(OperationsCallback<F, T> action)
一起提供,以便在相同线程绑定的 Session
的范围内执行多个 RemoteFileOperations
调用。
我们添加了用于检测不完整远程文件的新过滤器。
FtpOutboundGateway
和 SftpOutboundGateway
现在支持通过使用 GET
或 MGET
命令在成功传输之后删除远程文件的一个选项。
有关更多信息,请参见FTP/FTPS Adapters和SFTP Adapters。
Integration Properties
4.3.2版本添加了一个新的`spring.integration.readOnly.headers`全局属性,允许您自定义`MessageBuilder`向新创建的`Message`中复制的标头列表。有关更多信息,请参见Global Properties。
Stream Changes
我们在 CharacterStreamReadingMessageSource
中增加了一个新的选项,使之能够用于 “pipe” stdin,并在管道关闭时发布一个应用程序事件。有关详细信息,请参阅 Reading from Streams。
Barrier Changes
`BarrierMessageHandler`现在支持一个丢弃通道,迟到的触发消息会发送到该通道。有关更多信息,请参见Thread Barrier。
AMQP Changes
AMQP 出站端点现在支持在你使用 RabbitMQ Delayed Message Exchange 插件时设置一个延迟表达式。
入站端点现在支持 Spring AMQP DirectMessageListenerContainer
。
现在,可轮询的 AMQP 后备通道会阻塞轮询线程的轮询器已配置 receiveTimeout
(默认值:一秒)。
消息转换器添加到的消息属性的标头(如`contentType`)现在用于最终消息中。之前,它取决于转换类型,最终消息中会显示哪些标头和消息属性。若要覆盖转换器设置的标头,请将`headersMappedLast`属性设置为`true`。有关更多信息,请参见AMQP Support。
HTTP Changes
默认情况下,DefaultHttpHeaderMapper.userDefinedHeaderPrefix`属性现在是一个空字符串,而不是`X-
。有关更多信息,请参见HTTP Header Mappings。
默认情况下,uriVariablesExpression
现在使用 SimpleEvaluationContext
(自 5.0.4 起)。
有关详细信息,请参阅 Mapping URI Variables。
MQTT Changes
现在,入站消息使用 RECEIVED_TOPIC
、RECEIVED_QOS
和 RECEIVED_RETAINED
标题进行映射,以避免应用程序中继消息时无意传播到出站消息。
出站通道适配器现在支持主题、qos和保留属性的表达式。默认值保持不变。有关更多信息,请参见MQTT Support。
STOMP Changes
我们更改了STOMP模块以使用基于Project Reactor 3.1`和`reactor-netty`扩展的`ReactorNettyTcpStompClient
。根据`ReactorNettyTcpStompClient`基础,我们将`Reactor2TcpStompSessionManager`重命名为`ReactorNettyTcpStompSessionManager`。有关更多信息,请参见STOMP Support。
Web Services Changes
现在,您可以使用外部配置的 WebServiceTemplate
实例提供 WebServiceOutboundGateway
实例。
DefaultSoapHeaderMapper
现在可以将 javax.xml.transform.Source
用户定义标头映射到 SOAP 标头元素。
简单的 WebService 入站和出站网关现在可以将完整的 WebServiceMessage
处理为 payload
,从而允许操作 MTOM 附件。
有关更多信息,请参见Web Services Support。
Redis Changes
现在提供了 RedisStoreWritingMessageHandler
以及额外的基于 String
的 SpEL 表达式设置程序(便于使用 Java 配置)。您现在还可以在 RedisStoreWritingMessageHandler
上配置 zsetIncrementExpression
。此外,自 ZADD
Redis 命令上的 INCR
选项是可选的以来,此属性已从 true
更改为 false
。
现在,您可以为 RedisInboundChannelAdapter
提供一个用于执行 Redis 侦听器调用者的 Executor
。此外,收到的消息现在包含一个 RedisHeaders.MESSAGE_SOURCE
标头,以指示消息的来源(主题或模式)。
有关更多信息,请参见Redis Support。
TCP Changes
我们添加了一个新的 ThreadAffinityClientConnectionFactory
来将 TCP 连接绑定到线程。
现在,您可以配置 TCP 连接工厂以支持 PushbackInputStream
实例,让反序列化程序在“向前读取”后“不读”(推回)字节。
我们添加了一个没有 maxMessageSize
的 ByteArrayElasticRawDeserializer
来根据需要控制和缓冲传入数据。
有关更多信息,请参见TCP and UDP Support。
JDBC Changes
JdbcMessageChannelStore
现在为 ChannelMessageStorePreparedStatementSetter
提供了一个设置程序,让您可以自定义消息插入存储。
ExpressionEvaluatingSqlParameterSourceFactory
现在为 sqlParameterTypes
提供了一个设置程序,让您可以自定义参数的 SQL 类型。
有关更多信息,请参见 JDBC Support。
Metrics Changes
现在支持 Micrometer 应用程序监控(自版本 5.0.2 以来)。有关详细信息,请参阅 Micrometer Integration。
5.0.3 版本中的 Micro 仪表 Meters
进行了更改,使其更适合在维度系统中使用。5.0.4 中进行了进一步的更改。如果您使用 Micro 仪表,我们建议最低版本为 5.0.4。
@EndpointId
Annotations
此注释在版本 5.0.4 中引入,当您使用 Java 配置时,它将提供对 bean 命名进行控制。有关详细信息,请参阅 Endpoint Bean Names。