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

我有一个简单的回调绑定到findAsync调用。即使数据库中的数据是静态的，每隔几个请求我都会观察到失败。mongodb allanbank异步驱动程序回调被调用两次

一些快速调试显示我的回调总是被调用两次。我的应用程序失败的情况是由传入我的回调中的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)

来源

2013-05-02 jckdnk111

根本没有预料 - 你可以发送堆栈跟踪的空回调调用（或发布在这里）。电子邮件地址是allanbank.com上的Robert.J.Moore – 2013-05-02 23:58:15

感谢您的额外信息。

我很确定我发现了错误。

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

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

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

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

Rob。

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

来源

2013-05-03 01:32:23

修复了这个问题。感谢您的超级快速修复！真是惊人的软件和支持！ – jckdnk111 2013-05-03 01:41:09

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

回答

相关问题