在akka流中,可以执行以下操作:
Source.tick(0.seconds, 15.seconds, "Hello")
并且您的流将每15秒收到一个“Hello”节目元素。我正在寻找的是可以做同样的事情,但是在类似cron的时间表上,例如“每个星期一下午5点”。
我想到了。有一个akka插件akka-quartz-scheduler,允许配置一些石英计划配置,如下所示:将此部分添加到akka.conf
akka {
quartz.schedules {
SomeSchedule {
expression = "0 0 1 * * ?"
timezone = "GMT-7"
description = "Do something every day at 1 a.m. SF time."
}
}
}
然后安排它
case class Signal(someData: String)
implicit val system: ActorSystem = ActorSystem("lebulbeaux-system")
implicit val materializer: ActorMaterializer = ActorMaterializer()
// needed for the future flatMap/onComplete in the end
implicit val executionContext: ExecutionContextExecutor = system.dispatcher
val source: Source[Signal, ActorRef] = Source.actorRef[Signal](100, OverflowStrategy.fail)
val ref: ActorRef = Flow[Signal].to(Sink.foreach(signal => println(signal.someData))).runWith(source)
import com.typesafe.akka.extension.quartz.QuartzSchedulerExtension
QuartzSchedulerExtension(system).schedule("SomeSchedule", ref, Signal("Hello!"))
// scroll
现在,您每天凌晨1点收到一条信号消息。
另外,请查看此issue以获取使用Source.actorRef的更多选项