socket傳輸protobuf位元組流實例教程

零下一度
發布: 2017-06-23 16:15:17
原創
2135 人瀏覽過

版權聲明:本文為原創文章,轉載請聲明 

近期在做棋牌項目,需要用到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中文網其他相關文章!

來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板