快捷導(dǎo)航

Redis存取序列化與反序列化性能問(wèn)題詳解

更新時(shí)間：2020年12月31日 08:33:03 作者：這名字已經(jīng)存在

這篇文章主要給大家介紹了關(guān)于Redis存取序列化與反序列化性能問(wèn)題的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

1. 問(wèn)題場(chǎng)景

我們?cè)谑褂肦edis的時(shí)候經(jīng)常會(huì)將對(duì)象序列化存儲(chǔ)到Redis中，在取出的時(shí)候進(jìn)行反序列化，如果對(duì)象過(guò)大在進(jìn)行序列化和反序列化的時(shí)候會(huì)有一定性能問(wèn)題。今天查看了CSRedis源碼發(fā)現(xiàn)在Set和Get的時(shí)候是支持Byte[]類型，那么問(wèn)題來(lái)了如果我們將對(duì)象轉(zhuǎn)換成Byte[]類型進(jìn)行存儲(chǔ)是否會(huì)比序列化和反序列化操作快了？

2. 問(wèn)題驗(yàn)證

2.1. 編寫一個(gè)簡(jiǎn)單實(shí)例進(jìn)行驗(yàn)證

  List<User> list = new List<User>();
  for (int i = 0; i < 1000; i++)
  {
   User user = new User() { Id = i, Name = "張三", Age = 11 };
   list.Add(user);
  }
  Stopwatch stopwatch = new Stopwatch();
  stopwatch.Start(); // 開(kāi)始監(jiān)視代碼運(yùn)行時(shí)間

  //使用序列化
  rds.HSet("test2", "test2", list);
  var list1 = rds.HGet<List<User>>("test2", "test2");

  //使用byte方式
  //rds.HSet("test", "test1", ObjectToBytes(list));
  //var list2 = BytesToObject(rds.HGet<byte[]>("test", "test1"));

  stopwatch.Stop(); // 停止監(jiān)視
  TimeSpan timespan = stopwatch.Elapsed; // 獲取當(dāng)前實(shí)例測(cè)量得出的總時(shí)間
  double hours = timespan.TotalHours; // 總小時(shí)
  double minutes = timespan.TotalMinutes; // 總分鐘
  double seconds = timespan.TotalSeconds; // 總秒數(shù)
  double milliseconds = timespan.TotalMilliseconds;
  Console.WriteLine(+hours + " " + minutes + " " + seconds + " " + milliseconds);
  Console.ReadKey();

對(duì)象轉(zhuǎn)換成Byte，和Byte轉(zhuǎn)成對(duì)象公用方法。

 /// <summary> 
 /// 將一個(gè)object對(duì)象序列化，返回一個(gè)byte[]   
 /// </summary> 
 /// <param name="obj">能序列化的對(duì)象</param>   
 /// <returns></returns> 
 public static byte[] ObjectToBytes(object obj)
 {
  byte[] buff;
  using (MemoryStream ms = new MemoryStream())
  {
   IFormatter iFormatter = new BinaryFormatter();
   iFormatter.Serialize(ms, obj);
   buff = ms.GetBuffer();
  }
  return buff;
 }

 /// <summary> 
 /// 將一個(gè)序列化后的byte[]數(shù)組還原   
 /// </summary>
 /// <param name="Bytes"></param>   
 /// <returns></returns> 
 public static object BytesToObject(byte[] Bytes)
 {
  using (MemoryStream ms = new MemoryStream(Bytes))
  {
   IFormatter formatter = new BinaryFormatter(); return formatter.Deserialize(ms);
  }
 }

注意點(diǎn)：兩種方式要分開(kāi)執(zhí)行?。?！