你的位置:首页 > 数据库

[数据库]asp.net mvc 用Redis实现分布式集群共享Session。


1、这两天研究Redis搞分布式session问题,网上找的资料都是用ServiceStack.Redis来实现的,但是在做性能测试的时候发现最新的v4版本有限制每小时候最多请求6000次,因为官网开始商业化要收费了,好坑爹的说,还好我前期弄了个性能测试列子,不然上线以后出问题那就麻烦了。后面找了个NServiceKit.Redis(好像就是ServiceStack.Redis的v3版本)来替代v4的收费版。

2、解决方案是 Redis+cookie方式实现记录用户登录状态

     cookie:存放用户的ID,这个ID是经过加密的,并且后台可以通过密钥解密。

     Redis:key/value 方式存储,key存放比如:user_1。  value存放用户实体对象。

3、先安装一个Redis,windows的版本在本地进行测试,后期上线更换linux系统的Redis替换一下ip就可以了。

4、添加一个Session管理类

public class SessionHelper  {    private const int secondsTimeOut = 60 * 20; //默认过期时间20分钟 单位秒    public RedisHelper Redis = new RedisHelper(false);    public LoginUserInfo this[string key]    {      get      {        string webCookie = WebHelper.GetCookie(key);        if (webCookie == "")        {          return null;        }        key = key + "_" + SecureHelper.AESDecrypt(webCookie);        //距离过期时间还有多少秒        long l = Redis.TTL(key);        if (l >= 0)        {          Redis.Expire(key, secondsTimeOut);        }                return Redis.Get<LoginUserInfo>(key);      }      set      {        SetSession(key, value);      }    }    public void SetSession(string key, LoginUserInfo value)    {      if (string.IsNullOrWhiteSpace(key))      {        throw new Exception("Key is Null or Epmty");      }      WebHelper.SetCookie(key, SecureHelper.AESEncrypt(value.ID.ToString()));      key = key + "_" + value.ID;      Redis.Set<LoginUserInfo>(key, value, secondsTimeOut);    }    /// <summary>    /// 移除Session    /// </summary>    /// <param name="key"></param>    /// <returns></returns>    public bool Remove(string key)    {      var rs = Redis.Remove(key + "_" + SecureHelper.AESDecrypt(WebHelper.GetCookie(key)));      WebHelper.DeleteCookie(key);      return rs;    }         }

5、Redis操作类

public class RedisHelper : IDisposable  {    private RedisClient Redis = new RedisClient("127.0.0.1", 6379);    //缓存池    PooledRedisClientManager prcm = new PooledRedisClientManager();    //默认缓存过期时间单位秒    public int secondsTimeOut = 20 * 60;    /// <summary>    /// 缓冲池    /// </summary>    /// <param name="readWriteHosts"></param>    /// <param name="readOnlyHosts"></param>    /// <returns></returns>    public static PooledRedisClientManager CreateManager(string[] readWriteHosts, string[] readOnlyHosts)    {      return new PooledRedisClientManager(readWriteHosts, readOnlyHosts,        new RedisClientManagerConfig        {          MaxWritePoolSize = readWriteHosts.Length * 5,          MaxReadPoolSize = readOnlyHosts.Length * 5,          AutoStart = true,        });     }    /// <summary>    /// 构造函数    /// </summary>    /// <param name="OpenPooledRedis">是否开启缓冲池</param>    public RedisHelper(bool OpenPooledRedis = false)    {      if (OpenPooledRedis)      {        prcm = CreateManager(new string[] { "127.0.0.1:6379" }, new string[] { "127.0.0.1:6379" });        Redis = prcm.GetClient() as RedisClient;      }    }    /// <summary>    /// 距离过期时间还有多少秒    /// </summary>    /// <param name="key"></param>    /// <returns></returns>    public long TTL(string key)    {      return Redis.Ttl(key);    }    /// <summary>    /// 设置过期时间    /// </summary>    /// <param name="key"></param>    /// <param name="timeout"></param>    public void Expire(string key,int timeout = 0)    {      if (timeout >= 0)      {        if (timeout > 0)        {          secondsTimeOut = timeout;        }        Redis.Expire(key, secondsTimeOut);      }    }    #region Key/Value存储    /// <summary>    /// 设置缓存    /// </summary>    /// <typeparam name="T"></typeparam>    /// <param name="key">缓存建</param>    /// <param name="t">缓存值</param>    /// <param name="timeout">过期时间,单位秒,-1:不过期,0:默认过期时间</param>    /// <returns></returns>    public bool Set<T>(string key, T t, int timeout = 0)    {      Redis.Set<T>(key, t);      if (timeout >= 0)      {        if (timeout > 0)        {          secondsTimeOut = timeout;        }        Redis.Expire(key, secondsTimeOut);      }      return true;          }    /// <summary>    /// 获取    /// </summary>    /// <typeparam name="T"></typeparam>    /// <param name="key"></param>    /// <returns></returns>    public T Get<T>(string key)    {      return Redis.Get<T>(key);    }    /// <summary>    /// 删除    /// </summary>    /// <param name="key"></param>    /// <returns></returns>    public bool Remove(string key)    {      return Redis.Remove(key);    }    #endregion    //释放资源    public void Dispose()    {      if (Redis != null)      {        Redis.Dispose();        Redis = null;      }      GC.Collect();    }  }