You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
62 lines
1.9 KiB
Plaintext
62 lines
1.9 KiB
Plaintext
using ServiceStack.Redis;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace BP.Difference.Redis
|
|
{
|
|
public class RedisManager
|
|
{
|
|
/// <summary>
|
|
/// redis配置文件信息
|
|
/// </summary>
|
|
private static readonly RedisConfigInfo RedisConfigInfo = RedisConfigInfo.GetConfig();
|
|
|
|
private static PooledRedisClientManager _prcm;
|
|
|
|
/// <summary>
|
|
/// 静态构造方法，初始化链接池管理对象
|
|
/// </summary>
|
|
public RedisManager()
|
|
{
|
|
CreateManager();
|
|
}
|
|
/// <summary>
|
|
/// 创建链接池管理对象
|
|
/// </summary>
|
|
private void CreateManager()
|
|
{
|
|
var writeServerList = SplitString(RedisConfigInfo.WriteServerList, ",");
|
|
var readServerList = SplitString(RedisConfigInfo.ReadServerList, ",");
|
|
|
|
_prcm = new PooledRedisClientManager(writeServerList, readServerList,
|
|
new RedisClientManagerConfig
|
|
{
|
|
MaxWritePoolSize = RedisConfigInfo.MaxWritePoolSize,
|
|
MaxReadPoolSize = RedisConfigInfo.MaxReadPoolSize,
|
|
AutoStart = RedisConfigInfo.AutoStart,
|
|
DefaultDb = RedisConfigInfo.DefaultDb,
|
|
|
|
});
|
|
}
|
|
private static IEnumerable<string> SplitString(string strSource, string split)
|
|
{
|
|
return strSource.Split(split.ToArray());
|
|
}
|
|
/// <summary>
|
|
/// 客户端缓存操作对象
|
|
/// </summary>
|
|
public IRedisClient GetClient()
|
|
{
|
|
if (_prcm == null)
|
|
{
|
|
CreateManager();
|
|
}
|
|
IRedisClient redisClient = _prcm.GetClient();
|
|
return redisClient;
|
|
}
|
|
}
|
|
}
|