MongoDB Tailable Cursors 特性介绍

三里屯摇滚

MongoDB Tailable Cursors 特性介绍

MongoDB 有一个叫 Tailable Cursors的特性，它类似于tail -f 命令，你在一个Capped Collection上面执行查询操作，当操作完成后，你可以不关闭返回的数据Cursor，并持续地从中读出新加入的数据。

这个特性可以用来干什么？我觉得最直接的一个用途就是用作消息队列了，利用此特性加上MongoDB 天然的Replication 机制，做一个分布式的队列系统貌似不是什么难事。

下面是PHP 的示例代码：

1. selectDB('my_db')
   
2. $coll = $db->selectCollection('my_collection');
   
3. $cursor = $coll->find()->tailable(true);
   
4. while (true) {
   
5.     if ($cursor->hasNext()) {
   
6.         $doc = $cursor->getNext();
   
7.         print_r($doc);
   
8.     } else {
   
9.         sleep(1);
   
10.     }
    
11. }

复制代码

下面是Ruby 的示例代码：

1. db   = Mongo::Connection.new().db('my_db')
   
2. coll = db.collection('my_collection')
   
3. cursor = Mongo::Cursor.new(coll, :tailable => true)
   
4. loop do
   
5.   if doc = cursor.next_document
   
6.     puts doc
   
7.   else
   
8.     sleep 1
   
9.   end
   
10. end

复制代码

原文链接：http://jwage.com/2011/03/16/mongodb-tailable-cursors/
官方介绍：http://www.mongodb.org/display/DOCS/Tailable+Cursors

清风鸟儿

谢谢分享