MongoDB作为队列,上限集合+ tailable游标

Question

(在mongo用户讨论组https://groups.google.com/d/topic/mongodb-user/i1ge4bNiMgM/discussion上询问)

嗨,我想将MongoDB用作消息队列,并考虑使用上限集合+ tailable游标来实现此目的.我知道tailable游标可用于访问插入顺序中的文档但是

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

谢谢RG

Answer 1

2012年4月,AOL/About.me在硅谷MUG 上发表了关于" MongoDB作为消息队列 " 的演示文稿,您可能会发现在规划您的方法时很有帮助.

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

一个tailable光标尾随有顶集合的末尾,并且只按自然顺序排列.如果需要排序顺序,则需要使用索引查询.

请阅读Create Tailable Cursor文档页面以获取更多信息.

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

是的,在1.1 C#驱动程序中实现了tailable游标支持(请参阅:代码示例).

我希望我的队列保证单次传递 - 我的意思是如果两个客户端尝试从同一个集合中读取消息,他们就不应该"消费"相同的消息.我认为这可以用findAndModify来实现,但是如何用尾随游标来实现呢？

有几种方法:

• 让一个带有tailable游标的读者将任务分配给工作线程(即基于工作队列深度或循环).这比拥有多个阅读器更有效,但可能是单点故障.
• (@Contango在下面的评论中提出)有多个读者,但使用乐观并发来确保只有一个工作者"拥有"每个任务.这将导致更多I/O,但如果工作人员也直接拖尾,可能会简化您的设计.

有关原子操作的更多信息,请参阅MongoDB手册中的隔离操作顺序.