memcached安装及.NET中的Memcached.ClientLibrary使用详解

序言

吹吹牛逼先，借我你的20分钟，保证你在.net中使用memcached缓存数据，畅通无阻，提高数据读取效率，分担数据库压力，便不在话下。

本篇主要说下：memcached分布式缓存的负载均衡配置比例，数据压缩，socket的详细配置等，以及在.net中的经常使用方法。

memcached是什么，作什么的，为何要使用它，本篇不作介绍，建议百度百科，我看拉下，那里比我还能吹牛逼，哈哈，上料。

memcached在windows下的下载与安装

下载地址：http://pan.baidu.com/s/1yVILw       提取密码：5gx9

官方网站：http://memcached.org/

下载完成后

一、打开SetupFile安装文件夹。

     

二、打开cmd命令界面。           不要忘啦去windows服务中把服务启动了。

三、 以上的安装和启动都是在默认环境下进行的，在安装时可设置以下参数： 

-p 监听的端口 
-l 链接的IP地址, 默认是本机 
-d start 启动memcached服务 
-d restart 重起memcached服务 
-d stop|shutdown 关闭正在运行的memcached服务 
-d install 安装memcached服务 
-d uninstall 卸载memcached服务 
-u 以的身份运行 (仅在以root运行的时候有效) 
-m 最大内存使用，单位MB。默认64MB 
-M 内存耗尽时返回错误，而不是删除项 
-c 最大同时链接数，默认是1024 
-f 块大小增加因子，默认是1.25 
-n 最小分配空间，key+value+flags默认是48 
-h 显示帮助

四、对这样你就安装好啦。下面看咱们怎么用c#语言操做memcached啦。

五、telnet   add 0 1 zlh  0：时间（秒，0表明永远），1：字节数 ，zlh：value ，flush_all 清空全部数据。

先把memcached用起来

一、下载客户端的3个dll，ICSharpCode.SharpZipLib.dll，log4net.dll，Memcached.ClientLibrary.dll

二、跟着我新建一个简单控制台应用程序

 class AMemcached
    {
        public static MemcachedClient cache;
        static AMemcached()
        {
            string[] servers = { "172.18.5.66:11211" };
            //初始化池
            SockIOPool pool = SockIOPool.GetInstance();
            //设置服务器列表
            pool.SetServers(servers);
            //各服务器之间负载均衡的设置比例
            pool.SetWeights(new int[] { 1 });
            //初始化时建立链接数
            pool.InitConnections = 3;
            //最小链接数
            pool.MinConnections = 3;
            //最大链接数
            pool.MaxConnections = 5;
            //链接的最大空闲时间，下面设置为6个小时（单位ms），超过这个设置时间，链接会被释放掉
            pool.MaxIdle = 1000 * 60 * 60 * 6;
            //socket链接的超时时间，下面设置表示不超时（单位ms），即一直保持连接状态
            pool.SocketConnectTimeout = 0;
            //通信的超市时间，下面设置为3秒（单位ms），.Net版本没有实现
            pool.SocketTimeout = 1000 * 3;
            //维护线程的间隔激活时间，下面设置为30秒（单位s），设置为0时表示不启用维护线程
            pool.MaintenanceSleep = 30;
            //设置SocktIO池的故障标志
            pool.Failover = true;
            //是否对TCP/IP通信使用nalgle算法，.net版本没有实现
            pool.Nagle = false;
            //socket单次任务的最大时间（单位ms），超过这个时间socket会被强行中端掉，当前任务失败。
            pool.MaxBusy = 1000 * 10;
            pool.Initialize();
            cache = new MemcachedClient();
            //是否启用压缩数据：若是启用了压缩，数据压缩长于门槛的数据将被储存在压缩的形式
            cache.EnableCompression = false;
            //压缩设置，超过指定大小的都压缩 
            //cache.CompressionThreshold = 1024 * 1024;           
        }
    }
    class Program
    {
        static void Main(string[] args)
        {
            //存入key为a，value为123的一个缓存
            AMemcached.cache.Add("a", "123");
            //读出key为a的缓存值
            var s = AMemcached.cache.Get("a");
            //输出
            Console.WriteLine(s);
            Console.ReadKey();           
        }
    }

Note：首先告诉你一个好的消息，memcached就这么简单，你已经可以使用啦，若是感兴趣，那么在AMemcached.cache的后面加点，看看这个类库里面还有那些关于增删改查重载的好方法。若是你还想再进一步了解，那么继续往下看。

细品 .NET Memcached.ClientLibrary 

一、说说memcached分布式缓存的设置与应用

            string[] servers = { "172.18.5.66:11211", "192.168.10.121:11211" };
            //初始化池
            SockIOPool pool = SockIOPool.GetInstance();
            //设置服务器列表
            pool.SetServers(servers);
            //各服务器之间负载均衡的设置比例
            pool.SetWeights(new int[] { 1, 10 });

Note:

一、在172.18.5.66，与192.168.10.121两台机器上装memcached服务端。

二、 pool.SetWeights这里的1跟10意思是，负载均衡比例，假如11000条数据，大体数据分布为：172.18.5.66分布1000条数据左右。另一台为10000条左右。

三、memcached服务端并不具有负载均衡的能力，而是memcachedClient实现的，具体存取数据实现的核心是采用一致性Hash算法，把key-value分布到某一台服务器中里边。

二、说说memcached的数据压缩机制

            //是否启用压缩数据：若是启用了压缩，数据压缩长于门槛的数据将被储存在压缩的形式
            cache.EnableCompression = false;
            //压缩设置，超过指定大小的都压缩 
            //cache.CompressionThreshold = 1024 * 1024; 

Note：

一、这个处理是在MemcachedClient对象中，设置这个EnableCompression属性，是否使用压缩的意思，若是启用啦压缩功能 ,则ICSharpCode.SharpZipLib类库会在数据超过预设大小时，进行数据压缩处理。

二、CompressionThreshold这个属性是压缩的阀值，默认是15K，若是超过设定的阀值则使用memcached的通信协议，存数据时给每一个数据项分配一个16为的flag表示，用做记录是否有压缩，若是有压缩则提取数据是进行解压。若是没有超过阀值则不压缩，直接存储。

三、说说怎么使用客户端多个SocketIO池 

class AMemcached
    {
        public MemcachedClient cache;
        public  AMemcached(string poolName)
        {
            string[] servers = { "172.18.5.66:11211", "192.168.10.121:11211" };
            //初始化池
            SockIOPool pool = SockIOPool.GetInstance(poolName);
            //设置服务器列表
            pool.SetServers(servers);
            //各服务器之间负载均衡的设置比例
            pool.SetWeights(new int[] { 1, 10 });
            //初始化时建立链接数
            pool.InitConnections = 3;
            //最小链接数
            pool.MinConnections = 3;
            //最大链接数
            pool.MaxConnections = 5;
            //链接的最大空闲时间，下面设置为6个小时（单位ms），超过这个设置时间，链接会被释放掉
            pool.MaxIdle = 1000 * 60 * 60 * 6;
            //socket链接的超时时间，下面设置表示不超时（单位ms），即一直保持连接状态
            pool.SocketConnectTimeout = 0;
            //通信的超时时间，下面设置为3秒（单位ms），.Net版本没有实现
            pool.SocketTimeout = 1000 * 3;
            //维护线程的间隔激活时间，下面设置为30秒（单位s），设置为0时表示不启用维护线程
            pool.MaintenanceSleep = 30;
            //设置SocktIO池的故障标志
            pool.Failover = true;
            //是否对TCP/IP通信使用nalgle算法，.net版本没有实现
            pool.Nagle = false;
            //socket单次任务的最大时间（单位ms），超过这个时间socket会被强行中端掉，当前任务失败。
            pool.MaxBusy = 1000 * 10;
            // 初始化一些值并与MemcachedServer段创建链接
            pool.Initialize();
            cache = new MemcachedClient();
            //是否启用压缩数据：若是启用了压缩，数据压缩长于门槛的数据将被储存在压缩的形式
            cache.EnableCompression = false;
            //压缩设置，超过指定大小的都压缩 
            //cache.CompressionThreshold = 1024 * 1024;   
            //指定客户端访问的SockIO池
            cache.PoolName = poolName;
        }


    }
    class Program
    {
        static void Main(string[] args)
        {
            //存入key为a，value为123的一个缓存
            new AMemcached("me").cache.Add("b", 123);
            //读出key为a的缓存值
            var s = new AMemcached("me").cache.Get("b");
            //输出
            Console.WriteLine(s);
            Console.ReadKey();           
        }
    }

View Code

Note:使用SocketIoPool的场景，假如你的系统中用到A，B两台机器memcached的缓存数据，而A，B是不相关的，没有数据互通共享，那么这个时候你就能够根据设置poolName来处理读写那台机器。而不用多处，重复配置客户端的各类参数。

四、说说memcached的故障转移处理 

           //设置SocktIO池的故障标志
            pool.Failover = true;

Note：memcached的鼓掌转移是一套正常节点发生故障变为死节点时的处理机制。

一、开启故障转移：若是发生socket异常，则该节点被添加到存放死节点属性的_hostDead中，新请求被映射到dead server，检测尝试链接死节点的时间间隔属性_hostDeadDuration（默认设置为100ms），若是没有达到设定的间隔时间则key会被映射到可用的server处理，若是达到了时间间隔，则尝试从新连接，链接成功将此节点从_hostDead中去除，链接失败则间隔时间翻倍存放，下次从新链接时间会被拉长。

二、不开启故障转移：新的请求都会被映射到dead server上，尝试从新创建socket连接，若是链接失败，返回null或者操做失败。

五、说说key-value中的key与value

一、key在服务端的长度限制为250个字符，建议使用较短的key但不要重复。

二、value的大小限制为1mb，若是大拉，可使用压缩，若是还大，那可能拆分到多个key中。