2

我创建了一个默认大小为 50M 的上限集合。最近，我注意到Cursor not found当上限集合存储大小超过 50M 时出现错误。我不确定是什么原因造成的：在上限集合大小小于默认最大大小之前，我从未收到此错误。

if (this._cursor == null || this._cursor.IsDead)
{                 
   var cursor = this._queueCollection.Find(Query.GT("_id", this._lastId))
            .SetFlags(QueryFlags.AwaitData |
            QueryFlags.TailableCursor |
            QueryFlags.NoCursorTimeout)
            .SetSortOrder(SortBy.Ascending("$natural")); 
    this._cursor =(MongoCursorEnumerator<QueueMessage<T>>)cursor.GetEnumerator();
}

try
{
    if (this._cursor.MoveNext())
        //do some things
        return this._cursor.Current;
    else
     {
         if (this._cursor.IsDead){
               this._cursor.Dispose();
               this._cursor=null;
         }
     }
     return null;
}
catch{}

this._cursor.MoveNext ()会抛出cursor not found异常（偶尔，并不总是抛出。我的代码错了吗？

4

2 回答 2

2

我找到了导致此错误的原因。

如果出现以下任一情况，可尾游标可能会失效或无效：

  1. 查询不返回匹配项。
  2. 光标返回集合“末尾”的文档，然后应用程序删除这些文档。

来自 mongodb 官方网站的关于创建可尾游标的参考（http://docs.mongodb.org/manual/tutorial/create-tailable-cursor/）

在我的应用程序中，当抛出“找不到光标”异常时，总是因为光标在集合的“末尾”返回文档，然后应用程序删除了这些文档。

于 2013-05-27T02:58:11.910 回答
0

你可以使用foreach：

var query1 = new QueryBuilder<Message>().GT(m => m.date, lastTransferredMessageDate);
var result = messagesCollection.FindAs<Message>(query1).SetFlags(QueryFlags.NoCursorTimeout);

foreach (var message in result)
{
  // Your code
}
于 2013-05-16T07:31:46.557 回答