Akka Actor 必须区分消息传递时是否需要返回 future 吗？

Question

据我了解，演员可以用“发射后不管”风格发送消息！运算符，或带有 ? 的“发送并接收未来”风格操作员。通过 ? 传递消息的演员必须调用 self.reply，否则发送者将收到超时异常。另一方面，演员通过 !如果消息不是从另一个参与者传递的，则不能有 self.reply。

我的问题是，Actor 是否应该在编译时知道它是否会被调用！或者 ？ ???或者如果 self.reply 的必要性可以在运行时确定，那么如何确定呢？也许涉及 self.tryReply，但 akka 文档似乎暗示尝试回复失败是一个错误情况，而如果发送者不是参与者，如果消息通过！

编辑：

这是一些代码：

package akTest

import akka.actor.Actor

object Main1 {
  val worker = Actor.actorOf[ak].start()

  def main(args: Array[String]) {
    val resp = worker ? "Hi"
    resp.get
    println(resp)
  }
}

class ak extends Actor {
  def receive = {
    case msg:String  => {
      val response = "Received: " + msg
      println(response)
      response
    }
  }
}

这得到 线程“main”中的异常 akka.dispatch.FutureTimeoutException: Futures timed out after [4995] milliseconds

所以我向 actor 添加了一个 self.reply：

class ak extends Actor {
  def receive = {
    case msg:String  => {
      val response = "Received: " + msg
      println(response)
      self.reply(response)
      response
    }
  }
}

此更改修复了超时错误。但现在如果我有一个发送即发即忘消息的 Main2，

object Main2 {
  val worker = Actor.actorOf[ak].start()

  def main(args: Array[String]) {
    val resp = worker ! "Hi"
    println(resp)
  }
}

则会产生一个新错误： [ERROR] [2/1/12 2:04 PM] [akka:event-driven:dispatcher:global- 1] [本地演员参考] 范围内没有发送者，无法回复。

我如何编写我的参与者以消除其响应方式与发送者调用方法之间的耦合？我不想有 1 个版本的演员！和演员的第二个版本？

Answer 1

如果 senderFuture.isDefined 那么你有一个 future 可以回复