C#操作Memcached

要在nuget里引用（安装） EnyimMemcached ,下面是以调用阿里云的ocs(memcached)服务为例

using System;

using Enyim.Caching;

namespace MemcacheTest

{

///

/// MemcachedClient 帮组类 对外提供接口方法

    ///

public class MemcachedHelper    {      

///      

/// 定义一个静态MemcachedClient客户端,它随类一起加载，所有对象共用

        ///

private static MemcachedClient mclient;      

///      

/// 静态构造函数，初始化Memcached客户端

        ///

static MemcachedHelper()    

  {           

mclient = MemCached.getInstance();       

}      

///     

  /// 向Memcached缓存中添加一条数据

     ///

///返回是否添加成功

public static bool SetValue(string groupName,string key, object value, DateTime expiry)       

{          

key = groupName + &＃8220;-&＃8221; + key;           

return mclient.Store(Enyim.Caching.Memcached.StoreMode.Set,key, value, expiry);     

  }       

///     

  /// 向Memcached缓存中添加一条数据 默认超时24小时 

////

public static bool SetValue(string groupName, string key, object value)      

{          

key = groupName + &＃8220;-&＃8221; + key;           

eturn mclient.Store(Enyim.Caching.Memcached.StoreMode.Set, key, value, DateTime.Now.AddHours(24));      

}       

///      

/// 通过key 来得到一个对象

   ///

public static object GetValue(string groupName, string key)    

  {           

key = groupName + &＃8220;-&＃8221; + key;      

    return mclient.Get(key);       

}      

///      

/// 通过key 来得到一个对象(前类型)

    ///

public static T GetValue(string groupName, string key)   

    {          

key = groupName + &＃8220;-&＃8221; + key;     

      return mclient.Get(key);     

  }       

///       

/// 清除指定key的cache

///

public static bool Remove(string groupName, string key)     

  {          

key = groupName + &＃8220;-&＃8221; + key;         

  return mclient.Remove(key);     

  }      

///     

  /// 清除所有cache

       ///

public static void RemoveAll()    

  {       

    mclient.FlushAll();     

  }

  }

}

usingSystem.Net;

usingEnyim.Caching;

usingEnyim.Caching.Configuration;

usingEnyim.Caching.Memcached;

namespaceMemcacheTest

{

///

///MemcachedClient 配置类

///

publicsealedclassMemCached

    {

privatestaticMemcachedClient MemClient;

staticreadOnlyobjectpadlock=newobject();

//线程安全的单例模式

publicstaticMemcachedClientgetInstance()

        {

if(MemClient ==null)

            {

lock(padlock)

                {

if(MemClient ==null)

                    {

                        MemClientInit();

                    }

                }

            }

returnMemClient;

        }

staticvoidMemClientInit()

        {

//初始化缓存

MemcachedClientConfiguration memCOnfig=newMemcachedClientConfiguration();

IPAddress newaddress = IPAddress.Parse(Dns.GetHostEntry(&＃8220;XXXXXXXXXX.m.cnhzalicm10pub001.ocs.aliyuncs.com&＃8221;).AddressList[0].ToString());//xxxx替换为ocs控制台上的“内网地址”

IPEndPoint ipEndPoint =newIPEndPoint(newaddress,11211);// 配置文件 &＃8211; ip

            memConfig.Servers.Add(ipEndPoint);// 配置文件 &＃8211; 协议

            memConfig.Protocol = MemcachedProtocol.Binary;

// 配置文件-权限，如果使用了免密码功能，则无需设置userName和password

memConfig.Authentication.Type =typeof(PlainTextAuthenticator);

memConfig.Authentication.Parameters[&＃8220;zone&＃8221;] =&＃8221;&＃8221;;

memConfig.Authentication.Parameters[&＃8220;userName&＃8221;] =&＃8221;XXXXXXXXXXXXXXXXX&＃8221;;

memConfig.Authentication.Parameters[&＃8220;password&＃8221;] =&＃8221;XXXXXXXXXX&＃8221;;

//下面请根据实例的最大连接数进行设置

memConfig.SocketPool.MinPoolSize =5;

memConfig.SocketPool.MaxPoolSize =200;

MemClient =newMemcachedClient(memConfig);

        }

    }

}

程序调用

MemcachedHelper.SetValue(groupName,strKey, strValue, DateTime.Now.AddMinutes(5));

varrestr = MemcachedHelper.GetValue(groupName,strKey);

varobj = MemcachedHelper.GetValue(groupName,&＃8221;p001&＃8243;);

来源：https://blog.csdn.net/huwei2003/article/details/48897035