带有macWire DI的Akka actoreRef，未设置actoreRef

Question

我有 2 个演员，Actor1 和 Actor2。 Actor1 想将MyMsg1 发送给Actor2，而Actor2 在完成一些工作后得到Future[MyMsg2] 想将MyMsg2 发送给Actor1。我有这种方法，但 DI 失败了。

1. 场景 1 - 工作场景

   • Actor1 -->MyMsg1-->Actor2
   • Actor2 MyMsgHandler - 处理消息（使用 Future），使用MyMsg2 将 pipeTo 发送到发送者。工作正常，Actor1 接收 MyMsg2

2. 场景 2 - 失败场景

   • Actor1 有一个通过 MacWire 注入的 bean - myBean。
   • myBean 将 Actor2 作为 bean 注入，并将 MyMsg1 发送到 Actor2
   • Actor2 MyMsgHandler 处理消息（使用 Future），对发送者执行 pipeTo 并尝试发送 MyMsg2 - 转到 deadLetter。发送者的演员 Ref 永远不会被设置。

我该如何解决这个问题？

也粘贴代码

class Actor1(failedService: FailedService, actor2: ActorRef @@ Actor2) extends Actor{
  override def receive: Receive = {
    case TriggerActor1() =>
      println("Actor1 triggered from REST controller. Send msg to actor 2")
      failedService.testSend()
      //actor2 ! Msg1()
    case Msg2() => println("got msg2 from actor 1")
  }

class Actor2 extends Actor {
  override def receive: Receive = {
    case Msg1() => {
      println("send without future")
      val origsender = sender()
      origsender ! Msg2()
    }
  }

class FailedService(actor2: ActorRef@@Actor2) {
  def testSend() = {
    actor2 ! Msg1()
  }
}

使用我上面共享的当前代码，Actor1 能够将Msg1 发送到Actor2 actor2 回复 Msg2 但 Msg2 进入死信。我收到以下错误 akka.actor.DeadLetterActorRef - Message [backup.failedakka.Msg2] from Actor[akka://application/user/actor2#-662746578] to Actor[akka://application/deadLetters] was not delivered. [1] dead letters encountered.

但是，如果在我的 Actor1 中使用 failedService.testSend() 行，我取消注释它下面的行 并用它来交流，一切正常。 Q现在清楚了吗？我正在使用 MacWire 注入依赖项

Answer 1

! 定义为：

def !(message: Any)(implicit sender: ActorRef = Actor.noSender): Unit

您现在可以看到问题了，FailedService 范围内没有隐式发送者，尽管它在参与者实现“内部”的范围内。

我想你想做：

class FailedService(actor2: ActorRef@@Actor2) {
  def testSend(implicit sender: ActorRef) = {
    actor2 ! Msg1()
  }
}