此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring Integration 6.5.1spring-doc.cadn.net.cn

5.3 和 5.4 之间的更改

新组件

Apache Kafka 的通道适配器

独立的 Spring Integration for Apache Kafka 项目已合并为spring-integration-kafka模块添加到此项目。spring-doc.cadn.net.cn

KafkaProducerMessageHandler sendTimeoutExpression默认值已更改。spring-doc.cadn.net.cn

您现在可以访问Future<?>对于基础send()操作。spring-doc.cadn.net.cn

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

R2DBC 通道适配器

引入了用于 R2DBC 数据库交互的通道适配器。 有关更多信息,请参阅 R2DBC 支持spring-doc.cadn.net.cn

Redis Stream 支持

引入了 Redis Stream 支持的通道适配器。 有关详细信息,请参阅 Redis Stream 出站通道适配器spring-doc.cadn.net.cn

可续期锁注册表

引入了可续订锁注册表,以允许续订分布式锁的租约。 有关更多信息,请参阅 JDBC 实现spring-doc.cadn.net.cn

ZeroMQ 支持

ZeroMqChannel,ZeroMqMessageHandlerZeroMqMessageProducer已被引入。 有关更多信息,请参阅 ZeroMQ 支持spring-doc.cadn.net.cn

一般更改

单向消息传递网关(void方法返回类型)现在将nullChannel显式地将replyChannel标头以忽略任何可能的下游回复。 有关详细信息,请参阅设置默认回复通道spring-doc.cadn.net.cn

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

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

被千分尺仪取代的旧指标已被删除。spring-doc.cadn.net.cn

线程屏障现在有两个单独的超时选项:requestTimeouttriggerTimeout.spring-doc.cadn.net.cn

TCP/UDP 更改

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

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

AMQP 更改

出站终结点现在具有处理发布者确认和返回的新机制。 有关详细信息,请参阅发布者确认和退货的替代机制spring-doc.cadn.net.cn

一个新的BatchMode.EXTRACT_PAYLOAD_WITH_HEADERSAmqpInboundChannelAdapter. 有关更多信息,请参阅入站通道适配器spring-doc.cadn.net.cn

邮件更改

AbstractMailReceiver现在可以生成MimeMessage按原样,无需急于获取其内容。 有关更多信息,请参阅邮件接收通道适配器spring-doc.cadn.net.cn