protobuf对象二进制序列化存储

男娘i 2022-08-20 05:06 221阅读 0赞

首先下载protobuf库，可以用Nuget。

demo：

using System;
    
    namespace Tools
    {
        public class BufHelp
        {
            /// <summary>
            /// 对象锁
            /// </summary>
            private readonly static Object Locker = new Object();
            / <summary>
            / 读写分离锁
            / </summary>
            / <remarks>http://www.360doc.com/content/13/1216/09/10504424_337515446.shtml</remarks>
            //private static ReaderWriterLockSlim rwl = new ReaderWriterLockSlim();
    
            /// <summary>
            /// 序列化-表字段业务信息
            /// </summary>
            public static bool ProtoBufSerialize<T>(T model, string filename) where T : class
            {
                try
                {
                    string binpath = Config.KeyCenter.KeyBaseDirectory + @"Config\";
    
                    if (!System.IO.Directory.Exists(binpath))
                        System.IO.Directory.CreateDirectory(binpath);
    
                    lock (Locker)
                    {
                        using (var file = System.IO.File.Create(binpath + filename))
                        {
                            ProtoBuf.Serializer.Serialize<T>(file, model);
                            return true;
                        }
                    }
                }
                catch
                {
                    return false;
                }
            }
    
            public static T ProtoBufDeserialize<T>(string filename) where T : class
            {
                var dbpath = Config.KeyCenter.KeyBaseDirectory + @"Config\" + filename;
    
                if (System.IO.File.Exists(dbpath))
                {
                    lock (Locker)
                    {
                        using (var file = System.IO.File.OpenRead(dbpath))
                        {
                            var result = ProtoBuf.Serializer.Deserialize<T>(file);
                            return result;
                        }
                    }
                }
    
                return default(T);
            }
        }
    }

/// <summary>
            /// 序列化
            /// </summary>
            public static string Serialize<T>(T t) where T : class
            {
                using (MemoryStream ms = new MemoryStream())
                {
                    ProtoBuf.Serializer.Serialize<T>(ms, t);
                    return Encoding.UTF8.GetString(ms.ToArray());
                }
            }
            /// <summary>
            /// 反序列化
            /// </summary>
            public static T DeSerialize<T>(string content) where T : class
            {
                using (MemoryStream ms = new MemoryStream(Encoding.UTF8.GetBytes(content)))
                {
                    T t = ProtoBuf.Serializer.Deserialize<T>(ms);
                    return t;
                }
            }