玩！異步行動akka AskTimeoutException

我想使用問問模式使用akka Actor發出最簡單的異步請求，但無論如何我都會收到akka.pattern.AskTimeoutException。我所擁有的是這樣的：玩！異步行動akka AskTimeoutException

object Users extends Controller { 

    def newUser = { 
    val actor = Akka.system.actorOf(Props[UserRegistration]) 
    ActorAction[String](actor, "hello")(Ok(_)) 
    } 
}

其中ActorAction是平時Async的包裝：

object ActorAction { 

    def apply[A](actorRef: ActorRef, msg: AnyRef, timeout: Timeout = 5 seconds)(f: A => Result)(implicit m: Manifest[A]): Action[AnyContent] = { 
    Action { 
     AsyncResult { 
     ask(actorRef, msg, timeout).mapTo[A].asPromise.map(f) 
     } 
    } 
    } 

}

和演員什麼都不做，但會記錄接收消息並返回它：

class UserRegistration extends Actor { 
    val log = Logging(context.system, this) 
    def receive = { 
    case u => log.info("received " + u); u 
    } 
}

消息的記錄工作正常。我嘗試了一切，但沒有任何工作。任何幫助都比歡迎！

播放：2.9.1 阿卡：2.0.2

堆棧跟蹤：

[info] play - database [default] connected at jdbc:postgresql://localhost:5432/ss_dev 
[info] play - Application started (Dev) 
[info] play - Starting application default Akka system. 
[INFO] [12/28/2012 22:10:42.51] [application-akka.actor.default-dispatcher-1] [akka://application/user/$a] received hello 
[error] play - Waiting for a promise, but got an error: Timed out 
akka.pattern.AskTimeoutException: Timed out 
at akka.dispatch.DefaultPromise.result(Future.scala:875) [akka-actor.jar:2.0.2] 
at akka.dispatch.Await$.result(Future.scala:74) ~[akka-actor.jar:2.0.2] 
at play.api.libs.concurrent.AkkaPromise.await(Akka.scala:43) ~[play_2.9.1.jar:2.0.4] 
at play.api.libs.concurrent.Promise$class.await(Promise.scala:55) ~[play_2.9.1.jar:2.0.4] 
at play.api.libs.concurrent.AkkaPromise.await(Akka.scala:28) ~[play_2.9.1.jar:2.0.4] 
at play.api.libs.concurrent.Promise$class.value(Promise.scala:53) ~[play_2.9.1.jar:2.0.4] 
Caused by: akka.pattern.AskTimeoutException: Timed out 
at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:274) ~[akka-actor.jar:2.0.2] 
at akka.actor.DefaultScheduler$$anon$6$$anon$7.run(Scheduler.scala:183) ~[akka-actor.jar:2.0.2] 
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:94) [akka-actor.jar:2.0.2] 
at akka.jsr166y.ForkJoinTask$AdaptedRunnableAction.exec(ForkJoinTask.java:1381) [akka-actor.jar:2.0.2] 
at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259) [akka-actor.jar:2.0.2] 
at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:975) [akka-actor.jar:2.0.2]

在此先感謝！

來源

2012-12-28 Gerry

你不回覆消息sender ! u，請閱讀阿卡參考文檔：http://doc.akka.io

來源

2012-12-28 20:18:35

感謝維克多！它確實有用！我認爲接收方法的返回值是「回覆」。非常感謝。 – Gerry

嗨格里，接收方法不返回任何東西（單位），這是因爲你可以有0..N「返回值」 –

玩！異步行動akka AskTimeoutException

回答

相關問題