支持 .NET Core 的 Memcached 客户端 EnyimMemcachedCore

1. 介绍

EnyimMemcachedCore 是一个支持 .NET Core 的 Memcached 客户端，是从 EnyimMemcached 迁移至 .NET Core的，源代码托管在 GitHub 上：https://github.com/cnblogs/EnyimMemcachedCore ，NuGet 包地址：https://www.nuget.org/packages/EnyimMemcachedCore 。

2. 使用说明

2.1 安装 NuGet 包

Install-Package EnyimMemcachedCore

2.2 配置

2.2.1 在 appsetting.json 中进行配置

1）不带验证的配置

{

  "enyimMemcached": {

    "Servers": [

      {

        "Address": "memcached",

        "Port": 11211

      }

    ]

  }

}

2）带验证的配置

{

  "enyimMemcached": {

    "Servers": [

      {

        "Address": "memcached",

        "Port": 11211

      }

    ],

    "Authentication": {

      "Type": "Enyim.Caching.Memcached.PlainTextAuthenticator",

      "Parameters": {

        "zone": "",

        "userName": "username",

        "password": "password"

      }

    }

  }

}

3）Startup.cs 中的配置代码

public class Startup

{

    public void ConfigureServices(IServiceCollection services)

    {

        services.AddEnyimMemcached(options => Configuration.GetSection("enyimMemcached").Bind(options));

    }

    public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)

    {

        app.UseEnyimMemcached();

    }

}

2.2.2 直接硬编码配置（无需配置文件）

Startup.cs 中的硬编码配置代码

public class Startup

{

    public void ConfigureServices(IServiceCollection services)

    {

        services.AddEnyimMemcached(options =>

        {

            options.AddServer("memcached", );

            //options.AddPlainTextAuthenticator("", "usename", "password");

        });

    }        

    public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)

    {

        app.UseEnyimMemcached();

    }

}

2.3 调用

2.3.1 使用 IMemcachedClient 接口

public class TabNavService

{

    private ITabNavRepository _tabNavRepository;

    private IMemcachedClient _memcachedClient;

    public TabNavService(

        ITabNavRepository tabNavRepository,

        IMemcachedClient memcachedClient)

    {

        _tabNavRepository = tabNavRepository;

        _memcachedClient = memcachedClient;

    }

    public async Task<IEnumerable<TabNav>> GetAll()

    {

        var cacheKey = "aboutus_tabnavs_all";

        var result = await _memcachedClient.GetAsync<IEnumerable<TabNav>>(cacheKey);

        if (!result.Success)

        {

            var tabNavs = await _tabNavRepository.GetAll();

            await _memcachedClient.AddAsync(cacheKey, tabNavs, );

            return tabNavs;

        }

        else

        {

            return result.Value;

        }

    }

}

2.3.2 使用 IDistributedCache 接口（来自 Microsoft.Extensions.Caching.Abstractions ）

public class CreativeService

{

    private ICreativeRepository _creativeRepository;

    private IDistributedCache _cache;

    public CreativeService(

        ICreativeRepository creativeRepository,

        IDistributedCache cache)

    {

        _creativeRepository = creativeRepository;

        _cache = cache;

    }

    public async Task<IList<CreativeDTO>> GetCreatives(string unitName)

    {

        var cacheKey = $"creatives_{unitName}";

        IList<CreativeDTO> creatives = null;

        var creativesJson = await _cache.GetStringAsync(cacheKey);

        if (creativesJson == null)

        {

            creatives = await _creativeRepository.GetCreatives(unitName)

                    .ProjectTo<CreativeDTO>().ToListAsync();

            var json = string.Empty;

            if (creatives != null && creatives.Count() > )

            {

                json = JsonConvert.SerializeObject(creatives);

            }

            await _cache.SetStringAsync(

                cacheKey,

                json,

                new DistributedCacheEntryOptions().SetSlidingExpiration(TimeSpan.FromMinutes()));

        }

        else

        {

            creatives = JsonConvert.DeserializeObject<List<CreativeDTO>>(creativesJson);

        }

        return creatives;

    }

}

3. 问题支持

如果在使用中遇到问题，麻烦您在 GitHub 上提交 Issue 。

巴特西