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