protobuf对象二进制序列化存储-蒲公英云

protobuf对象二进制序列化存储

男娘i 2022-08-20 05:06 344阅读 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;
            }
        }