101.9. 消费者


有几种类型的消费者:

  1. Tailable Cursor Consumer
  2. Change Streams Consumer

101.9.1. Tailable Cursor Consumer

MongoDB 提供了一种机制,可以立即使用集合中持续使用持续的数据,方法是保持光标的开放方式,类似于 *nix 系统的 tail -f 命令。这种机制比调度的轮询效率更高,因为服务器将新数据推送到客户端,而不是让客户端按计划的间隔重新执行 ping 来获取新数据。它还可减少其他冗余网络流量。

使用可尾随光标的一个先决条件:集合必须是"总结集合",即它将只保存 N 对象,当达到限制时,MongoDB 会按照最初插入的顺序清除旧对象。如需更多信息,请参阅 http://www.mongodb.org/display/DOCS/Tailable+Cursors

Camel MongoDB 组件实施可尾部的光标消费者,使此功能可供您用于 Camel 路由。在插入新对象时,MongoDB 将以自然顺序将其推送为可尾部的光标消费者,后者会将其转换为 Exchange,并触发您的路由逻辑。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat