java play2-akka for jobs

c7rzv4ha 于 2021-07-09 发布在 Java

关注(0)|答案(2)|浏览(405)

我试图用akka在javaplay2中创建一个job。
我总是犯同样的错误 error: cannot find symbol 它指向 system.actorOf() intellij和eclipse没有给我错误消息。
但是我找不到这个方法。我使用了以下导入

import play.libs.Akka;
import akka.actor.ActorSystem;
import akka.actor.ActorRef;
import akka.actor.UntypedActorFactory;
import akka.actor.UntypedActor;
import akka.actor.Props;
import akka.actor.ActorRefFactory;

也许文件已经过时了，他们已经删除了 system.actorOf() ?

public class Global extends GlobalSettings {
    ActorRef tickActor = system.actorOf(new Props().withCreator(new UntypedActorFactory() {
          public UntypedActor create() {
            return new UntypedActor() {
              public void onReceive(Object message) {
                if (message.equals("Log")) {
                  controllers.Application.log();
                } else {
                  unhandled(message);
                }
              }
            };
          }
        }));
    @Override
    public void onStart(Application app) {
        Cancellable cancellable = system.scheduler().schedule(Duration.Zero(), Duration.create(10, TimeUnit.SECONDS),
                tickActor, "Log");
    }
}

编辑：
.
哦。。。谷歌把我转到了过时的文档。是的 Akka.System() 现在。。
有人能给我举个例子，说明如何用代码创建tickactor吗？
http://www.playframework.org/documentation/2.0.2/javaakka

Java akka Jobs playframework-2.0

来源：https://stackoverflow.com/questions/12108431/java-play2-akka-for-jobs

2条答案

按热度按时间

zmeyuzjn1#

解决了。
顺便说一句，文档中有一些拼写错误。

import java.util.concurrent.TimeUnit;
import play.*;
import play.mvc.*;
import play.mvc.Http.RequestHeader;
import static play.mvc.Results.*;
import play.libs.Akka;
import akka.actor.ActorSystem;
import akka.actor.ActorRef;
import akka.actor.UntypedActorFactory;
import akka.actor.UntypedActor;
import akka.actor.Props;
import akka.actor.ActorRefFactory;
import akka.util.*;
public class Global extends GlobalSettings {
    ActorRef tickActor;
    @Override
    public void onStart(Application app) {
        Logger.info("D");
        tickActor = Akka.system().actorOf((new Props().withCreator(new UntypedActorFactory() {
              public UntypedActor create() {
                    return new UntypedActor() {
                      public void onReceive(Object message) {
                        if (message.equals("Log")) {
                                 //Do something
                         // controllers.Application.log();
                        } else {
                          unhandled(message);
                        }
                      }
                    };
                  }
                })));
        Akka.system().scheduler().schedule(
                  Duration.create(0, TimeUnit.MILLISECONDS),
                  Duration.create(30, TimeUnit.MINUTES),
                  tickActor, 
                  "Log"
                );
    }
}