Redis在Windows上使用和集群配置

public class RedisHelper
{
#region 属性成员
//ConnectionMultiplexer实例是线程安全的，默认设计为单例(连接复用器)
//主服务器负责write操作
private static ConnectionMultiplexer writeRedis = ConnectionMultiplexer.Connect(new ConfigurationOptions()
{
EndPoints = { { "192.168.2.153", } },
Password = "",
AllowAdmin = true
});
//查询较多，从服务器负责read，查询负荷大的时候可以随时添加从服务器
private static ConnectionMultiplexer readRedis = ConnectionMultiplexer.Connect(new ConfigurationOptions()
{
EndPoints = { { "192.168.2.154", }, { "192.168.2.155", } },
Password = "",
});
static IDatabase masterDb = writeRedis.GetDatabase();
static IDatabase slaveDb = readRedis.GetDatabase();
#endregion
#region string类型操作
/// <summary>
/// string类型写入
/// </summary>
/// <param name="key"></param>
/// <param name="value"></param>
/// <returns>isSuccess</returns>
public static bool StringSet(string key, string value, TimeSpan? expiry = default(TimeSpan?))
{
return masterDb.StringSet(key, value, expiry);
}
/// <summary>
/// string类型读取
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public static string StringGet(string key)
{ return slaveDb.StringGet(key);
}
#endregion
#region 单个实例
/// <summary>
/// 单个实例写入
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="key"></param>
/// <param name="t"></param>
/// <param name="expiry"></param>
/// <returns></returns>
public static bool ObjSet<T>(string key, T t, TimeSpan? expiry = default(TimeSpan?))
{
string json = Newtonsoft.Json.JsonConvert.SerializeObject(t);
return masterDb.StringSet(key, json, expiry);
}
/// <summary>
/// 单个实例获取
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="key"></param>
/// <returns></returns>
public static T ObjGet<T>(string key) where T : class
{
try
{
string json = slaveDb.StringGet(key);
if (!string.IsNullOrWhiteSpace(json))
{
T t = Newtonsoft.Json.JsonConvert.DeserializeObject<T>(json);
if (t != null)
{
return t;
}
}
return null;
}
catch (Exception)
{
throw;
}
}
#endregion //public static void List_Add<T>(String key,T t)
//{
// masterDb.ListRightPush(key,t)
//} #region 哈希类型
#region 简单属性
/// <summary>
/// set or update the HashValue for string key
/// </summary>
/// <param name="key"></param>
/// <param name="hashkey"></param>
/// <param name="value"></param>
/// <returns></returns>
public static void SampleHashSet(string key, string hashkey, RedisValue value)
{
masterDb.HashSet(key, hashkey, value);
}
/// <summary>
/// 获取简单类型的属性值
/// </summary>
/// <param name="key">Represents a key that can be stored in redis</param>
/// <param name="hashkey"></param>
/// <returns></returns>
public static RedisValue SampleHashGet(string key, string hashkey)
{
return slaveDb.HashGet(key, hashkey);
}
#endregion
#region 复杂属性
/// <summary>
/// 复杂属性存入
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="key"></param>
/// <param name="hashkey"></param>
/// <param name="t">defined class</param>
/// <returns></returns>
public static void ObjHashSet<T>(string key, string hashkey, T t) where T : class
{
string json = Newtonsoft.Json.JsonConvert.SerializeObject(t);
masterDb.HashSet(key, hashkey, json);
}
/// <summary>
/// 复杂属性取出
/// </summary>
/// <param name="key">Represents a key that can be stored in redis</param>
/// <param name="hashkey"></param>
/// <returns></returns>
public static T ObjHashGet<T>(string key, string hashkey) where T : class
{
try
{
string json = slaveDb.HashGet(key, hashkey).ToString();
if (!string.IsNullOrWhiteSpace(json))
{
T t = Newtonsoft.Json.JsonConvert.DeserializeObject<T>(json);
if (t != null)
{
return t;
}
}
return null;
}
catch (Exception)
{
throw;
}
}
#endregion
#endregion
}