mongodb allanbank异步驱动程序回调被调用两次

Question

我有一个简单的回调绑定到findAsync调用。即使数据库中的数据是静态的，每隔几个请求我都会观察到失败。

一些快速调试显示我的回调总是被调用两次。我的应用程序失败的情况是由传入我的回调中的nullMongoIterator<Document>引起的。当然，我只希望在数据准备好的时候进行一次回调（或者发生异常）。

这是预期的行为？有什么我可以做的，以确保我的回调只查询完成后调用一次？

这里是代码片段：

collection.findAsync(
    [ 
     callback: { MongoIterator<Document> v -> 
      List data = [] 
      try { 
       while(v.hasNext()) { 
        data.add(docToJson(v.next())) 
       } 
      } finally { 
       if (v != null) v.close() 
      } 
      sendReply([ status: 'ok', data: data ]) 
     }, 
     exception: { Throwable t -> 
      sendReply([ status: 'error', message: t.message ]) 
     } 
    ] as Callback<MongoIterator<Document>>, 
    find 
) 

这里是堆栈跟踪：

Unexpected MongoDB Connection closed: Auth(MongoDB(43026-->localhost/127.0.0.1:27017)). Will try to reconnect. 
Reconnected to localhost/127.0.0.1:27017 
Exception in thread "MongoDB 43026<--localhost/127.0.0.1:27017" java.lang.NullPointerException: Cannot invoke method hasNext() on null object 
    at org.codehaus.groovy.runtime.NullObject.invokeMethod(NullObject.java:77) 
    at org.codehaus.groovy.runtime.callsite.PogoMetaClassSite.call(PogoMetaClassSite.java:45) 
    at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:45) 
    at org.codehaus.groovy.runtime.callsite.NullCallSite.call(NullCallSite.java:32) 
    at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:45) 
    at org.codehaus.groovy.runtime.callsite.PogoMetaClassSite.call(PogoMetaClassSite.java:54) 
    at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:112) 
    at mongoAsync$_run_closure2_closure6.doCall(mongoAsync.groovy:126) 
    at sun.reflect.GeneratedMethodAccessor54.invoke(Unknown Source) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:601) 
    at org.codehaus.groovy.reflection.CachedMethod.invoke(CachedMethod.java:90) 
    at groovy.lang.MetaMethod.doMethodInvoke(MetaMethod.java:233) 
    at org.codehaus.groovy.runtime.metaclass.ClosureMetaClass.invokeMethod(ClosureMetaClass.java:272) 
    at groovy.lang.MetaClassImpl.invokeMethod(MetaClassImpl.java:909) 
    at groovy.lang.Closure.call(Closure.java:411) 
    at org.codehaus.groovy.runtime.ConvertedMap.invokeCustom(ConvertedMap.java:50) 
    at org.codehaus.groovy.runtime.ConversionHandler.invoke(ConversionHandler.java:81) 
    at com.sun.proxy.$Proxy14.callback(Unknown Source) 
    at com.allanbank.mongodb.client.AbstractReplyCallback.handle(AbstractReplyCallback.java:82) 
    at com.allanbank.mongodb.client.AbstractValidatingReplyCallback.callback(AbstractValidatingReplyCallback.java:72) 
    at com.allanbank.mongodb.client.AbstractValidatingReplyCallback.callback(AbstractValidatingReplyCallback.java:33) 
    at com.allanbank.mongodb.connection.message.ReplyHandler.reply(ReplyHandler.java:77) 
    at com.allanbank.mongodb.connection.socket.SocketConnection.reply(SocketConnection.java:560) 
    at com.allanbank.mongodb.connection.socket.SocketConnection$ReceiveRunnable.receiveOne(SocketConnection.java:735) 
    at com.allanbank.mongodb.connection.socket.SocketConnection$ReceiveRunnable.run(SocketConnection.java:683) 
    at java.lang.Thread.run(Thread.java:722) 

Answer 1

感谢您的额外信息。

我很确定我发现了错误。

查询的回调/迭代器之间有一个竞争，获取处理查询的服务器的名称（GetMore请求需要）和接收回复。不知道他人怎么没有看到它。

这里有一个打补丁的jar：[redact]。让我知道它是否能为您解决问题。

的1.2.2版本可与修复：http://www.allanbank.com/mongodb-async-driver/download.html

假如是的话，我将推动这一解决了明天一1.2.2。

Rob。

编辑：添加链接到正式版。