版權聲明：本文為原創文章，轉載請聲明
近期在做棋牌項目，需要用到socket傳輸protobuf字節流，在網上找了一些博客和文章後發現，沒有特別全面的，所以把自己研究的全部源碼拿出來和大家分享，因為剛開始做，可能會有不足的地方，歡迎拍磚~~
這篇主要是protocol buffer檔案的序列化與解析，廢話不多說了，直接上乾貨
1 /// <summary> 2 /// 将消息序列化为二进制的方法 3 /// </summary> 4 /// <param name="model">要序列化的对象</param> 5 public static byte[] Serialize(IExtensible model) 6 { 7 try 8 { 9 //创建流对象10 MemoryStream ms = new MemoryStream()11 //使用ProtoBuf自带的序列化工具序列化IExtensible对象12 Serializer.Serialize<IExtensible>(ms, model);13 //创建二级制数组，保存序列化后的流14 byte[] bytes = new byte[ms.Length];15 //将流的位置设为016 ms.Position = 0;17 //将流中的内容读取到二进制数组中18 ms.Read(bytes, 0, bytes.Length);19 return bytes;20 }21 catch (Exception e)22 {23 Debug.Log("序列化失败: " + e.ToString());24 return null;25 }26 }protobuf檔案中的每一則message經過protocol buffer提供的ProtoGen工具可以轉成c#的中的類，例如
message Test {
required string test1= 1;
required string test2= 2;
}經過轉化後就變成了
1 [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"SedReq")] 2 public partial class Test : global::ProtoBuf.IExtensible 3 { 4 public Test() {} 5 6 private string _test1; 7 [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"test1", DataFormat = global::ProtoBuf.DataFormat.Default)] 8 public string test1 9 {10 get { return _test1; }11 set { _test1 = value; }12 }
13 private string _test2;14 [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"test2", DataFormat = global::ProtoBuf.DataFormat.Default)]15 public string test216 {17 get { return _test2; }18 set { _test2 = value; }19 }20 private global::ProtoBuf.IExtension extensionObject;21 global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)22 { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); }23 }無視所有帶global的程式碼，你會發現，轉化後的c#類別和一個標準的c#實體類別一模一樣，並且，這些轉換後的類別都繼承至ProtoBuf.IExtensible，所以上文中的序列化函數的參數的類型是IExtensible
有了序列化，當然還需要反序列化，也就是講byte[]反序列化為繼承至IExtensible的類型的物件
1 /// <summary> 2 /// 将收到的消息反序列化成IExtensible对象 3 /// </summary> 4 /// <param name="msg">收到的消息的字节流.</param> 5 /// <returns></returns> 6 public static T DeSerialize<T>(byte[] bytes) where T : IExtensible 7 { 8 try 9 {10 MemoryStream ms = new MemoryStream()11 //将消息写入流中12 ms.Write(bytes, 0, bytes.Length);13 //将流的位置归014 ms.Position = 0;15 //反序列化对象16 T result = Serializer.Deserialize<T>(ms);17 return result;18 }19 catch (Exception e)20 {21 Debug.Log("反序列化失败: " + e.ToString());22 return null;23 }24 }因為反序列化後的物件是繼承至IExtensible的類別的對象，所以返回值必須使用泛型約束來定義，這樣才能保證函數的通用性
工具搞定，接下來就是測試程式碼了
1 public void Test()2 {3 Test test = new Test() { test1 = "123", test2 = "456" };4 byte[] bytes = Serialize(test);5 Test test2 = DeSerialize<Test>(bytes);6 Debug.Log(test2.test1 + test2.test2);7 }輸出結果 123456
附上protobuf-net.dll檔案
預先編譯與轉換工具
以上是socket傳輸protobuf位元組流實例教程的詳細內容。更多資訊請關注PHP中文網其他相關文章！
