美文网首页asp.netdotNET.NET
.Net下基于EnyimMemcached封装Memcached

.Net下基于EnyimMemcached封装Memcached

作者: zeor2016 | 来源:发表于2016-08-07 20:20 被阅读442次

    ** 原创文章,如有转载请注明来源! **  
    .Net下Memcached的引用环境包很多,EnyimMemcached包是其中的一个比较出名的。我们只需要在使用Memcached的项目中通过Nuget安装EnyimMemcached,Nuget就会帮根据我们开发环境的版本引用相应版本的dll及写入配置文件,相对我们手动去下载包文件引入,手动配置可谓省时省力,推荐大家使用这种安装方式!


    EnyimMemcached安装以后,我们已经可以通过相应的代码对Memcached进行操作,但我们可以根据项目实际需要对其进行进一步封装,方便我们的实际使用。 
     
    通常,对于一些可配置参数我们都会配置在web.config文件里。下面我们就对Memcached的参数进行配置。

    1. 打开web.config文件,找到configuration的configSections子节点,添加如下配置:
    <sectionGroup name="enyim.com" \>    
    <section name="memcached" type="Enyim.Caching.Configuration.MemcachedClientSection, Enyim.Caching" \>    
    </sectionGroup \> 
    

    然后我们添加名为enyim.com的根节点,内容如下:

    <!--Eniym配置开始-- \>  
    <enyim.com>    
    <memcached protocol="Text">     
    <servers>        
    <add address="127.0.0.1" port="11211" />      < /servers>      
    <socketPool minPoolSize="10" maxPoolSize="100" connectionTimeout="00:00:05" deadTimeout="00:02:00" />    
    </memcached>
     < /enyim.com> 
    < !--Eniym配置结束-->
    

    整个配置代码如下图


    接下来,新建MemCachedHelper.cs文件,详细代码如下:

        using Enyim.Caching;
        using Enyim.Caching.Configuration;
        using Enyim.Caching.Memcached;
        using System;
        using System.Net;
    
    
        #region Version Info
        /* ========================================================================
        * 【本类功能概述】MemCached缓存处理
        *
        * 作者:Zeor 时间:2016/7/24 12:03:55
        * 文件名:MemCachedHelper
        * 版本:V1.0.1
        *
        * 修改者: 时间:
        * 修改说明:
        * ========================================================================
        */
        #endregion
        namespace Zeor.MVCDemo.Common.Cache
        {
        public class MemCachedHelper
        {
            private static MemcachedClient MemClient;
            static readonly object padlock = new object();
    
            //线程安全的单例模式
            public static MemcachedClient getInstance()
            {
                if (MemClient == null)
                {
                    lock (padlock)
                    {
                        if (MemClient == null)
                        {
                            MemClientInit();
                        }
                    }
                }
                return MemClient;
            }
    
            static void MemClientInit()
            {
                try
                {
                    MemClient = new MemcachedClient();
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }
    
            /// <summary>
            /// 插入指定值
            /// </summary>
            /// <param name="key">缓存名称 </param>
            /// <param name="value">缓存值</param>
            /// <param name="minutes">过期时间(分钟),默认一个礼拜</param>
            /// <returns>返回是否成功</returns>
            public bool Insert(string key, string value,int minutes=10080) {
                MemcachedClient mc = getInstance();
                var data = mc.Get(key);
    
                DateTime dateTime =DateTime.Now.AddMinutes(1);
                if (data == null)
                    return mc.Store(StoreMode.Add, key, value, dateTime);
                else
                    return mc.Store(StoreMode.Replace, key, value, dateTime);
            }
    
            /// <summary>
            /// 获取缓存值
            /// </summary>
            /// <param name="key"></param>
            /// <returns></returns>
            public object Get(string key)
            {
                MemcachedClient mc = getInstance();
                return mc.Get(key);
            }
    
            /// <summary>
            /// 删除指定缓存
            /// </summary>
            /// <param name="key"></param>
            /// <returns></returns>
            public bool Remove(string key) {
                MemcachedClient mc = getInstance();
                
                return mc.Remove(key);
            }
    
            /// <summary>
            /// 清空缓存服务器上的缓存
            /// </summary>
            public void FlushCache() {
                MemcachedClient mc = getInstance();
    
                mc.FlushAll();
            }
        }
        
        }
    

    ** 获取Memcached缓存 **

        MemCachedHelper memcacheHelper = new  MemCachedHelper();  
        var obj=memcacheHelper.Get(key));
    

    ** 设置Memcached缓存 **

        MemCachedHelper memcacheHelper = new  MemCachedHelper();
        memcacheHelper.Insert(key,value,minutes));
    

    相关文章

      网友评论

        本文标题:.Net下基于EnyimMemcached封装Memcached

        本文链接:https://www.haomeiwen.com/subject/vhmlsttx.html