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）;

谢谢，Rotem。

Answer 1

使用 mongo 反应式驱动程序，使其成为非阻塞的。我们使用了这种方法并在生产环境中运行了一个月，没有出现任何问题。