试图反序列化一个没有 ActorSystem 范围内的序列化 ActorRef - Spark/Akka/Scala

Question

编辑：在确认执行 forEach 后，与序列化/反序列化 Akka Actor 相关的异常仍然存在。 我正在学习 Akka，遇到了这个序列化问题，我对 Akka 很陌生，发现很难弄清楚如何最好地解决问题。

我有一个创建actorSystem 和actor 的类，该类调用另一个类中的方法，我想在另一个类中使用我的actor。到目前为止，我已经尝试过：

Class a:
-create actor
-classB.methodX(actor)

Class b:
-methodX(actorRef)
--actorRef! message

目前来自 B 类的消息没有被发送，而 A 类的消息发送，这让我觉得我要么需要用我传入的 ActorRef 实例化一个新的 Actor，要么，这是完全错误的。

我了解系统需要存在于所有节点上，但我不确定如何执行此操作。

编辑：代码片段：

ClassA:
  private val system = ActorSystem("System")
  private val metricActor= system.actorOf(Props(new MetricActor("metrics")), name = "metrics")

metricActor ! message works fine

writeFiles(metricActor) //writeFiles is in another class


writeFiles(actor: ActorRef) {
  f.forEach(v => {
  actor ! message // this doesn't seem to work
})
}

已编辑以提供更多代码。

B 类的完整示例

def writeFiles(bucket: String, filesToWrite: RDD[(String, String)], actor:ActorRef): Unit =
filesToWrite.foreachPartition(f => {
  f.foreach(v => {
    try {
      //actor  ! ProcessSingleItem(MetricItem("File Created"))
      logger.debug(s"Writing file:")
      writeFile()
    }
    catch {
      case e: Exception =>
        //actor ! ProcessSingleItem(CloudWatchMetricItem("File create failure")) 
        logger.error("Error creating file", e)
    }
  })
})

Answer 1

您所描述的应该有效。您没有粘贴完整的（但最少的！）代码示例，所以我不能说问题出在哪里（可能是您的 foreach 逻辑中的某些内容；我们甚至不知道 f 是什么），但这是绝对有效的。尝试以此为基础。

object Test extends App {

  class MetricActor extends Actor {
    def receive = {
      case a: String => println(a)
    }
  }

  private val system = ActorSystem("System")
  private val metricActor= system.actorOf(Props(new MetricActor()), name = "metrics")

  OtherClass.writeFiles(metricActor) // prints "foo"
}

// this is in other file:
object OtherClass {
  def writeFiles(actor: ActorRef) {
    actor ! "foo"
  }
}

编辑：在 cmets 中讨论后发现有问题的部分与 Akka 无关（try 块甚至没有执行），但我将把它留在这里以防它对某人有所帮助。