mongodb 更改流 java

Question

由于此功能相对较新(mongo 3.6)，我发现的 java 示例很少。 我的问题: 1. 观察变化流的最佳实践是什么？ 2、看流一定要阻塞调用吗？ (这意味着每个集合一个线程，这是不太需要的) 这是我遇到的例子:

http://mongodb.github.io/mongo-java-driver/3.6/driver/tutorials/change-streams/

阻塞调用是: collection.watch().forEach(printBlock);

谢谢， 罗腾。

Answer 1

当您在 reactive streams 的上下文中查看它们时，更改流更有意义.我花了一段时间才意识到这个概念的存在范围比 MongoDB 驱动程序要广泛得多。

我建议查看上面的文章，然后查看提供的示例 here .这两个链接帮助理清了问题，并提供了有关如何利用 react 流 Mongo 驱动程序编写代码的见解，它是非阻塞的。