RedisDrive
这是一个.net 的redis集成驱动，支持单实例、云集群、哨兵等模式的数据操作，支持keys等命令
本驱动基于stackexcnage.redis完成,在此基础上强化使用的简洁性、可靠性
wenli.Drive.Redis使用方法：
1.添加wenli.Drive.Redis引用
2.添加stackexcnage.redis nuget包引用
3.添加Wenli.Drive.Redis、log4net配置节点，添加RedisClient appsettings
app.config(web.config)配置如下：
<?xml version="1.0" encoding="utf-8"?>
<configuration>
<configSections>
<section name="RedisConfig" type="Wenli.Drive.Redis.RedisConfig, Wenli.Drive.Redis" />
<section name="SentinelConfig" type="Wenli.Drive.Redis.RedisConfig, Wenli.Drive.Redis" />
<section name="ClusterConfig" type="Wenli.Drive.Redis.RedisConfig, Wenli.Drive.Redis" />
<section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler,log4net" />
</configSections>
<!--单点模式配置-->
<RedisConfig Type="0" Masters="127.0.0.1:6379" Slaves="127.0.0.1:6379" DefaultDatabase="0" />
<!--哨兵模式配置-->
<SentinelConfig Type="1" Masters="127.0.0.1:26379" ServiceName="mymaster" DefaultDatabase="0" />
<!--集群模式配置-->
<ClusterConfig Type="2" Masters="127.0.0.1:16379,127.0.0.1:16380,127.0.0.1:16381" />
<log4net>
<logger name="logerror">
<level value="ERROR" />
<appender-ref ref="ErrorAppender" />
</logger>
<logger name="loginfo">
<level value="INFO" />
<appender-ref ref="InfoAppender" />
</logger>
<logger name="logdebug">
<level value="DEBUG" />
<appender-ref ref="DebugAppender" />
</logger>
<appender name="ErrorAppender" type="log4net.Appender.RollingFileAppender">
<param name="File" value="ErrorLog.log" />
<param name="AppendToFile" value="true" />
<param name="MaxSizeRollBackups" value="100" />
<param name="MaximumFileSize" value="1MB" />
<param name="RollingStyle" value="Size" />
<param name="StaticLogFileName" value="true" />
<layout type="log4net.Layout.PatternLayout">
<param name="ConversionPattern" value="%-5p %d [%c] %m%n" />
</layout>
</appender>
<appender name="InfoAppender" type="log4net.Appender.RollingFileAppender">
<param name="File" value="InfoLog.log" />
<param name="AppendToFile" value="true" />
<param name="MaxSizeRollBackups" value="100" />
<param name="MaximumFileSize" value="1MB" />
<param name="RollingStyle" value="Size" />
<param name="StaticLogFileName" value="true" />
<layout type="log4net.Layout.PatternLayout">
<param name="ConversionPattern" value="%-5p %d [%c] %m%n" />
</layout>
</appender>
<appender name="DebugAppender" type="log4net.Appender.RollingFileAppender">
<param name="File" value="DebugLog.log" />
<param name="AppendToFile" value="true" />
<param name="MaxSizeRollBackups" value="100" />
<param name="MaximumFileSize" value="1MB" />
<param name="RollingStyle" value="Size" />
<param name="StaticLogFileName" value="true" />
<layout type="log4net.Layout.PatternLayout">
<param name="ConversionPattern" value="%-5p %d [%c] %m%n" />
</layout>
</appender>
</log4net>
<appSettings>
<add key="RedisClient" value="Wenli.Drive.Redis.Core.SERedisHelper;Wenli.Drive.Redis,Version=1.0.0.0,Culture=neutral,PublicKeyToken=null" />
</appSettings>
<runtime>
<assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
<dependentAssembly>
<assemblyIdentity name="System.Runtime" publicKeyToken="b03f5f7f11d50a3a" culture="neutral" />
<bindingRedirect oldVersion="0.0.0.0-2.6.10.0" newVersion="2.6.10.0" />
</dependentAssembly>
<dependentAssembly>
<assemblyIdentity name="System.Threading.Tasks" publicKeyToken="b03f5f7f11d50a3a" culture="neutral" />
<bindingRedirect oldVersion="0.0.0.0-2.6.10.0" newVersion="2.6.10.0" />
</dependentAssembly>
</assemblyBinding>
</runtime>
</configuration>
也可以使用项目中的测试工具对集群进行相关测试
实例代码：
class Program
{
static void Main(string[] args)
{
Console.Title = "Wenli.Drive.Redis驱动测试";
Console.WriteLine("Wenli.Drive.Redis test");
Console.WriteLine("输入s 测试哨兵模式，输入c测试cluster模式，M为连续，其它为单实例模式");
while (true)
{
var c = Console.ReadLine();
if (c.ToUpper() == "S")
{
#region sentinel
Console.WriteLine("Wenli.Drive.Redis test 进入哨兵模式---------------------");
using (var redisHelper = RedisHelperBuilder.Build("ClusterConfig"))
{
#region string
Console.ReadLine();
Console.WriteLine("string get/set test");
redisHelper.GetRedisOperation().StringSet("abcabcabc", "123123");
Console.WriteLine("写入key：abcabcabc，value：123123");
var str = redisHelper.GetRedisOperation().StringGet("abcabcabc");
Console.WriteLine("查询key：abcabcabc，value：" + str);
redisHelper.GetRedisOperation().KeyDelete("abcabcabc");
Console.WriteLine("移除key：abcabcabc");
#endregion
#region hashset
Console.ReadLine();
Console.WriteLine("hashset get/set test");
var testModel = new DemoModel()
{
ID = Guid.NewGuid().ToString("N"),
Age = 18,
Name = "Kitty",
Created = DateTime.Now
};
redisHelper.GetRedisOperation().HashSet<DemoModel>(testModel.Name, testModel.ID, testModel);
Console.WriteLine(string.Format("写入hashid：{0}，key：{1}", testModel.Name, testModel.ID));
testModel = redisHelper.GetRedisOperation().HashGet<DemoModel>(testModel.Name, testModel.ID);
Console.WriteLine(string.Format("查询hashid：{0}，key：{1}", testModel.Name, testModel.ID));
redisHelper.GetRedisOperation().HashDelete(testModel.Name, testModel.ID);
Console.WriteLine("移除hash");
#endregion
#region 队列
Console.ReadLine();
Console.WriteLine("list test");
redisHelper.GetRedisOperation().Enqueue("list", "listvalue");
Console.WriteLine("入队：list，value：listvalue");
Console.WriteLine("list.coumt：" + redisHelper.GetRedisOperation().QueueCount("list"));
Console.WriteLine(string.Format("出队：list,value：{0}", redisHelper.GetRedisOperation().Dnqueue("list")));
Console.WriteLine("list.coumt：" + redisHelper.GetRedisOperation().QueueCount("list"));
#endregion
#region sortedset
Console.ReadLine();
Console.WriteLine("sortedset test");
Console.WriteLine(string.Format("sortedset add :{0}", redisHelper.GetRedisOperation().SortedSetAdd("sortedset", "sortedset", 0)));
var list = redisHelper.GetRedisOperation().GetSortedSetRangeByRankWithSocres("sortedset", 0, 10000, 1, 9999, true);
Console.WriteLine(string.Format("sortedset getlist :{0}", list));
Console.WriteLine(string.Format("sortedset remove :{0}", redisHelper.GetRedisOperation().RemoveItemFromSortedSet("sortedset", "sortedset")));
#endregion
#region pub/sub
Console.ReadLine();
Console.WriteLine("sub/pub test");
Console.WriteLine("订阅频道：happy");
redisHelper.GetRedisOperation().Subscribe("happy", (x, y) =>
{
Console.WriteLine(string.Format("订阅者收到消息；频道：{0},消息：{1}", x, y));
});
Console.WriteLine("发布频道happy 10 条测试消息");
for (int i = 1; i <= 10; i++)
{
redisHelper.GetRedisOperation().Publish("happy", "this is a test message" + i);
Thread.Sleep(400);
}
#endregion
Console.ReadLine();
redisHelper.GetRedisOperation().Unsubscribe("happy");
}
#endregion
}
else if (c.ToUpper() == "C")
{
#region cluster
Console.WriteLine("Wenli.Drive.Redis test 进入集群模式---------------------");
var redisHelper = RedisHelperBuilder.Build("ClusterConfig");
#region string
Console.ReadLine();
Console.WriteLine("string get/set test");
redisHelper.GetRedisOperation().StringSet("abcabcabc", "123123");
Console.WriteLine("写入key：abcabcabc，value：123123");
var str = redisHelper.GetRedisOperation().StringGet("abcabcabc");
Console.WriteLine("查询key：abcabcabc，value：" + str);
redisHelper.GetRedisOperation().KeyDelete("abcabcabc");
Console.WriteLine("移除key：abcabcabc");
#endregion
#region hashset
Console.ReadLine();
Console.WriteLine("hashset get/set test");
var testModel = new DemoModel()
{
ID = Guid.NewGuid().ToString("N"),
Age = 18,
Name = "Kitty",
Created = DateTime.Now
};
redisHelper.GetRedisOperation().HashSet<DemoModel>(testModel.Name, testModel.ID, testModel);
Console.WriteLine(string.Format("写入hashid：{0}，key：{1}", testModel.Name, testModel.ID));
testModel = redisHelper.GetRedisOperation().HashGet<DemoModel>(testModel.Name, testModel.ID);
Console.WriteLine(string.Format("查询hashid：{0}，key：{1}", testModel.Name, testModel.ID));
redisHelper.GetRedisOperation().HashDelete(testModel.Name, testModel.ID);
Console.WriteLine("移除hash");
#endregion
#region 队列
Console.ReadLine();
Console.WriteLine("list test");
redisHelper.GetRedisOperation().Enqueue("list", "listvalue");
Console.WriteLine("入队：list，value：listvalue");
Console.WriteLine("list.coumt：" + redisHelper.GetRedisOperation().QueueCount("list"));
Console.WriteLine(string.Format("出队：list,value：{0}", redisHelper.GetRedisOperation().Dnqueue("list")));
Console.WriteLine("list.coumt：" + redisHelper.GetRedisOperation().QueueCount("list"));
#endregion
#region pub/sub
Console.ReadLine();
Console.WriteLine("sub/pub test");
Console.WriteLine("订阅频道：happy");
redisHelper.GetRedisOperation().Subscribe("happy", (x, y) =>
{
Console.WriteLine(string.Format("订阅者收到消息；频道：{0},消息：{1}", x, y));
});
Console.WriteLine("发布频道happy 10 条测试消息");
for (int i = 1; i <= 10; i++)
{
redisHelper.GetRedisOperation().Publish("happy", "this is a test message" + i);
Thread.Sleep(400);
}
#endregion
Console.ReadLine();
redisHelper.GetRedisOperation().Unsubscribe("happy");
#endregion
}
else if (c.ToUpper() == "M")
{
#region default redis
Console.WriteLine("Wenli.Drive.Redis test 进入连续测试模式---------------------");
string value = "123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式123123进入连续测试模式";
var td1 = new Thread(new ThreadStart(() =>
{
using (var redisHelper = RedisHelperBuilder.Build("SentinelConfig"))
{
Parallel.For(0, 100000, countIndex =>
{
#region string
Console.WriteLine("string get/set test");
redisHelper.GetRedisOperation().StringSet(countIndex.ToString(), value);
Console.WriteLine("写入key：abcabcabc，value：123123");
var str = redisHelper.GetRedisOperation().StringGet(countIndex.ToString());
Console.WriteLine("查询key：abcabcabc，value：" + str);
redisHelper.GetRedisOperation().KeyDelete(countIndex.ToString());
Console.WriteLine("移除key：abcabcabc");
#endregion
#region hashset
Console.WriteLine("hashset get/set test");
var testModel = new DemoModel()
{
ID = Guid.NewGuid().ToString("N"),
Age = 18,
Name = "Kitty",
Created = DateTime.Now
};
redisHelper.GetRedisOperation().HashSet<DemoModel>(testModel.Name, testModel.ID, testModel);
Console.WriteLine(string.Format("写入hashid：{0}，key：{1}", testModel.Name, testModel.ID));
testModel = redisHelper.GetRedisOperation().HashGet<DemoModel>(testModel.Name, testModel.ID);
Console.WriteLine(string.Format("查询hashid：{0}，key：{1}", testModel.Name, testModel.ID));
redisHelper.GetRedisOperation().HashDelete(testModel.Name, testModel.ID);
Console.WriteLine("移除hash");
#endregion
});
}
}));
var td2 = new Thread(new ThreadStart(() =>
{
Parallel.For(0, 100000, countIndex =>
{
using (var redisHelper = RedisHelperBuilder.Build("SentinelConfig"))
{
#region string
Console.WriteLine("string get/set test");
redisHelper.GetRedisOperation().StringSet(countIndex.ToString(), value);
Console.WriteLine("写入key：abcabcabc，value：123123");
var str = redisHelper.GetRedisOperation().StringGet(countIndex.ToString());
Console.WriteLine("查询key：abcabcabc，value：" + str);
redisHelper.GetRedisOperation().KeyDelete(countIndex.ToString());
Console.WriteLine("移除key：abcabcabc");
#endregion
#region hashset
Console.WriteLine("hashset get/set test");
var testModel = new DemoModel()
{
ID = Guid.NewGuid().ToString("N"),
Age = 18,
Name = "Kitty",
Created = DateTime.Now
};
redisHelper.GetRedisOperation().HashSet<DemoModel>(testModel.Name, testModel.ID, testModel);
Console.WriteLine(string.Format("写入hashid：{0}，key：{1}", testModel.Name, testModel.ID));
testModel = redisHelper.GetRedisOperation().HashGet<DemoModel>(testModel.Name, testModel.ID);
Console.WriteLine(string.Format("查询hashid：{0}，key：{1}", testModel.Name, testModel.ID));
redisHelper.GetRedisOperation().HashDelete(testModel.Name, testModel.ID);
Console.WriteLine("移除hash");
#endregion
}
});
}));
td1.Start();
td2.Start();
while (td1.IsAlive || td2.IsAlive)
{
Thread.Sleep(50);
}
Console.WriteLine("Wenli.Drive.Redis test 任务已完成！---------------------");
#endregion
}
else
{
#region default redis
Console.WriteLine("Wenli.Drive.Redis test 进入单实例模式---------------------");
var redisHelper = RedisHelperBuilder.Build("RedisConfig");
#region string
Console.ReadLine();
Console.WriteLine("string get/set test");
redisHelper.GetRedisOperation(12).StringSet("abcabcabc", "123123");
Console.WriteLine("写入key：abcabcabc，value：123123");
var str = redisHelper.GetRedisOperation(12).StringGet("abcabcabc");
Console.WriteLine("查询key：abcabcabc，value：" + str);
redisHelper.GetRedisOperation(12).KeyDelete("abcabcabc");
Console.WriteLine("移除key：abcabcabc");
#endregion
#region hashset
Console.ReadLine();
Console.WriteLine("hashset get/set test");
var testModel = new DemoModel()
{
ID = Guid.NewGuid().ToString("N"),
Age = 18,
Name = "Kitty",
Created = DateTime.Now
};
redisHelper.GetRedisOperation().HashSet<DemoModel>(testModel.Name, testModel.ID, testModel);
Console.WriteLine(string.Format("写入hashid：{0}，key：{1}", testModel.Name, testModel.ID));
testModel = redisHelper.GetRedisOperation().HashGet<DemoModel>(testModel.Name, testModel.ID);
Console.WriteLine(string.Format("查询hashid：{0}，key：{1}", testModel.Name, testModel.ID));
redisHelper.GetRedisOperation().HashGetAll<DemoModel>(testModel.Name, 1, 1);
redisHelper.GetRedisOperation().HashDelete(testModel.Name, testModel.ID);
Console.WriteLine("移除hash");
#endregion
#region 队列
Console.ReadLine();
Console.WriteLine("list test");
redisHelper.GetRedisOperation().Enqueue("list", "listvalue");
Console.WriteLine("入队：list，value：listvalue");
Console.WriteLine("list.coumt：" + redisHelper.GetRedisOperation().QueueCount("list"));
Console.WriteLine(string.Format("出队：list,value：{0}", redisHelper.GetRedisOperation().Dnqueue("list")));
Console.WriteLine("list.coumt：" + redisHelper.GetRedisOperation().QueueCount("list"));
#endregion
#region pub/sub
Console.ReadLine();
Console.WriteLine("sub/pub test");
Console.WriteLine("订阅频道：happy");
redisHelper.GetRedisOperation().Subscribe("happy", (x, y) =>
{
Console.WriteLine(string.Format("订阅者收到消息；频道：{0},消息：{1}", x, y));
});
Console.WriteLine("发布频道happy 10 条测试消息");
for (int i = 1; i <= 10; i++)
{
redisHelper.GetRedisOperation().Publish("happy", "this is a test message" + i);
Thread.Sleep(400);
}
#endregion
Console.ReadLine();
redisHelper.GetRedisOperation().Unsubscribe("happy");
#endregion
}
}
Console.ReadLine();
}
}