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 = * ; //默认过期时间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 >= )
{
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", );
//缓存池
PooledRedisClientManager prcm = new PooledRedisClientManager(); //默认缓存过期时间单位秒
public int secondsTimeOut = * ; /// <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 * ,
MaxReadPoolSize = readOnlyHosts.Length * ,
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 = )
{
if (timeout >= )
{
if (timeout > )
{
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 = )
{
Redis.Set<T>(key, t);
if (timeout >= )
{
if (timeout > )
{
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(); }
}