聊聊Memcached的应用

ibaobei

　　是一缓存，能够Set, Get value，哈哈，普通用法如下：



public User GetUser(int userId)
{
UserInfo user = cacheService.Get("UserInfo:" + userId) as UserInfo;//cacheService是自定义的接口，具体的memcache实现代码被隔离了
if (user == null)
{
user = dao.GetUser(userId);
cacheService.Set("UserInfo:" + userId, user);
}
return user;
}
　　在真正使用Memcached之前，需要先初始化它，如下：



string[] serverlist = { "192.168.1.11:11211", "192.168.1.12:11211", "192.168.1.13:11211" };//服务器可以是多个  
//初始化池  
SockIOPool pool = SockIOPool.GetInstance();
pool.SetServers(serverlist);//设置连接池可用的cache服务器列表，server的构成形式是IP:PORT（如：127.0.0.1:11211）  
pool.InitConnections = 3;//初始连接数  
pool.MinConnections = 3;//最小连接数  
pool.MaxConnections = 5;//最大连接数  
pool.SocketConnectTimeout = 1000;//设置连接的套接字超时  
pool.SocketTimeout = 3000;//设置套接字超时读取  
pool.MaintenanceSleep = 30;//设置维护线程运行的睡眠时间。如果设置为0，那么维护线程将不会启动,30就是每隔30秒醒来一次  
//获取或设置池的故障标志。  
//如果这个标志被设置为true则socket连接失败，将试图从另一台服务器返回一个套接字如果存在的话。  
//如果设置为false，则得到一个套接字如果存在的话。否则返回NULL，如果它无法连接到请求的服务器。  
pool.Failover = true;
pool.Nagle = false;//如果为false，对所有创建的套接字关闭Nagle的算法  
pool.Initialize();
　　MemcachedProvider代码：



public class MemcachedProvider : ICache
{
private MemcachedClient mc = new MemcachedClient();
public void Set(string key, object o)
{
mc.Set(key, o);
}
public object Get(string key)
{
return mc.Get(key);
}
}
　　
　　用法很简单，下面说说它的一些限制：

• 每个key最多<=250长度
  
• 每个value最大<=1M（如果超过1M，则在C#端自己分解搞定）
  
• 没有冗余机制，既：当某一台memcached服务器down掉后，数据就丢失了，不会自动平衡数据
  

　　示例的UML图：

　　缓存的数据是通过hash后来分布到各台Memcache Server的，因此，假设每台Memcached Server都分别分配到4G内存的话，那我们的C#程序就能够用到12G内存。这个说法其实不准确，能否用足这12G的内存，完全看MemcacheClient端的分布key的算法（上图中左边接口部分），等以后再深入研究这个算法。

下面来说说当某台memcached server down掉后的解决办法（共3种解决方法）：

• 
  用热备节点
  
• 
  从配置文件里去掉那台失效的memcached server的ip
  
• 
  增加一台Backup Memcached Server
  

　　
　　一、用热备节点
　　程序端不改变任何东西
　　当发现某memcached server down机后，启动一台新memcached server，并且把新memcached server的IP修改为down机的IP（down掉的那台不要拿单独修复）
　　这个办法不利的地方是：在down掉和上线期间，缓存是没有的，会throw exception，需要程序捕获，并且当成null值来处理，会增加数据库的压力
　　
　　二、从配置文件里去掉那台失效的memcached server的ip
　　那就是修改配置文件了，然后再把down掉的server慢慢修复，等修复后再修改配置文件...
　　非常不好，光修改配置文件就要导致application reset了。不过当资源有限时，也只能这样了。
　　
　　三、增加一台Backup Memcached Server
　　物理节点图如下：

　　C#端：由原先的一个MemcachedClient客户端变成了"MemcachedClient"和"BackupMemcachedClient"共同存在
　　Memcached server服务器端：增加一台Backup Memcached Server,这台server性能和内存都要高于其他三台memcached server的配置，这台server将保存所有的cache，因此性能要求高，尤其是网络和内存。
　　先初始化这2个pool：



string[] serverlist = { "192.168.1.11:11211", "192.168.1.12:11211", "192.168.1.13:11211" };//普通Memcached服务器  
//初始化池  
SockIOPool pool = SockIOPool.GetInstance("NormalServers");                     //设置PoolName
pool.SetServers(serverlist);//设置连接池可用的cache服务器列表，server的构成形式是IP:PORT（如：127.0.0.1:11211）  
pool.InitConnections = 3;//初始连接数  
pool.MinConnections = 3;//最小连接数  
pool.MaxConnections = 5;//最大连接数  
pool.SocketConnectTimeout = 1000;//设置连接的套接字超时  
pool.SocketTimeout = 3000;//设置套接字超时读取  
pool.MaintenanceSleep = 30;//设置维护线程运行的睡眠时间。如果设置为0，那么维护线程将不会启动,30就是每隔30秒醒来一次  
//获取或设置池的故障标志。  
//如果这个标志被设置为true则socket连接失败，将试图从另一台服务器返回一个套接字如果存在的话。  
//如果设置为false，则得到一个套接字如果存在的话。否则返回NULL，如果它无法连接到请求的服务器。  
pool.Failover = true;
pool.Nagle = false;//如果为false，对所有创建的套接字关闭Nagle的算法  
            pool.Initialize();

string[] backupServerlist = { "192.168.1.14:11211"};                         //Backup服务器
//初始化池  
SockIOPool backupPool = SockIOPool.GetInstance("BackupServers");             //设置PoolName
backupPool.SetServers(backupServerlist);//设置连接池可用的cache服务器列表，server的构成形式是IP:PORT（如：127.0.0.1:11211）  
backupPool.InitConnections = 3;//初始连接数  
backupPool.MinConnections = 3;//最小连接数  
backupPool.MaxConnections = 5;//最大连接数  
backupPool.SocketConnectTimeout = 1000;//设置连接的套接字超时  
backupPool.SocketTimeout = 3000;//设置套接字超时读取  
backupPool.MaintenanceSleep = 30;//设置维护线程运行的睡眠时间。如果设置为0，那么维护线程将不会启动,30就是每隔30秒醒来一次  
//获取或设置池的故障标志。  
//如果这个标志被设置为true则socket连接失败，将试图从另一台服务器返回一个套接字如果存在的话。  
//如果设置为false，则得到一个套接字如果存在的话。否则返回NULL，如果它无法连接到请求的服务器。  
backupPool.Failover = true;
backupPool.Nagle = false;//如果为false，对所有创建的套接字关闭Nagle的算法  
backupPool.Initialize();
　　
　　MemcachedProvider改为：



public class MemcachedProvider : ICache
{
private static MemcachedClient GetNormalServerClient()
{
MemcachedClient mc = new MemcachedClient();
mc.PoolName = "NormalServers";
return mc;
}
private static MemcachedClient GetBackupServerClient()
{
MemcachedClient mc = new MemcachedClient();
mc.PoolName = "BackupServers";
return mc;
}
public void Set(string key, object o)
{
try
{
GetNormalServerClient().Set(key, o);
GetBackupServerClient().Set(key, o);       //这个看情况改为异步执行
}
catch
{
//notify or log
            }
}
public object Get(string key)
{
object o=null;
try
{
o = GetNormalServerClient().Get(key);
}
catch
{
//notify or log
            }
if (o != null)
return o;
try
{
o = GetBackupServerClient().Get(key);
}
catch
{
//notify or log
            }
return o;
}
}
　　就这些吧。