38.8. 消费者
使用者有几种类型:
- Tailable Cursor Consumer
- 更改 Streams Consumer
38.8.1. Tailable Cursor Consumer
MongoDB 提供了一种机制来即时消耗集合中持续数据,方法是将光标保持开放,就像 *nix 系统的 tail -f
命令一样。这种机制比调度的轮询更高效,因为服务器在客户端可用时推送新数据,而不是让客户端 ping 重新调度的间隔以获取新数据。它还减少了冗余网络流量。
只有一个必要条件才能使用尾部光标:集合必须是"捕获集合",即仅保存 N 个对象,并且达到限制时,MongoDB 会按最初插入的顺序清除旧对象。如需更多信息,请参阅 http://www.mongodb.org/display/DOCS/Tailable+Cursors。
Camel MongoDB 组件实施可尾部的光标消费者,使此功能供您在 Camel 路由中使用。当插入新对象时,MongoDB 将以自然的方式将其推送为 Document
,以便将其转换为 Exchange,并将触发您的路由逻辑。