88.10. tailable 光标消费者的工作方式

要将光标转换为可尾部的光标，在首次生成光标时，将向 MongoDB 发出一些特殊标志。创建后，光标将保持打开状态，并在调用 MongoCursor.next （） 方法时阻止，直到新数据到达为止。但是，如果新数据没有在确定周期后显示，MongoDB 服务器保留自己终止您的光标的权利。如果您有兴趣继续使用新数据，则必须重新生成光标。为此，您必须记住您离开的位置，否则您将再次从上移使用的位置。

Camel MongoDB tailable 光标消费者为您处理所有这些任务。您只需要在增加性质的数据中为某些字段提供键，这将作为标记来每次重新生成光标时定位，例如时间戳、顺序 ID 等。它可以是 MongoDB 支持的任何 datatype。日期、字符串和整数可以正常工作。我们在此组件上下文中称为"定制"机制。

消费者将记住此字段的最后一个值，无论光标要重新生成时，它将使用类似： increasingField > lastValue 的过滤器运行查询，以便只消耗未读取的数据。

设置 increasing 字段： 在端点 URI tailTrackingIncreasingField 选项上设置 increasing 字段的键。在 Camel 2.10 中，它必须是数据的顶级字段，因为尚不支持此字段的嵌套导航。也就是说，"timestamp"字段是 okay，但 "nested.timestamp" 将无法正常工作。如果您需要对嵌套增加字段的支持，请在 Camel JIRA 中创建一个票据。

光标重新生成延迟： 需要注意的是，如果新数据在初始时尚未可用，MongoDB 将立即终止光标。由于我们不想在此案例中对服务器进行重负，因此引入了一个 cursorRegenerationDelay 选项（默认值为 1000ms）。您可以修改以适合您的需求。

例如：

from("mongodb:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime")
    .id("tailableCursorConsumer1")
    .autoStartup(false)
    .to("mock:test");

以上路由将使用 "flights.cancellations" capped 集合，使用 "departureTime" 作为增加字段，默认重新生成光标延迟 1000ms。