272.9.2. 控制 Backpressure (消费者侧)


当 Camel 消耗来自 Reactive-streams publisher 的项时,动态交换的最大数量可以设置为端点选项。

与消费者关联的订阅者与发布者交互,以使路由中的消息数量低于阈值。

backpressure-aware 路由示例:

Copy to Clipboard Toggle word wrap
from("reactive-streams:numbers?maxInflightExchanges=10")
.to("direct:endpoint");

Camel 向源发布者请求(通过被动流后端机制)的项数量始终低于 10。消息由 Camel 一侧的单个线程处理。

并发使用者(线程)的数量也可以设置为端点选项(并发Consumers)。使用 1 个消费者(默认值)时,源流中的项目顺序会被维护。当此值增加时,项目将由多个线程同时处理(因此不会保留顺序)。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat, Inc.