Changes between 5.3 and 5.4
Channel Adapters for Apache Kafka
独立的 Spring Integration for Apache Kafka 项目已合并为该项目的一个 spring-integration-kafka
模块。
KafkaProducerMessageHandler
sendTimeoutExpression
默认值已更改。
您现在可以访问基础 send()
操作的 Future<?>
。
有关更多信息,请参见 Spring for Apache Kafka Support。
R2DBC Channel Adapters
已经引入了用于 R2DBC 数据库交互的通道适配器。有关更多信息,请参见 R2DBC Support。
Redis Stream Support
已引入支持 Redis 流的通道适配器。有关详细信息,请参见 Redis Stream Outbound Channel Adapter。
Renewable Lock Registry
已引入可维护锁注册表,用于允许维护分布式锁的租约。有关详细信息,请参见 JDBC implementation。
ZeroMQ Support
已经引入了 ZeroMqChannel
、ZeroMqMessageHandler
和 ZeroMqMessageProducer
。有关更多信息,请参见 ZeroMQ Support。
General Changes
单向消息网关(void
方法返回类型)现将 nullChannel
显式地设到 replyChannel
标头中,以忽略所有可能的下游答复。有关详细信息,请参见 Setting the Default Reply Channel。
此外,网关方法调用者(GatewayProxyFactoryBean.MethodInvocationGateway
)现在提供托管 Bean 名称,它是网关代理 Bean 名称与方法签名组合。例如:sampleGateway#echo(String)
。这会影响公开的网关方法调用消息历史记录和指标,并且还在应用程序上下文的启动和关闭期间提供细粒度的日志。
聚合器(和重新排序器)现在可以使孤立组(持久存储库中的组,在应用程序重新启动后不再收到任何新消息)过期。有关详细信息,请参见 Aggregator Expiring Groups。
已经删除了被 Micrometer 仪表所替代的旧版指标。
Thread Barrier 现在有两个单独的超时选项:requestTimeout
和 triggerTimeout
。
TCP/UDP Changes
连接工厂现支持多个发送组件 (TcpSender
);它们仍然仅限于一个接收组件 (TcpListener
)。例如,这允许入站网关和出站通道适配器共享同一工厂,既支持请求/答复,也支持从服务器到客户端的任意消息传递。除非使用单用连接或 ThreadAffinityClientConnectionFactory
,否则不应将共享工厂与出站网关一起使用。有关详细信息,请参见 Collaborating Channel Adapters 和 TCP Gateways。
UDP 通道适配器现在可以通过 SocketCustomizer
进行配置,允许多种设置适配器不支持的套接字属性。有关更多信息,请参见 UDP Adapters。
AMQP Changes
出站端点现在有一种新的机制来处理发布程序的确认和返回。有关更多信息,请参见 Alternative Mechanism for Publisher Confirms and Returns。
AmqpInboundChannelAdapter
支持新的 BatchMode.EXTRACT_PAYLOAD_WITH_HEADERS
。有关更多信息,请参见 Inbound Channel Adapter。
Mail Changes
AbstractMailReceiver
现可按原样产生 MimeMessage
,而无需急切地获取其内容。有关详细信息,请参见 Mail-receiving Channel Adapter。