此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.3.4! |
此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.3.4! |
Apache Kafka 的通道适配器
独立的 Spring Integration for Apache Kafka 项目已作为模块合并到该项目中。spring-integration-kafka
默认值已更改。KafkaProducerMessageHandler
sendTimeoutExpression
您现在可以访问 for underlying operations.Future<?>
send()
有关更多信息,请参阅 Spring for Apache Kafka 支持。
R2DBC 通道适配器
引入了用于 R2DBC 数据库交互的 Channel Adapters。 有关更多信息,请参阅 R2DBC 支持。
Redis 流支持
引入了 Channel Adapters for Redis Stream 支持。 有关更多信息,请参阅 Redis Stream Outbound Channel Adapter。
可更新锁注册表
引入了 Renewable lock registry,以允许续订分布式锁的租约。 有关更多信息,请参阅 JDBC 实现。
ZeroMQ 支持
ZeroMqChannel
,并且已引入。
有关更多信息,请参阅 ZeroMQ 支持。ZeroMqMessageHandler
ZeroMqMessageProducer
一般更改
单向消息传递网关(方法返回类型)现在在标头中显式设置一个,以忽略任何可能的下游回复。
有关更多信息,请参阅设置默认回复通道。void
nullChannel
replyChannel
此外,网关方法调用程序 () 现在提供托管 Bean 名称,作为网关代理 Bean 名称和方法签名的组合。
例如:。
这会影响为网关方法调用公开的消息历史记录和指标,并在应用程序上下文的启动和关闭期间提供精细的日志。GatewayProxyFactoryBean.MethodInvocationGateway
sampleGateway#echo(String)
聚合器(和重新排序器)现在可以使孤立组(持久存储中的组,在应用程序重新启动后没有新消息到达)过期。 有关更多信息,请参阅 Aggregator Expiring Groups 。
已删除由 Micrometer meter 替换的旧指标。
Thread Barrier 现在有两个单独的超时选项:和 .requestTimeout
triggerTimeout
TCP/UDP 更改
连接工厂现在支持多个发送组件 ();它们仍然仅限于一个接收组件 ()。
例如,这允许入站网关和出站通道适配器共享同一个工厂,同时支持请求/回复和从服务器到 Client 端的任意消息传递。
共享工厂不应与出站网关一起使用,除非正在使用一次性连接或 。
有关更多信息,请参阅 Collaborative Channel Adapters and TCP Gateways。TcpSender
TcpListener
ThreadAffinityClientConnectionFactory
UDP 通道适配器现在可以配置为 ,允许设置适配器不直接支持的套接字属性。
有关更多信息,请参阅 UDP 适配器。SocketCustomizer
AMQP 更改
出站终端节点现在具有处理发布者确认和返回的新机制。 有关更多信息,请参阅 Publisher Confirms and Returns 的替代机制。
new 受 .
有关更多信息,请参阅 入站通道适配器 。BatchMode.EXTRACT_PAYLOAD_WITH_HEADERS
AmqpInboundChannelAdapter
邮件更改
现在可以按原样生成,而无需急切地获取其内容。
有关更多信息,请参阅 Mail-receiving Channel Adapter 。AbstractMailReceiver
MimeMessage