如何每X分钟查询一次数据库

我想通过akka和scala监控我们的订单流程，并且想要构建一个actor系统。来自网上商店的消息存储在mongoDB中，并存储在4个不同的集合中。每个集合都需要一个自己的FSM，因为这个订单在每个集合中都有不同的状态（例如collection1 = payment，collection2 = delivery，...）如何每X分钟查询一次数据库

我的问题是如何设置这个整个actor系统。特别是我需要知道我如何处理mongoDB，因为我需要查看数据库中每隔X分钟是否有新条目。这个查询应该由一个Actor执行，它将消息发送给FSM。我怎样才能做到这一点？

我真的没有找到谷歌的东西（或者我只是不知道该怎么谷歌：/）

感谢提前:)

来源

2016-11-15 Chaya93

阿卡有一个调度器。你可以用它做查询每X时间：http://doc.akka.io/docs/akka/current/scala/scheduler.html

另一个（丑陋的）的解决办法是做线程休眠

来源

2016-11-15 09:37:50 pedrorijo91

好一个无限循环，这是一个好点:) 你知道我是怎么可以确保自上次查询后才能获得添加的文档？ – Chaya93

不幸的是我没有使用mongoDB的经验.. – pedrorijo91

如何每X分钟查询一次数据库

回答

相关问题