来自Akka Actor的异步回调

Question

我有一个actor可以从外部系统（UDP/TCP）接收消息。根据传入数据的内容，有时我希望actor回调代码的非AKA部分。
换句话说，我不想用ask调用和actor并等待一些传入数据，而是异步回调。
我如何实现这一点而不关闭调用对象（在创建ActorRef时会在回调中传递琐碎的内容，但这会捕获调用者）？

Answer 1

假设您有一个函数接口HandleMessage-即一个方法HandleMessage，它只接受不可变数据-您可以简单地将它包装在Future中，在参与者的上下文中运行：

import scala.concurrent.Future

// Inside your actor, this is the implicit execution context holding the thread
// pool the actor executes within. You MUST import this in order for it to be in
// the implicit scope for scala.concurrent.Future.
import context.dispatcher
Future {
  handleMessage(messageData)
  // If you need to know when this completes, send a message to the initiating
  // actor here.
}