.net redis读写分离
电脑版发表于:2020/3/1 17:22
封装一下获取redis实例的类:
public class SingletonRedis { // 定义一个静态变量来保存类的实例 private static PooledRedisClientManager poolrl; private static readonly object obj = new object(); // 定义私有构造函数,使外界不能创建该类实例 private SingletonRedis() { } /// <summary> /// 获取Redis写节点 /// </summary> /// <returns></returns> public static RedisClient GetInstance() { // 如果连接池的实例不存在则创建,否则直接返回 if (poolrl == null) { lock (obj) { if (poolrl == null) { CreatePoolManager(); } } } return poolrl.GetClient() as RedisClient; } /// <summary> /// 获取Redis读节点(读取的时候就读取本地的,这样效率就会很快) /// </summary> /// <returns></returns> public static RedisClient GetReadOnlyInstance() { if (poolrl == null) { lock (obj) { if (poolrl == null) { CreatePoolManager(); } } } return poolrl.GetReadOnlyClient() as RedisClient; } private static void CreatePoolManager() { ////写节点(主节点) List<string> writes = new List<string>(); writes.Add("127.0.0.1:6379"); //读节点(本地) List<string> reads = new List<string>(); reads.Add("127.0.0.1:6379"); reads.Add("127.0.0.1:6380"); //配置连接池和读写分类 poolrl = new PooledRedisClientManager(writes, reads, new RedisClientManagerConfig() { MaxReadPoolSize = 50, //读节点个数 MaxWritePoolSize = 50,//写节点个数 }); } }
这样我们想要去写入缓存的时候就调用 GetInstance方法,如果是想要读的话就调用CreatePoolManager方法,通常读节点配置成本地缓存,这样效率快一点。
我们可以测试获取一下一下读节点,上面我们读接口设置了两个看看获取的情况:
我们可以看到找到6380的次数是10次,刚好是我们循环次数的一半,说明负载均衡做得不错哇
当然大家还可以试试去获取读节点