Reactive-MongoDB异步Java Driver解读

ObservableSubscriber subscriber =newObservableSubscriber(); collection.find().subscribe(subscriber);//结果处理 subscriber.get(15,TimeUnit.SECONDS).forEach( d ->{     System.out.println("Document:"+ d.toJson());}); 

当然，这个例子还有可以继续完善，比如使用 List 作为缓存，则要考虑数据量的问题，避免将全部(或超量) 的文档一次性转入内存。

作者：唐卓章

华为技术专家，多年互联网研发/架设经验，关注NOSQL 中间件高可用及弹性扩展，在分布式系统架构性能优化方面有丰富的实践经验，目前从事物联网平台研发工作，致力于打造大容量高可用的物联网服务。

（编辑：应用网_阳江站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!