源代码:https://git.oschina.net/zhaord/CacheDemo.git(dev_redis 分支)
前提:已安装并运行redis服务器
redis 缓存
通过 《C# 缓存》 可以了解到，缓存其实，就是一系列的 key-value，而 redis 是典型的key-value数据库之一，那么，我们是不是可以借助 redis来实现缓存呢?答案是肯定的!
实现
代码是在 《C# 缓存》基础上修改的，代码分支为:dev_redis。
在 《C# 缓存》中，是用C#自带的类库实现的缓存，那么，我们只要继承自 cachebase,并重写相关方法，就可以实现使用redis作为缓存服务器，在实现之前，我们先约定key值为 “n:name,c:key”来作为redis的key值，启用name为自定义的，因为可能不同的分层会使用不同的name名称，key就是需要保存的缓存项的key，代码如下
protected virtual string GetLocalizedKey(string key)
{
return "n:" + "RandomRedis" + ",c:" + key;
}
redis中保存的value值，格式是 "类名,程序集名 | 序列化后的值" 作为value的保存格式，具体实现代码如下
protected virtual string Serialize(object value, Type type)
{
var serialized = JsonConvert.SerializeObject(value);
return string.Format(
"{0}{1}{2}",
type.AssemblyQualifiedName,
TypeSeperator,
serialized
);
}
既然，我们针对保存的值进行了格式约定，那么久需要解析约定，解析代码如下
protected virtual object Deserialize(RedisValue objbyte)
{
var serializedObj = objbyte.ToString();
var typeSeperatorIndex = serializedObj.IndexOf(TypeSeperator);
var type = Type.GetType(serializedObj.Substring(0, typeSeperatorIndex));
var serialized = serializedObj.Substring(typeSeperatorIndex + 1);
return JsonConvert.DeserializeObject(serialized, type);
}
通过以上两个函数，我们可以显示取值和设置值得函数，如下
public override object GetOrDefault(string key)
{
var objbyte = this._database.StringGet(this.GetLocalizedKey(key));
return objbyte.HasValue ? this.Deserialize(objbyte) : null;
}
public override void Set(string key, object value, TimeSpan? slidingExpireTime = null, TimeSpan? absoluteExpireTime = null)
{
if (value == null)
{
throw new Exception("不可以插入null到缓存!");
}
var type = value.GetType();
// 以string类型保存缓存值
this._database.StringSet(
this.GetLocalizedKey(key),
this.Serialize(value, type),
absoluteExpireTime ?? slidingExpireTime ?? TimeSpan.FromSeconds(60)
);
}
那么整个缓存实现的代码如下
public class RedisCache
:CacheBase
{
private readonly IDatabase _database;
private ConnectionMultiplexer redisClient = ConnectionMultiplexer.Connect("localhost");
private const char TypeSeperator = '|';
public RedisCache()
{
this._database = this.redisClient.GetDatabase();
}
public override object GetOrDefault(string key)
{
var objbyte = this._database.StringGet(this.GetLocalizedKey(key));
return objbyte.HasValue ? this.Deserialize(objbyte) : null;
}
public override void Set(string key, object value, TimeSpan? slidingExpireTime = null, TimeSpan? absoluteExpireTime = null)
{
if (value == null)
{
throw new Exception("不可以插入null到缓存!");
}
var type = value.GetType();
// 以string类型保存缓存值
this._database.StringSet(
this.GetLocalizedKey(key),
this.Serialize(value, type),
absoluteExpireTime ?? slidingExpireTime ?? TimeSpan.FromSeconds(60)
);
}
public override void Remove(string key)
{
this._database.KeyDelete(this.GetLocalizedKey(key));
}
public override void Clear()
{
this._database.KeyDeleteWithPrefix(this.GetLocalizedKey("*"));
}
protected virtual object Deserialize(RedisValue objbyte)
{
var serializedObj = objbyte.ToString();
var typeSeperatorIndex = serializedObj.IndexOf(TypeSeperator);
var type = Type.GetType(serializedObj.Substring(0, typeSeperatorIndex));
var serialized = serializedObj.Substring(typeSeperatorIndex + 1);
return JsonConvert.DeserializeObject(serialized, type);
}
protected virtual string Serialize(object value, Type type)
{
var serialized = JsonConvert.SerializeObject(value);
return string.Format(
"{0}{1}{2}",
type.AssemblyQualifiedName,
TypeSeperator,
serialized
);
}
protected virtual string GetLocalizedKey(string key)
{
return "n:" + "RandomRedis" + ",c:" + key;
}
}
代码大部分实现，是和democache类想通，只不过，democache通过封装memory实现缓存保存，而 类 RedisCache 封装 redis客户端，作为缓存 容器!
使用缓存
在《C# 缓存》 已经写好了测试过程，我们只需要将代码ICache cache = new DemoCache(); 替换为 ICache cache = new RedisCache();即可使用新的缓存实现方式。
运行结果
具体的运行结果如下
和 《C# 缓存》 中运行期望一直，说明我们已经成功使用redis来作为缓存容器了!
总结
通过上述描述，我们就可以借助redis来实现缓存容器了。
本片文章和《C# 缓存》中使用了大量ABP的代码。
qq:1260825783
转载备注:http://www.jianshu.com/p/f5f2a5e7ec1c
