对于最新的稳定版本,请使用 Spring Integration 6.3.1Spring中文文档

对于最新的稳定版本,请使用 Spring Integration 6.3.1Spring中文文档

新组件

Apache Kafka 的通道适配器

独立的 Spring Integration for Apache Kafka 项目已合并为此项目的模块。spring-integration-kafkaSpring中文文档

默认值已更改。KafkaProducerMessageHandlersendTimeoutExpressionSpring中文文档

现在,您可以访问基础操作。Future<?>send()Spring中文文档

有关更多信息,请参见 Spring for Apache Kafka 支持Spring中文文档

R2DBC 通道适配器

引入了用于 R2DBC 数据库交互的通道适配器。 有关详细信息,请参阅 R2DBC 支持Spring中文文档

Redis Stream 支持

引入了 Redis Stream 通道适配器支持。 有关详细信息,请参阅 Redis 流出站通道适配器Spring中文文档

可再生锁登记处

引入了可再生锁注册表,以允许续租分布式锁。 有关更多信息,请参阅 JDBC 实现Spring中文文档

ZeroMQ 支持

ZeroMqChannel,并已被介绍。 有关更多信息,请参阅 ZeroMQ 支持ZeroMqMessageHandlerZeroMqMessageProducerSpring中文文档

一般更改

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

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

聚合器(和重排序器)现在可以使孤立的组(持久性存储中的组)过期,在应用程序重新启动后没有新消息到达。 有关详细信息,请参阅聚合器过期组Spring中文文档

已被千分尺取代的旧指标已被删除。Spring中文文档

线程屏障现在有两个单独的超时选项:和 。requestTimeouttriggerTimeoutSpring中文文档

TCP/UDP 更改

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

现在可以对 UDP 通道适配器进行配置,该适配器允许设置适配器不直接支持的套接字属性。 有关详细信息,请参阅 UDP 适配器SocketCustomizerSpring中文文档

AMQP 更改

出站终结点现在具有用于处理发布者确认和返回的新机制。 有关详细信息,请参阅发布者确认和返回的替代机制Spring中文文档

新的 . 有关详细信息,请参阅入站通道适配器BatchMode.EXTRACT_PAYLOAD_WITH_HEADERSAmqpInboundChannelAdapterSpring中文文档

邮件更改

现在可以按原样生成,而无需急切地获取其内容。 有关详细信息,请参阅邮件接收通道适配器AbstractMailReceiverMimeMessageSpring中文文档