Implement BinaryFormatterTranscoder

Author: cnblogs-dudu

Enyim.Caching/Configuration/MemcachedClientConfiguration.cs

@@ -125,9 +125,24 @@ public MemcachedClientConfiguration(
                 NodeLocator = options.Servers.Count > 1 ? typeof(DefaultNodeLocator) : typeof(SingleNodeLocator);
             }
 
-            if(options.Transcoder != null)
+            if(!string.IsNullOrEmpty(options.Transcoder))
             {
-                _transcoder = options.Transcoder;
+                try
+                {
+                    if (options.Transcoder == "BinaryFormatterTranscoder")
+                        options.Transcoder = "Enyim.Caching.Memcached.Transcoders.BinaryFormatterTranscoder";
+
+                    var transcoderType = Type.GetType(options.Transcoder);
+                    if (transcoderType != null)
+                    {
+                        Transcoder = Activator.CreateInstance(transcoderType) as ITranscoder;
+                        _logger.LogDebug($"Use '{options.Transcoder}'");
+                    }
+                }
+                catch (Exception ex)
+                {
+                    _logger.LogError(new EventId(), ex, $"Unable to load '{options.Transcoder}'");
+                }
             }
 
             if (options.NodeLocatorFactory != null)

Enyim.Caching/Configuration/MemcachedClientOptions.cs

@@ -19,7 +19,7 @@ public class MemcachedClientOptions : IOptions<MemcachedClientOptions>
 
         public string KeyTransformer { get; set; }
 
-        public ITranscoder Transcoder { get; set; }
+        public string Transcoder { get; set; }
 
         public IProviderFactory<IMemcachedNodeLocator> NodeLocatorFactory { get; set; }
 

Enyim.Caching/Memcached/Transcoders/BinaryFormatterTranscoder.cs

@@ -0,0 +1,33 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Runtime.Serialization.Formatters.Binary;
+using System.Text;
+
+namespace Enyim.Caching.Memcached.Transcoders
+{
+    public class BinaryFormatterTranscoder : DefaultTranscoder
+    {
+        protected override ArraySegment<byte> SerializeObject(object value)
+        {
+            using (var ms = new MemoryStream())
+            {
+                new BinaryFormatter().Serialize(ms, value);
+                return new ArraySegment<byte>(ms.GetBuffer(), 0, (int)ms.Length);
+            }
+        }
+
+        public override T Deserialize<T>(CacheItem item)
+        {
+            return (T)base.Deserialize(item);
+        }
+
+        protected override object DeserializeObject(ArraySegment<byte> value)
+        {
+            using (var ms = new MemoryStream(value.Array, value.Offset, value.Count))
+            {
+                return new BinaryFormatter().Deserialize(ms);
+            }
+        }
+    }
+}

Enyim.Caching/Memcached/Transcoders/DefaultTranscoder.cs

@@ -28,7 +28,7 @@ object ITranscoder.Deserialize(CacheItem item)
             return this.Deserialize(item);
         }
 
-        T ITranscoder.Deserialize<T>(CacheItem item)
+        public virtual T Deserialize<T>(CacheItem item)
         {
             if (item.Data == null || item.Data.Count == 0) return default(T);
 
@@ -184,7 +184,7 @@ protected virtual object Deserialize(CacheItem item)
                 // earlier versions serialized decimals with TypeCode.Decimal
                 // even though they were saved by BinaryFormatter
                 case TypeCode.Decimal:
-                //case TypeCode.Object: return this.DeserializeObject(data);
+                case TypeCode.Object: return this.DeserializeObject(data);
                 default: throw new InvalidOperationException("Unknown TypeCode was returned: " + code);
             }
         }

SampleWebApp/appsettings.json

@@ -13,7 +13,8 @@
       "receiveTimeout": "00:00:15",
       "deadTimeout": "00:00:15",
       "queueTimeout": "00:00:00.150"
-    }
+    }//,
+    //"Transcoder": "BinaryFormatterTranscoder"
     //,
     //"KeyTransformer": "Enyim.Caching.Memcached.SHA1KeyTransformer"
     //,