我正在使用 Play Framework 2.6.x 創建一個在特定時間(例如凌晨 3 點)運行任務的簡單 cron 作業。但現在我陷入了一個簡單的計劃任務:我創建了一個演員:package actors;import akka.actor.UntypedActor;import org.slf4j.LoggerFactory;public class DoSomethingActor extends UntypedActor { private static final org.slf4j.Logger log = LoggerFactory.getLogger(DoSomethingActor.class); @Override public void onReceive(final Object message) throws Throwable { log.info("Write your crone task or simply call your method here that perform your task " + message); }}然后我創建了一個 Schedule 類,每次我設置時調用 Actor:package tasks;import java.util.concurrent.TimeUnit;import javax.inject.Inject;import javax.inject.Named;import javax.inject.Singleton;import akka.actor.ActorRef;import akka.actor.ActorSystem;import akka.actor.Cancellable;import scala.concurrent.duration.Duration;@Singletonpublic class DoSomethingScheduler { @Inject public DoSomethingScheduler(final ActorSystem system, @Named("do-something-actor") final ActorRef doSomethingActor) { final Cancellable scheduler; final int timeDelayFromAppStart = 0; final int timeGapInSeconds = 1; //Here you provide the time delay for every run system.scheduler().schedule( Duration.create(timeDelayFromAppStart, TimeUnit.MILLISECONDS), //Initial delay when system start Duration.create(timeGapInSeconds, TimeUnit.SECONDS), //Frequency delay for next run doSomethingActor, "message for onreceive method of doSomethingActor", system.dispatcher(), null); }}最后,我將這些類綁定到一個模塊類中:package modules;import actors.DoSomethingActor;import com.google.inject.AbstractModule;import play.libs.akka.AkkaGuiceSupport;import tasks.DoSomethingScheduler;在這些事情之后,我運行了該應用程序,但它并沒有像我預期的那樣工作。我希望它每 1 秒顯示一次日志記錄,但沒有任何反應。你能幫我修一下嗎?太感謝了!
添加回答
舉報
0/150
提交
取消