Akka Serialization

Akka本身使用了Protocol Buffers來序列化內部消息(比如gossip message)。Akka系統還可以配置自定義序列化機制。

配置conf

akka {
  actor {
    ## 在akka.actor.serializers中聲明有哪些序列化方式
    serializers {
      java = "akka.serialization.JavaSerializer"
      proto = "akka.remote.serialization.ProtobufSerializer"
    }
    ## 在akka.actor.serialization-bindings中說明哪些類(基類或者介面)需要使用哪個特定的序列器
    ## 僅僅需要聲明哪些介面或者抽象類
    ## 一個類的多個父類(介面)分別聲明瞭不同的序列器，那麼採用他們的最大公告s父類所使用的序列器
    serialization-bindings {
      "java.lang.String" = java
      "nathan.Frequency" = proto ##自定義trait
      "nathan.Frequency$" = proto ##自定義object
      "java.lang.Boolean" = proto
    }
  }
}
akka {
  actor {
    ## 序列化所有的消息(local actor和remote actor)，可能在測試的時候使用
    serizlize-messages = on
  }
}
akka {
  actor {
    ## 序列化所有的Props(local和remote)
    serialize-creators = on
  }
}

預設的，在local actor之間(the same JVM)的消息是不會序列化的。可以通過akka.actor.serialize-message配置，來序列化所有消息(local和remote)。序列化所有的消息不回給性能帶來提升，應當只在測試時使用。

akka {
  actor {
    ## 序列化所有的消息(local actor和remote actor)，可能在測試的時候使用
    serizlize-messages = on
  }
}

編程式手動獲取類對應的序列器。

  val actorSystem = ActorSystem("akka1", ConfigFactory.load())
  val serialization = SerializationExtension(actorSystem)
  val original = "2122"
  val stringSerializer = serialization.findSerializerFor(original)
  val frequcecySerization =   serialization.findSerializerFor(Frequency)

序列化某類的實例，得到Array[Byte]:

  val original = "2122"
  val stringSerializer = serialization.findSerializerFor(original)
  val array = stringSerializer.toBinary(original)

反序列化Array[Byte]

  val back = stringSerializer.fromBinary(array, classOf[String]) //明確Class[_]
  println(back) //2122
  println(back.getClass) //class java.lang.String

  val back = stringSerializer.fromBinary(array)
  println(back) //2122
  println(back.getClass) //class java.lang.String