MVC使用Memcache+Cookie解决分布式系统共享登录状态学习笔记6

      为了解决单机处理的瓶颈，增强软件的可用性，我们需要将软件部署在多台服务器上启用多个二级子域名以频道化的方式，根据业务功能将网站分布部署在独立的服务器上，或通过负载均衡技术（如：dns轮询、radware、f5、lvs等）让多个频道共享一组服务器。当我们将网站程序分部到多台服务器上后，由于session受实现原理的局限，无法跨服务器同步更新session，使得登录状态难以通过session共享。

      我们使用memcache+cookie方案来解决分布式系统共享登录状态的问题。

      memcache服务器本身就是一个socket服务端，内部数据采用键值对的形式存储在服务器的内存中，本质就是一个大型的哈希表。数据的删除采用惰性删除机制。虽然memcache并没有提供集群功能，但是通过客户端的驱动程序很容易就可以实现memcache的集群配置。

     先简单介绍一下memcache的用法

1. 下载安装memcache（windows平台）

    （1）将程序解压到磁盘任意位置

    （2）进入cmd窗口，运行memcached.exe -d install安装服务，安装后打开服务窗口查看服务是否安装成功。

    （3）直接在服务管理中启动服务，或者使用cmd命令 net start "memcache server"

    （4）使用telnet连接到memcache控制台，验证服务是否正常 telnet 127.0.0.1 11211

            使用stats指令查看当前memcache服务器状态

2. 程序中的用法

    （1）在程序中添加 memcached.clientlibrary.dll 的引用

    （2）c#中操作memcache的代码示例

string[] serverlist = { "192.168.1.100:11211",
"192.168.1.101:11211" };
// initialize the pool for memcache servers
sockiopool pool = sockiopool.getinstance("test");
pool.setservers(serverlist);
pool.initialize();
mc = new memcacheclient();
mc.poolname = "test";
mc.enablecompression = false;
pool.shutdown();//关闭连接池

下面我们做方案的具体实现

1. 首先在common层中引入memcached.clientlibrary.dll，并封装memcache的帮助类，memcachehelper

using memcached.clientlibrary;
using system;

namespace pms.common
{
 public class memcachehelper
 {
 private static readonly memcachedclient mc = null;

 static memcachehelper()
 {
 //最好放在配置文件中
 string[] serverlist = { "127.0.0.1:11211", "10.0.0.132:11211" };

 //初始化池
 var pool = sockiopool.getinstance();
 pool.setservers(serverlist);

 pool.initconnections = 3;
 pool.minconnections = 3;
 pool.maxconnections = 5;

 pool.socketconnecttimeout = 1000;
 pool.sockettimeout = 3000;

 pool.maintenancesleep = 30;
 pool.failover = true;

 pool.nagle = false;
 pool.initialize();

 // 获得客户端实例
 mc = new memcachedclient {enablecompression = false};
 }
 /// <summary>
 /// 存储数据
 /// </summary>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 public static bool set(string key,object value)
 {
 return mc.set(key, value);
 }
 public static bool set(string key, object value,datetime time)
 {
 return mc.set(key, value,time);
 }
 /// <summary>
 /// 获取数据
 /// </summary>
 /// <param name="key"></param>
 /// <returns></returns>
 public static object get(string key)
 {
 return mc.get(key);
 }
 /// <summary>
 /// 删除
 /// </summary>
 /// <param name="key"></param>
 /// <returns></returns>
 public static bool delete(string key)
 {
 return mc.keyexists(key) && mc.delete(key);
 }
 }
}

2. 改变用户登录方法userlogin，用户登录成功后生成guid，将此guid存入cookie并以guid为键将登录用户信息序列化存入memcache服务器。

public actionresult userlogin()
{
 #region 验证码校验
 var validatecode = session["validatecode"] != null ? session["validatecode"].tostring() : string.empty;
 if (string.isnullorempty(validatecode))
 return content("no:验证码错误!!");
 session["validatecode"] = null;
 var txtcode = request["validatecode"];
 if (!validatecode.equals(txtcode, stringcomparison.invariantcultureignorecase))
 return content("no:验证码错误!!");
 #endregion

 var username = request["username"];
 var userpwd = request["password"];
 //查询用户是否存在
 var user = userservice.loadentities(u => u.username == username && u.password == userpwd).firstordefault();
 if (user == null) return content("no:登录失败");

 //产生一个guid值作为memache的键.
 var sessionid = guid.newguid().tostring();
 //将登录用户信息存储到memcache中。
 memcachehelper.set(sessionid, serializehelper.serializetostring(user), datetime.now.addminutes(20));
 //将memcache的key以cookie的形式返回给浏览器。
 response.cookies["sessionid"].value = sessionid;
 return content("ok:登录成功");
}

3. 改变登录校验控制器filtercontroller的onactionexecuting方法，使其校验方式改为从memcache服务器中读取cookie中值为键的对象：

protected override void onactionexecuting(actionexecutingcontext filtercontext)
{
 base.onactionexecuting(filtercontext);
 //if (session["user"] == null)
 if (request.cookies["sessionid"] != null)
 {
 var sessionid = request.cookies["sessionid"].value;
 //根据该值查memcache.
 var obj = memcachehelper.get(sessionid);
 if (obj == null)
 {
 filtercontext.result = redirect("/login/index");
 return;
 }
 var user = serializehelper.deserializetoobject<user>(obj.tostring());
 loginuser = user;
 //模拟出滑动过期时间.
 memcachehelper.set(sessionid, obj, datetime.now.addminutes(20)); 
 }
 else
 filtercontext.result = redirect("/login/index");
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。