5.3 和 5.4 之间的更改

新组件

Apache Kafka 的通道适配器

独立的 Spring Integration for Apache Kafka 项目已作为模块合并到该项目中。spring-integration-kafkaspring-doc.cn

默认值已更改。KafkaProducerMessageHandlersendTimeoutExpressionspring-doc.cn

您现在可以访问 for underlying operations.Future<?>send()spring-doc.cn

有关更多信息,请参阅 Spring for Apache Kafka 支持spring-doc.cn

R2DBC 通道适配器

引入了用于 R2DBC 数据库交互的 Channel Adapters。 有关更多信息,请参阅 R2DBC 支持spring-doc.cn

Redis 流支持

引入了 Channel Adapters for Redis Stream 支持。 有关更多信息,请参阅 Redis Stream Outbound Channel Adapterspring-doc.cn

可更新锁注册表

引入了 Renewable lock registry,以允许续订分布式锁的租约。 有关更多信息,请参阅 JDBC 实现spring-doc.cn

ZeroMQ 支持

ZeroMqChannel,并且已引入。 有关更多信息,请参阅 ZeroMQ 支持ZeroMqMessageHandlerZeroMqMessageProducerspring-doc.cn

一般更改

单向消息传递网关(方法返回类型)现在在标头中显式设置一个,以忽略任何可能的下游回复。 有关更多信息,请参阅设置默认回复通道voidnullChannelreplyChannelspring-doc.cn

此外,网关方法调用程序 () 现在提供托管 Bean 名称,作为网关代理 Bean 名称和方法签名的组合。 例如:。 这会影响为网关方法调用公开的消息历史记录和指标,并在应用程序上下文的启动和关闭期间提供精细的日志。GatewayProxyFactoryBean.MethodInvocationGatewaysampleGateway#echo(String)spring-doc.cn

聚合器(和重新排序器)现在可以使孤立组(持久存储中的组,在应用程序重新启动后没有新消息到达)过期。 有关更多信息,请参阅 Aggregator Expiring Groupsspring-doc.cn

已删除由 Micrometer meter 替换的旧指标。spring-doc.cn

Thread Barrier 现在有两个单独的超时选项:和 .requestTimeouttriggerTimeoutspring-doc.cn

TCP/UDP 更改

连接工厂现在支持多个发送组件 ();它们仍然仅限于一个接收组件 ()。 例如,这允许入站网关和出站通道适配器共享同一个工厂,同时支持请求/回复和从服务器到 Client 端的任意消息传递。 共享工厂不应与出站网关一起使用,除非正在使用一次性连接或 。 有关更多信息,请参阅 Collaborative Channel Adapters and TCP GatewaysTcpSenderTcpListenerThreadAffinityClientConnectionFactoryspring-doc.cn

UDP 通道适配器现在可以配置为 ,允许设置适配器不直接支持的套接字属性。 有关更多信息,请参阅 UDP 适配器SocketCustomizerspring-doc.cn

AMQP 更改

出站终端节点现在具有处理发布者确认和返回的新机制。 有关更多信息,请参阅 Publisher Confirms and Returns 的替代机制spring-doc.cn

new 受 . 有关更多信息,请参阅 入站通道适配器BatchMode.EXTRACT_PAYLOAD_WITH_HEADERSAmqpInboundChannelAdapterspring-doc.cn

邮件更改

现在可以按原样生成,而无需急切地获取其内容。 有关更多信息,请参阅 Mail-receiving Channel AdapterAbstractMailReceiverMimeMessagespring-doc.cn