Protobuf的設(shè)計非常適用于在網(wǎng)絡(luò)通訊中的數(shù)據(jù)載體，它序列化出來的數(shù)據(jù)量少再加上以K-V的方式來存儲數(shù)據(jù)，對消息的版本兼容性非常強;還有一個比較大的優(yōu)點就是有著很多的語言平臺支持。下面講解一下如何在TCP通訊應(yīng)用中集成Protobuf.
Protobuf提供一種簡單的對象消息方式來描述數(shù)據(jù)的存儲，通過相關(guān)實現(xiàn)可以簡單地實現(xiàn)數(shù)據(jù)流和對象之間的轉(zhuǎn)換。但由于Protobuf序列化后的信息并不包括一些相應(yīng)對象類型描述，只有消息體的內(nèi)容;因此在進行通信交互過程中默認情況是不知道這些數(shù)據(jù)和對象的對應(yīng)關(guān)系;既然對方不清楚這些數(shù)據(jù)對應(yīng)那種類型，那數(shù)據(jù)還源成對象就根本沒辦法入手。所以把Protobuf用到網(wǎng)絡(luò)通訊中我們還需要外加一些協(xié)議來規(guī)范數(shù)據(jù)的對應(yīng)關(guān)系。
在通訊協(xié)議上只需要在消息體中先寫入類型然后再寫入Protobuf數(shù)據(jù)，TypeName主要是用于對方配匹數(shù)據(jù)對應(yīng)的對象關(guān)系，這個TypeName是string還是int或其他就根據(jù)自己喜好來制定了。
在通訊上問題就解決了，但還要面對實際中使用的一種情況消息太多了……那處理TypeName->Object則一個蛋痛的事情。還好在.net和android下有類元素表這玩意還能在運行行進行操作，從而可以大大節(jié)省這些if判斷處理。由于本人熟悉的語言平臺有限，在這里分別提供java和c#的解決方法。
public static void Register(Class protobufclass) {
try {
ProtoMessageHandler mb;
Class[] protoObjs = protobufclass.getClasses();
for (Class item : protoObjs) {
if(item==null)
continue;
if (!item.isInterface() && item.getSuperclass().equals(
com.google.protobuf.GeneratedMessage.class)) {
mb = new ProtoMessageHandler();
mb.SetType(item);
mMessageTbl.put(item.getSimpleName(), mb);
}
}
} catch (Exception e) {
}
}
由于使用Protoc工具生成的類都會生成一個大類里，所以只需要注冊指定的類然后對所有繼承com.google.protobuf.GeneratedMessage的內(nèi)嵌類找出來并記錄在一個Map中即可。
String name= stream.ReadUTF();
ProtoMessageHandler handler = ProtoPackage.GetMsgHandler(name);
if(handler==null)
throw new Exception(name+" message type notfound!");
Message=(com.google.protobuf.GeneratedMessage) handler.GetObject(stream.GetStream());
以上是通過類型值獲取對應(yīng)的對象，并填充Protobuf數(shù)據(jù)。
相對于android平臺下的實現(xiàn)，.net的實現(xiàn)就更簡單些了。
public static void Register(System.Reflection.Assembly assembly)
{
foreach(Type type in assembly.GetTypes())
{
if (!type.IsAbstract && !type.IsInterface && type.GetCustomAttributes(typeof(ProtoBuf.ProtoContractAttribute), false).Length > 0)
mProtoTbl[type.Name] = type;
}
}
string name = reader.ReadUTF();
Type type = ProtoPakcage.GetProtoType(name);
Message = ProtoBuf.Meta.RuntimeTypeModel.Default.Deserialize(reader.Stream, null, type);
通過以上方法在使用Protobuf的時候就不用擔心消息太多寫if寫到手軟了，也不容易出錯。不過有一點要注意的就是類的名稱一定要對應(yīng)，否則就無法匹配到消息了。如果想得到完全整的代碼可以到https://beetlenp.codeplex.com獲取。
