我正在使用MongoDB Reactive Streams Java API，它是我在this example之后实现的，但我遇到了一个严重的问题:有时，当我试图查询一个集合时，await方法不起作用，并且它会挂起，直到超时。
浏览 38提问于2021-10-07得票数 3
这就是为什么我在寻找使用MongoDB进行非阻塞查询和对象映射的最佳方法。这看起来像是在玩！在Java开发人员中不是很流行，所以没有太多的选择。我已经找到了MongoDB Reactive Streams Java驱动程序，但使用它进行对象映射似乎非常痛苦。
你能建议一个更好的解决方案吗？
浏览 47提问于2017-01-27得票数 0
背景 log.error("Caught exception when reading from mongodbreactiveMongoOperations.find(..)没有为给定类型找到任何文档(从而记录了"Failed to f
浏览 3提问于2019-11-21得票数 1
回答已采纳
1回答
我正在使用SpringData MongoDB Reactive Streams驱动程序，代码如下： })我希望所有的东西都在my-scheduler中执行实际发生的情况是，flatMap操作在my-scheduler中执行，而我的process(
浏览 8提问于2019-07-06得票数 1
它使用了我创建的一个非常简单的MongoDB数据库。我确定MongoDB版本4.0.10安装在我的计算机上，以防与此相关。当试图执行匹配记录的查询时，我会得到以下错误：
UnhandledPromiseRejectionWarning: MongoError: FieldPath字段名可能不会以'$‘开头。:20)、addChunk (内部/streams/readable.js:309:12)、readableAddChunk (内部/
浏览 3提问于2021-02-13得票数 3
我有一个spring reactive webapp，在一个典型的应用中使用reactive mongo driver for mongodb。foos来自：
Flux<Foo>
浏览 0提问于2018-09-13得票数 0
我在升级我的spring-boot/mongodb-driver时遇到了一个非常令人困惑的问题。作为数据库，我们运行的是mongodb:4.0实例。mongo-java-driver-reactivestreams", version: "3.11.2|1.12.0" 现在切换到 Spring Boot 2.3.4
"mongo-java-driver|reactive-streams", version: "4.0.5" 在
浏览 181提问于2020-12-08得票数 0
当200个或更多用户同时访问时，我的NodeJS应用程序挂起MongoDB的“查找”查询。
为了演示/再现这个问题，我构建了一个小型POC，它只有一个路由，它连接到MongoDB并获取数据。当我使用LoadUIweb创建大约500个同时请求时，有时集合的“findone”函数永远不会返回。当服务器挂起时，它会打印“获取请求”和“得到响应”，但它从不打印“迭代响应”和“返回响应”。似乎节点服务器本身并不是因为接受新请求而挂起的
浏览 1提问于2016-03-28得票数 1
2回答
因为这个特性相对较新(mongo 3.6)，所以我找到的java示例很少。我的问题: 1.观看更改流的最佳实践是什么? 2.观看流必须是阻塞调用吗？(这意味着每个集合一个线程，这是不太需要的)这是我遇到的例子：
谢谢，Rotem。
浏览 1提问于2018-03-12得票数 5
collectionBRepository.findDocsNotIn(list)) .subscribe();
但是，如果集合A中没有文档，则不会执行第二个查询如何强制执行second来获取所有文档。
浏览 13提问于2019-08-01得票数 1
1回答
一个是MongoDB，另一个是运行简单rest的容器，该容器应该能够查询MongoDB容器。docker/node_modules:/usr/lib/node_modules -p 3000:3000 --name rest_container rest_image /bin/bash172.17.0.2
我知道API可以工作，因为我可以在没有在docker上运行程序的
浏览 6提问于2017-06-30得票数 2
回答已采纳
我有一个异步函数，它基于函数调用中传递的对象查询mongodb。函数执行，并将结果返回给回调函数，回调函数将结果记录到控制台，然后挂起。最后，我希望获取异步查询的结果，然后在原始异步函数之外对它们执行一些操作。我不明白为什么它在登录到控制台后挂起。const MongoClient = require('mongodb').MongoClient; field : {},
limit : 1
浏览 0提问于2019-08-24得票数 0
回答已采纳
2回答
我正在尝试使用Q承诺库同时运行两个猫鼬查询。我希望独立地进行这两个查询，然后在两个查询完成后使用结果执行一个函数。 console.log(result) console.log(err)其结果是下面挂起的承诺的对象
浏览 4提问于2015-06-24得票数 4
回答已采纳
我们的问题是，有时候mongodb驱动程序Find()函数挂起16分钟。函数调用不会失败。我们正在使用mongodb地图集和mongodb驱动程序v2.15.1从nuget。我尝试过用shell调试mongo，但是当find函数挂起时，没有任何正在进行的查询。
我们的请求流前端是=> NginX =>反向代理到web，它位于docker容器中。有趣的是，当您连续使用和导航调用web的网页时，没有一个请求会被挂起/
浏览 4提问于2022-06-06得票数 0
2回答
在spring数据中，我可以轻松地执行以下查询：在reactive Spring data (MongoDBpageable);如果没有有效的方法可以做到这一点，有没有一种方法可以在没有Page的情况下实际执行一次查询就可以获得查询总数呢
浏览 0提问于2021-06-28得票数 0
1回答
在处理大型项目数据库的本地副本时，mongodb游标似乎对大多数查询都挂起。具体来说，我正在使用PyMongo，但是即使是集合上的一个简单的count()也会挂起(所以这个问题不是python问题)。迭代游标，直到它被卡住时才会发现，它总是发生在相同的点(即，对于相同的查询)--然后它就挂起了。尝试cursor.alive可以发现它确实是活的，而且很好。
降低和重建指数也于事无补。运行mongodb版本2.6.4。和PyMongo版本
浏览 0提问于2015-05-27得票数 6
2回答
我从中选择了Kotlin、Gradle、M7和Web-reactive，创建了一个项目。save方法只返回一个需要执行的Mono。connectionId{localValue:5, serverValue:160}] to localhost:27017Jack但是，当我使用block而不是subscribe时，应用程序挂起：2017-12-21 13:16:47.200 INFO 17463 --- [ Thread-14] org.mongodb<
浏览 0提问于2017-12-21得票数 14
回答已采纳
2回答
因此，我已经阅读了NodeJS缓存查询的，直到它连接到MongoDB为止(没有超时)。但是当数据库崩溃时，应该可以向用户发送消息。因此，解决此问题的一种方法是执行以下操作 // whem we hit timeout, respond to the user内存泄漏(挂起对MongoDB的查询)怎么办？
浏览 0提问于2012-02-22得票数 3
回答已采纳
3回答
我使用akka streams从kafka中读取并写入外部源，在我的例子中是: cassandra。Akka streams(reactive-kafka)库为我配备了背压和其他一些很好的东西来实现这一点。kafka是Source，Cassandra是Sink，当我通过Kafka得到一堆事件时，比如这里的cassandra查询，这些查询应该是按顺序执行的(例如:它可以是插入、更新和删除，并且必须是顺序的)我不能同时使用mayAsync和执行这两个语句，
浏览 0提问于2018-01-24得票数 0
我有一个非常简单的MongoDB find查询，它在一个字段上过滤相当大的集合。allValues = await cursor.toArray()
cursor.close()})()
浏览 8提问于2022-01-30得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
