Java Akka 调度 API 抛出 MissingMethodException

Question

Java 8（好吧，Groovy）在这里使用 Akka com.typesafe.akka:akka-actor_2.11:2.5.4。我正在尝试创建一个 creates/owns/manages 另一个演员 (StateChecker) 的演员 (AppMaster)，并计划每 4 次向此 StateChecker 发送一条 CheckState 消息秒数：

class CheckState {}

class StateChecker extends AbstractActor {
  // For this question, it really doesn't matter what this actor does
}

class AppMaster extends AbstractActor {
    ActorRef stateChecker

    @Override
    Receive createReceive() {
      receiveBuilder()
            .match(Init, { message ->
              stateChecker = context.actorOf(Props.create(StateChecker, "yes", 20), "state-checker")

              FiniteDuration startDur = Duration.Zero()

              FiniteDuration freqDur = Duration.create(4000, TimeUnit.MILLISECONDS)
              CheckState checkState = new CheckState()
              ExecutionContextExecutor executor = context.system().dispatcher()

              context.system().scheduler().schedule(startDur, freqDur, stateChecker, checkState,
                executor)
            })
        .build()
    }
}

当我运行时，我得到以下异常：

groovy.lang.MissingMethodException: No signature of method: akka.actor.LightArrayRevolverScheduler.schedule() is applicable for argument types: (scala.concurrent.duration.FiniteDuration, scala.concurrent.duration.FiniteDuration, akka.actor.LocalActorRef, com.me.myapp.messages.CheckState, akka.dispatch.Dispatcher) values: [0 days, 4000 milliseconds, Actor[akka://myapp/user/myapp-master/o1-keeper#-1837899613], ...]
Possible solutions: schedule(scala.concurrent.duration.FiniteDuration, scala.concurrent.duration.FiniteDuration, java.lang.Runnable, scala.concurrent.ExecutionContext), schedule(scala.concurrent.duration.FiniteDuration, scala.concurrent.duration.FiniteDuration, scala.Function0, scala.concurrent.ExecutionContext), schedule(scala.concurrent.duration.FiniteDuration, scala.concurrent.duration.FiniteDuration, akka.actor.ActorRef, java.lang.Object, scala.concurrent.ExecutionContext, akka.actor.ActorRef)
    at org.codehaus.groovy.runtime.ScriptBytecodeAdapter.unwrap(ScriptBytecodeAdapter.java:58)
    at org.codehaus.groovy.runtime.callsite.PojoMetaClassSite.call(PojoMetaClassSite.java:49)

我在日志语句中添加，在调度期间抛出异常：

context.system().scheduler().schedule(startDur, freqDur, stateChecker, checkState,
  executor)

知道我需要做什么来解决这个问题吗？由于这是我在使用 Akka 的 Java API 时遇到的问题，我 do 需要通过 Java API.

Answer 1

问题是您传递给 schedule() 方法的参数与该方法的重载版本的 none 相匹配。您可以在 JavaDoc.

中看到 schedule() 的重载版本的签名

您尝试使用的版本如下method:

Cancellable schedule(scala.concurrent.duration.FiniteDuration initialDelay,
                     scala.concurrent.duration.FiniteDuration interval,
                     ActorRef receiver,
                     java.lang.Object message,
                     scala.concurrent.ExecutionContext executor,
                     ActorRef sender)

您缺少最后一个参数，它是一个 ActorRef，被指定为预定消息的发件人。如果 StateChecker 不关心是谁向它发送了 CheckState 消息，那么最简单的解决方法是传入 null 作为最后一个参数：

context.system()
       .scheduler()
       .schedule(startDur, freqDur, stateChecker, checkState, executor, null)
                                                                     // ^

Java Akka 调度 API 抛出 MissingMethodException

Java Akka Scheduling API throwing MissingMethodException

java

groovy

scheduling

akka