hangscer

Akka Serialization

2017/12/16

Akka本身使用了Protocol Buffers来序列化内部消息(比如gossip message)。Akka系统还可以配置自定义序列化机制。

配置conf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
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)。序列化所有的消息不回给性能带来提升,应当只在测试时使用。

1
2
3
4
5
6
akka {
actor {
## 序列化所有的消息(local actor和remote actor),可能在测试的时候使用
serizlize-messages = on
}
}

编程式手动获取类对应的序列器。

1
2
3
4
5
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]:

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

反序列化Array[Byte]

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