Merge pull request #16 from sj-distributor/enhance-memory-serialize

enhance memory serialize

FastCache.InMemory/Drivers/MemoryCache.cs

@@ -2,11 +2,13 @@
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Linq;
+using System.Reflection;
 using System.Threading.Tasks;
 using FastCache.Core.Driver;
 using FastCache.Core.Entity;
 using FastCache.InMemory.Enum;
 using FastCache.InMemory.Extension;
+using Newtonsoft.Json;
 
 namespace FastCache.InMemory.Drivers
 {
@@ -36,7 +38,8 @@ public Task Set(string key, CacheItem cacheItem, long _ = 0)
             {
                 ReleaseCached();
             }
-
+
+            cacheItem.Value = JsonConvert.SerializeObject(cacheItem.Value);
             _dist.TryAdd(key, cacheItem);
 
             return Task.CompletedTask;
@@ -51,9 +54,11 @@ public Task<CacheItem> Get(string key)
                 Delete(key);
                 return Task.FromResult(new CacheItem());
             }
-
+            if (cacheItem?.AssemblyName == null || cacheItem?.Type == null) return Task.FromResult(new CacheItem());
             ++cacheItem.Hits;
-
+            var assembly = Assembly.Load(cacheItem.AssemblyName);
+            var valueType = assembly.GetType(cacheItem.Type, true, true);
+            cacheItem.Value = JsonConvert.DeserializeObject(cacheItem.Value as string, valueType);
             return Task.FromResult(cacheItem);
         }
 

UnitTests/MemoryCacheTests.cs

@@ -57,6 +57,8 @@ public async void TestMemoryCacheCanSet(string key, string value, string result)
     {
         await _memoryCache.Set(key, new CacheItem()
         {
+            Type =value.GetType().FullName,
+            AssemblyName = value.GetType().Assembly.FullName,
             Value = value,
             Expire = DateTime.UtcNow.AddSeconds(20).Ticks
         });