排名
3
文章
317
粉丝
22
评论
14
ICP备案 :渝ICP备18016597号-1
网站信息:2018-2025TNBLOG.NET
技术交流:群号656732739
联系我们:contact@tnblog.net
公网安备:
50010702506256


欢迎加群交流技术

封装一下获取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次,刚好是我们循环次数的一半,说明负载均衡做得不错哇
当然大家还可以试试去获取读节点
欢迎加群讨论技术,1群:677373950(满了,可以加,但通过不了),2群:656732739。有需要软件开发,或者学习软件技术的朋友可以和我联系~(Q:815170684)
评价
尘叶心繁
建议使用新的明星库:StackExchange.Redis
青春年华
青春年华
Good!