聊聊Memcached的应用
是一缓存,能够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; } }
就这些吧。
心怀远大理想。
为了家庭幸福而努力。
创建全局SystemTray.ProgressIndicator
当处理耗时任务时,我们自然要给个进度指示器让用户看到应用正在做事呢,不然用户就会想到底好没好啊,死了?。所以我们一定要有进度指示器,这样才是一个正常的用户体验
。而创建进度指示器的最简单方法就是使用系统托盘里的ProgressIndicator,不过系统托盘和页面是挂钩的,要是用户这时转入其它页面,那ProgressIndicator就没了啊,用户就看不到进度了
。所以不管用户做了什么事,ProgressIndicator都要显示出来,就是要做个全局的ProgressIndicator。于是网上搜索一番,找到了个代码,思路是这样的:写一个类,保存ProgressIndicator的相关数据,订阅Frame的Navigating和Navigated,监视页面切换。对移入的页面,利用保存的数据创建一个ProgressIndicator显示出来,对移出的页面,隐藏ProgressIndicator。不过后来想了想,能不能用绑定来实现呢?于是试了一下,果真可以。
下面是相关代码:
using System; using System.ComponentModel; namespace *.ViewModels { public class ProgressIndicatorViewModel : INotifyPropertyChanged { private Boolean isVisible; private String text; private Boolean isIndeterminate; private Double value; /// <summary> /// 获取或设置 是否显示ProgressIndicator。 /// </summary> public Boolean IsVisible { get { return isVisible; } set { if (isVisible != value) { isVisible = value; NotifyPropertyChanged("IsVisible"); } } } /// <summary> /// 获取或设置 显示的文字。 /// </summary> public String Text { get { return text; } set { if (text != value) { text = value; NotifyPropertyChanged("Text"); } } } /// <summary> /// 获取或设置 进度指示器是不确定的还是确定的。 /// </summary> public Boolean IsIndeterminate { get { return isIndeterminate; } set { if (isIndeterminate != value) { isIndeterminate = value; NotifyPropertyChanged("IsIndeterminate"); } } } /// <summary> /// 获取或设置 进度(0-1)。 /// </summary> public Double Value { get { return value; } set { if (this.value != value) { this.value = value; NotifyPropertyChanged("Value"); } } } public ProgressIndicatorViewModel() { isVisible = false; text = String.Empty; isIndeterminate = false; value = 0; } public event PropertyChangedEventHandler PropertyChanged; private void NotifyPropertyChanged(String propertyName) { if (null != PropertyChanged) PropertyChanged(this, new PropertyChangedEventArgs(propertyName)); } } }
<phone:PhoneApplicationPage shell:SystemTray.Opacity="0" shell:SystemTray.IsVisible="{Binding IsVisible}"> <shell:SystemTray.ProgressIndicator> <shell:ProgressIndicator IsVisible="{Binding IsVisible}" Text="{Binding Text}" IsIndeterminate="{Binding IsIndeterminate}" Value="{Binding Value}"/> </shell:SystemTray.ProgressIndicator> <Grid> </Grid> </phone:PhoneApplicationPage>