Improve to work with IDistributedCache

Author: cnblogs-dudu

Enyim.Caching/EnyimMemcachedServiceCollectionExtensions.cs

@@ -48,27 +48,28 @@ private static IServiceCollection AddEnyimMemcached(IServiceCollection services,
             configure(services);
             services.Add(ServiceDescriptor.Transient<IMemcachedClientConfiguration, MemcachedClientConfiguration>());
             services.Add(ServiceDescriptor.Singleton<IMemcachedClient, MemcachedClient>());
+            services.Add(ServiceDescriptor.Singleton<IDistributedCache, MemcachedClient>());
             return services;
         }
 
-        public static IServiceCollection AddDistributedEnyimMemcached(this IServiceCollection services, Action<MemcachedClientOptions> setupAction)
+        public static IServiceCollection AddEnyimMemcachedIDistributedCache(this IServiceCollection services)
         {
-            if (services == null)
-            {
-                throw new ArgumentNullException(nameof(services));
-            }
-
-            if (setupAction == null)
+            services.AddSingleton<IDistributedCache>(factory =>
             {
-                throw new ArgumentNullException(nameof(setupAction));
-            }
-
-            services.AddOptions();
-            services.Configure(setupAction);
-            services.Add(ServiceDescriptor.Transient<IMemcachedClientConfiguration, MemcachedClientConfiguration>());
-            services.Add(ServiceDescriptor.Singleton<IDistributedCache, MemcachedClient>());
-
+                var memcachedClient = factory.GetService<IMemcachedClient>();
+                if(memcachedClient == null)
+                {
+                    throw new ArgumentNullException("Please AddEnyimMemcached first");
+                }
+                return memcachedClient as MemcachedClient;
+            });
             return services;
         }
+
+        [Obsolete]
+        public static IServiceCollection AddDistributedEnyimMemcached(this IServiceCollection services, Action<MemcachedClientOptions> setupAction)
+        {
+            return services.AddEnyimMemcachedIDistributedCache();
+        }
     }
 }

SampleWebApp/Program.cs

@@ -4,20 +4,22 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore;
 
 namespace SampleWebApp
 {
     public class Program
     {
         public static void Main(string[] args)
         {
-            var host = new WebHostBuilder()
-                .UseKestrel()
-                .UseContentRoot(Directory.GetCurrentDirectory())
+            BuildWebHost(args).Run();
+        }
+
+        public static IWebHost BuildWebHost(string[] args)
+        {
+            return WebHost.CreateDefaultBuilder(args)                
                 .UseStartup<Startup>()
                 .Build();
-
-            host.Run();
         }
     }
 }

SampleWebApp/SampleWebApp.csproj

@@ -13,4 +13,10 @@
     <ProjectReference Include="..\Enyim.Caching\Enyim.Caching.csproj" />
   </ItemGroup>
 
+  <ItemGroup>
+    <Content Update="appsettings.json">
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </Content>
+  </ItemGroup>
+
 </Project>

SampleWebApp/Startup.cs

@@ -9,6 +9,7 @@
 using Microsoft.Extensions.Logging;
 using Enyim.Caching;
 using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Caching.Distributed;
 
 namespace SampleWebApp
 {
@@ -32,15 +33,15 @@ public Startup(IHostingEnvironment env)
         public void ConfigureServices(IServiceCollection services)
         {
             services.AddEnyimMemcached(Configuration.GetSection("enyimMemcached"));
+                //.AddEnyimMemcachedIDistributedCache(); //For Microsoft.Extensions.Caching.Distributed.IDistributedCache
         }
 
         public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
         {
-            loggerFactory.AddConsole(LogLevel.Debug);
-
             app.UseEnyimMemcached();
 
             var memcachedClient = app.ApplicationServices.GetService<IMemcachedClient>();
+            var distributedCache = app.ApplicationServices.GetService<IDistributedCache>();
             var logger = loggerFactory.CreateLogger<MemcachedClient>();
 
             app.Run(async (context) =>
@@ -50,7 +51,9 @@ public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerF
                 var cacheResult = await memcachedClient.GetAsync<string>(cacheKey);
                 if (cacheResult.Success)
                 {
-                    await context.Response.WriteAsync(cacheResult.Value);
+                    var distributedCacheValue = await distributedCache.GetStringAsync(cacheKey);
+                    await context.Response
+                        .WriteAsync($"memcachedClient: {cacheResult.Value}<br/>distributedCache: {distributedCacheValue}");
                     await memcachedClient.RemoveAsync(cacheKey);
                     logger.LogDebug($"Hinted cache with '{cacheKey}' key");
                 }

SampleWebApp/appsettings.json

@@ -25,6 +25,14 @@
     //    "password": "password"
     //  }
     //}
+  },
 
+  "Logging": {
+    "IncludeScopes": false,
+    "LogLevel": {
+      "Default": "Debug",
+      "System": "Warning",
+      "Microsoft": "Warning"
+    }
   }
 }