MongoDB作为队列，有上限的集合+可尾游标

Question

（在 mongo-user 讨论组 https://groups.google.com/d/topic/mongodb-user/i1ge4bNiMgM/discussion 上提问）

您好，我想将 MongoDB 用作消息队列，并考虑为此目的使用上限集合 + 可尾游标。 我知道可尾光标可用于按插入顺序访问文档，但是

1. 我可以对光标使用任何排序顺序吗？
2. 尾标是否可以与过滤查询一起使用（跳过一些我不想处理的文档）？如果是这样，它如何处理新文档的插入 - 只有当新文档符合查询条件时才会通知我？
3. C# 驱动程序是否完全支持尾随游标？
4. 我希望我的队列保证单次传递 - 我的意思是如果两个客户端尝试从同一个集合中读取消息，他们不应该能够“使用”相同的消息。我认为这可以通过 findAndModify 来实现，但是如何使用拖尾光标来实现呢？

谢谢 RG

Answer 1

AOL/About.me 于 2012 年 4 月在硅谷 MUG 上发表了关于“MongoDB as message queue”的演讲，您可能会发现它有助于规划您的方法。

1. 我可以对光标使用任何排序顺序吗？
2. 尾标是否可以与过滤查询一起使用（跳过一些我不想处理的文档）？如果是这样，它如何处理新文档的插入 - 只有当新文档符合查询条件时才会通知我？

可尾游标尾随封顶集合的end，并且仅以自然顺序。如果您需要排序顺序，则需要使用索引查询。

请阅读Create Tailable Cursor 文档页面了解更多信息。

C# 驱动程序是否完全支持尾随游标？

是的，可尾光标支持已在 1.1 C# 驱动程序中实现（请参阅：code example）。

我希望我的队列保证单次传递 - 我的意思是，如果两个客户端尝试从同一个集合中读取消息，他们不应该能够“使用”同一条消息。我认为这可以通过 findAndModify 来实现，但是如何使用拖尾光标来实现呢？

有几种方法：

• 让一个带有可尾光标的读取器将任务分配给工作线程（即基于工作队列深度或循环）。这将比拥有多个阅读器更有效，但可能会出现单点故障。
• （@Contango 在下面的评论中建议）拥有多个阅读器，但使用乐观并发确保只有一个工作人员“拥有”每个任务。这将导致更多的 I/O，但如果工作人员也直接拖尾，则可能会简化您的设计。

有关原子操作的更多信息，请参阅 MongoDB 手册中的Isolate Sequence of Operations。