下面来正式分享今天的文章吧:
。搭建Redis服务端,并用客户端连接
。封装缓存父类,定义Get,Set等常用方法
。定义RedisCache缓存类,执行Redis的Get,Set方法
。构造出缓存工厂调用方法
下面一步一个脚印的来分享:
。搭建Redis服务端,并用客户端连接
首先,咋们去这个地址下载安装文件https://github.com/dmajkic/redis/downloads,我这里的版本是:redis-2.4.5-win32-win64里面有32位和64位的执行文件,我这里服务器是64位的下面给出截图和用到部分程序的说明:

现在,咋们直接可以用鼠标双击redis-server.exe这个应用程序,这样就打开了redis服务窗体(您也可以下载一个windows服务承载器,把redis服务运行在windows的服务中,就不用担心每次关闭redis服务黑色窗体后无法访问redis了),运行起来是这样:

有红色框的信息就表示成功了,这里redis服务监听的端口默认是6379,要修改端口或者更多的配置信息请找到redis.conf配置文件,具体配置信息介绍可以来这里http://www.shouce.ren/api/view/a/6231
再来,打开客户端连接服务端,咋们退到64bit文件夹的目录中,鼠标移到64bit文件夹上并且安装Shift键,同时点击鼠标的右键,选中"在此处打开命令窗口"这样快速进入到了该文件夹的cmd命令窗口中(当然不同的操作系统不同,这里演示的是windows的操作;还有其他进入的方式这里不做介绍,因为个人感觉这是最快的);然后,在命令窗口中录入redis-cli.exe -h localhost -p 6379回车来访问服务端,效果图:

再来看下服务端窗体截图:

没错这样客户端就连接上服务端了,可以简单在客户端执行下set,get命令:

如果是客户端要访问远程的redis服务端,只需要把localhost换成可访问的ip就行了如果还需要密码等更多配置请去上面的那个地址链接;
。封装缓存父类,定义Get,Set等常用方法
先来,上父类的代码:
public class BaseCache : IDisposable
{
protected string def_ip = string.Empty;
protected int def_port = 0;
protected string def_password = string.Empty;
public BaseCache()
{
}
public virtual void InitCache(string ip = "", int port = 0, string password = "")
{
}
public virtual bool SetCache<T>(string key, T t, int timeOutMinute = 10) where T : class,new()
{
return false;
}
public virtual T GetCache<T>(string key) where T : class,new()
{
return default(T);
}
public virtual bool Remove(string key)
{
return false;
}
public virtual bool FlushAll()
{
return false;
}
public virtual bool Any(string key)
{
return false;
}
public virtual void Dispose(bool isfalse)
{
if (isfalse)
{
}
}
//手动释放
public void Dispose()
{
this.Dispose(true);
//不自动释放
GC.SuppressFinalize(this);
}
}
</div>
这里定义的方法没有太多的注释,更多的意思我想看方法名称就明白了,这个父类主要实现了IDisposable,实现的Dispose()中主要用来释放资源并且自定义了一个 public virtual void Dispose(bool isfalse)方法,这里面有一句是GC.SuppressFinalize(this);按照官网介绍的意思是阻塞自动释放资源,其他的没有什么了,继续看下面的
。定义RedisCache缓存类,执行Redis的Get,Set方法
首先,咋们分别定义类RedisCache,MemcachedCache(这里暂未实现对memcache缓存的操作),并且继承BaseCache,重写Set,Get方法如下代码:
/// <summary>
/// Redis缓存
/// </summary>
public class RedisCache : BaseCache
{
public RedisClient redis = null;
public RedisCache()
{
//这里去读取默认配置文件数据
def_ip = "172.0.0.1";
def_port = 6379;
def_password = "";
}
#region Redis缓存
public override void InitCache(string ip = "", int port = 0, string password = "")
{
if (redis == null)
{
ip = string.IsNullOrEmpty(ip) ? def_ip : ip;
port = port == 0 ? def_port : port;
password = string.IsNullOrEmpty(password) ? def_password : password;
redis = new RedisClient(ip, port, password);
}
}
public override bool SetCache<T>(string key, T t, int timeOutMinute = 10)
{
var isfalse = false;
try
{
if (string.IsNullOrEmpty(key)) { return isfalse; }
InitCache();
isfalse = redis.Set<T>(key, t, TimeSpan.FromMinutes(timeOutMinute));
}
catch (Exception ex)
{
}
finally { this.Dispose(); }
return isfalse;
}
public override T GetCache<T>(string key)
{
var t = default(T);
try
{
if (string.IsNullOrEmpty(key)) { return t; }
InitCache();
t = redis.Get<T>(key);
}
catch (Exception ex)
{
}
finally { this.Dispose(); }
return t;
}
public override bool Remove(string key)
{
var isfalse = false;
try
{
if (string.IsNullOrEmpty(key)) { return isfalse; }
InitCache();
isfalse = redis.Remove(key);
}
catch (Exception ex)
{
}
finally { this.Dispose(); }
return isfalse;
}
public override void Dispose(bool isfalse)
{
if (isfalse && redis != null)
{
redis.Dispose();
redis = null;
}
}
#endregion
}
/// <summary>
/// Memcached缓存
/// </summary>
public class MemcachedCache : BaseCache
{
}
</div>
这里,用到的RedisClient类是来自nuget包引用的,这里nuget包是:

然后,来看下重写的InitCache方法,这里面有一些ip,port(端口),password(密码)参数,这里直接写入在cs文件中没有从配置文件读取,大家可以扩展下;这些参数通过RedisClient构造函数传递给底层Socket访问需要的信息,下面简单展示下RedisClient几个的构造函数:
public RedisClient(); public RedisClient(RedisEndpoint config); public RedisClient(string host); public RedisClient(Uri uri); public RedisClient(string host, int port); public RedisClient(string host, int port, string password = null, long db = 0);</div>
至于Get,Set方法最终都是使用RedisClient对象访问的,个人觉得需要注意的是Set方法里面的过期时间参数,目前还没有试验这种情况的效果:
?通过这几种方法设置过期时间后,快到过期时间的时候如果此时有使用这个缓存key那么过期时间是否会往后自动增加过期时间有效期,这里暂时没有试验(这里是由于前面项目中的.net core框架中的memecache缓存都有这种设置,想来redis应该也有吧)
这里,需要重写下public override void Dispose(bool isfalse)方法,因为调用完RedisClient后需要释放,我们通过Dispose统一来手动释放,而不是直接在调用的时候使用using()
。构造出缓存工厂调用方法
接下来,咋们需要定义一个缓存工厂,因为上面刚才定义了一个RedisCache和MemcachedCache明显这里会有多个不同缓存的方法调用,所用咋们来定义个工厂模式来调用对应的缓存;这里的工厂模式没有使用直接显示创建new RedisCache(),new MemcachedCache()对象的方法,而是使用了反射的原理,创建对应的缓存对象;
先来,定义个枚举,枚举里面的声明的名字要和咋们缓存类的名称相同,代码如下:
public enum CacheType
{
RedisCache,
MemcachedCache
}
</div>
再来,定义个工厂来CacheRepository(

