Akka Serialization

Posted 蒋航的博客

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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

以上是关于Akka Serialization的主要内容,如果未能解决你的问题,请参考以下文章

在线程“ main”中获取Akka流代码时出错,异常java.lang.NoClassDefFoundError:scala / Function1 $ class

AKKA HTTP 简单示例

Scala 学习 并发编程模型Akka

AKKA-HTTP DSL源码解读

我想在(Akka 2.3.14)中使用 AkkaSpec

akka-http 分块响应连接