7

我正在尝试使用 akka 远程参与者发送消息，其中案例类是在其构造函数中采用参数的超类的子类。

这是重现该问题的最小示例：

package com.tuvistavie.testremote

import akka.actor.{ Actor, ActorSystem, Props, ActorLogging }
import com.typesafe.config.ConfigFactory

abstract class Foo(val a: Int)
case class MessageFoo(override val a: Int) extends Foo(a)

object Sender {
  def main(args: Array[String]) {
    val system = ActorSystem("Sender", ConfigFactory.load.getConfig("sender"))
    val actor = system.actorFor("akka://Receiver@127.0.0.1:2552/user/receiver")
    actor ! MessageFoo(1)
  }
}

object Receiver {
  class ReceiverActor extends Actor with ActorLogging {
    def receive = {
      case m: MessageFoo => log.debug(m.toString)
    }
  }

  def main(args: Array[String]) {
    val system = ActorSystem("Receiver", ConfigFactory.load.getConfig("receiver"))
    val actor = system.actorOf(Props[ReceiverActor], "receiver")
  }
}

运行此代码时，我收到以下错误：

[ERROR] [06/26/2013 02:53:16.132] [Receiver-9] 
[NettyRemoteTransport(akka://Receiver@127.0.0.1:2552)] 
RemoteServerError@akka://Receiver@127.0.0.1:2552] Error[java.io.InvalidClassException: com.tuvistavie.testremote.MessageFoo; no valid constructor]

我认为这是因为消息无法反序列化（使用akka.serialization.JavaSerializer），因为父母的构造函数。如果只有一两条消息，我知道我可以编写自己的序列化程序，但我的应用程序中有很多这样的案例类。

是否有任何简单的方法可以使用远程参与者传递这种对象？

4

2 回答 2

10 
class A(a: Int)
case class C() extends A(1)

就像 cmbaxter 的回答指出的那样，这种模式（案例类的超类没有无参数构造函数）会导致InvalidClassException反序列化。根据 cmbaxter 的回答，避免这种模式是一种解决方案。

但是这种模式有什么问题呢？原因记录在Serializable的 API 文档中：

为了允许序列化不可序列化类的子类型，子类型可以负责保存和恢复超类型的公共、受保护和（如果可访问）包字段的状态。仅当它扩展的类具有可访问的无参数构造函数来初始化类的状态时，子类型才可以承担此责任。如果不是这种情况，则声明类 Serializable 是错误的。将在运行时检测到错误。

所以问题是它class A没有一个无参数的构造函数，而且它不是Serializable. 所以一个简单的解决方案就是制作它Serializable！

class A(a: Int) extends Serializable
case class C() extends A(1)
于 2015-01-28T10:54:24.517 回答
9

如果您像这样进行重组，一切都会奏效：

trait Foo{
  val a:Int
}
case class MessageFoo(a:Int) extends Foo

我通常会尝试使用案例类远离类继承。如果我需要能够将一组案例类引用为抽象类型，我会改用特征。

于 2013-06-25T19:16:22.583 回答