基本信息
源码名称：Redis多线程 批量插入 性能测试 示例
源码大小：23.22M
文件格式：.zip
开发语言：C#
更新时间：2016-11-27
友情提示：（无需注册或充值，赞助后即可获取资源下载链接）
嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300
本次赞助数额为： 2 元×
微信扫码支付：2 元
×
请留下您的邮箱，我们将在2小时内将文件发到您的邮箱
源码介绍
下为基础操作：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Drawing;
using System.Linq;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using ServiceStack.Redis;
using ServiceStack.Redis.Generic;
namespace SSRedisDemo
{
public partial class Form1 : Form
{
public static IRedisClientsManager clientsManager=null;
public static IRedisClient redisClient=null;
public Form1()
{
InitializeComponent();
var count = this.tabControl1.TabCount;
for (int i = 0; i < count; i )
{
this.tabControl1.GetControl(i).Enabled = false;
}
this.tabControl1.GetControl(0).Enabled = true;
}
private void btnConn_Click(object sender, EventArgs e)
{
try
{
#region 集群访问方式
var host = String.Format("{2}@{0}:{1}", this.txtHost.Text, this.txtPort.Text, this.txtPwd.Text);
host = String.Format("{0}:{1}", this.txtHost.Text, this.txtPort.Text);//v3.0格式
clientsManager = new PooledRedisClientManager(new string[] {host});
redisClient = clientsManager.GetClient();
#endregion
#region 单个实例方式
//redisClient = new RedisClient(this.txtHost.Text, Int32.Parse(this.txtPort.Text),this.txtPwd.Text);
#endregion
}
catch(Exception ex)
{
MessageBox.Show("失败:" ex.Message);
return;
}
MessageBox.Show("成功");
var count = this.tabControl1.TabCount;
for (int i = 0; i < count; i )
{
this.tabControl1.GetControl(i).Enabled = true;
}
}
private void btnSetString_Click(object sender, EventArgs e)
{
redisClient.Set(this.txtStringKey.Text, this.txtStringValue.Text);
}
private void btnGetString_Click(object sender, EventArgs e)
{
var strValue=redisClient.Get<string>(this.txtStringKey.Text);
MessageBox.Show(strValue);
}
private void btnTransaction_Click(object sender, EventArgs e)
{
using (IRedisClient RClient = clientsManager.GetClient())
{
RClient.Add("key", 1);
using (IRedisTransaction IRT = RClient.CreateTransaction())
{
IRT.QueueCommand(r => r.Set("key", 20));
IRT.QueueCommand(r => r.Increment("key", 1));
IRT.Commit(); // 提交事务
}
MessageBox.Show(RClient.Get<string>("key"));
}
}
private void btnAcquireLock_Click(object sender, EventArgs e)
{
using (IRedisClient RClient = clientsManager.GetClient())
{
RClient.Add("mykey", 1);
// 支持IRedisTypedClient和IRedisClient
using (RClient.AcquireLock("testlock"))
{
//Response.Write("申请并发锁<br/>");
var counter = RClient.Get<int>("mykey");
Thread.Sleep(100);
RClient.Set("mykey", counter 1);
MessageBox.Show(RClient.Get<int>("mykey").ToString());
}
}
}
private void btnQueue_Click(object sender, EventArgs e)
{
redisClient.EnqueueItemOnList("operLog", "操作时间:" DateTime.Now.ToString());
MessageBox.Show("写入成功");
}
private void btnQueueRead_Click(object sender, EventArgs e)
{
string msg = redisClient.DequeueItemFromList("operLog");
MessageBox.Show(msg);
}
/// <summary>
/// DecrementValue 根据指定的Key，将值减1(仅整型有效)
///DecrementValueBy 根据指定的Key，将值减去指定值(仅整型有效)
///IncrementValue 根据指定的Key，将值加1(仅整型有效)
///IncrementValueBy 根据指定的Key，将值加上指定值(仅整型有效)
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnIncStart_Click(object sender, EventArgs e)
{
var key = "incKey";
var v = redisClient.IncrementValue(key);//将值加1(仅整型有效)
redisClient.IncrementValueBy(key, 100);//将值加100
MessageBox.Show("Success");
}
private void btnIncStop_Click(object sender, EventArgs e)
{
var key = "incKey";
var v = redisClient.Get<long>(key);
MessageBox.Show("当前值:" v.ToString());
}
private void btnTypedClient_Click(object sender, EventArgs e)
{
Person p1 = new Person() { Id = 1, Name = "刘备" };
Person p2 = new Person() { Id = 2, Name = "关羽" };
Person p3 = new Person() { Id = 3, Name = "张飞" };
Person p4 = new Person() { Id = 4, Name = "曹操" };
Person p5 = new Person() { Id = 5, Name = "典韦" };
Person p6 = new Person() { Id = 6, Name = "郭嘉" };
List<Person> ListPerson = new List<Person>() { p2, p3, p4, p5, p6 };
using (IRedisClient RClient = clientsManager.GetClient())
{
IRedisTypedClient<Person> IRPerson = RClient.As<Person>();
IRPerson.DeleteAll();
//------------------------------------------添加--------------------------------------------
//添加单条数据
IRPerson.Store(p1);
//添加多条数据
IRPerson.StoreAll(ListPerson);
//------------------------------------------查询--------------------------------------------
//Linq支持
MessageBox.Show("Id == 1 的Name:" IRPerson.GetAll().Where(m => m.Id == 1).First().Name); //刘备
//注意，用IRedisTypedClient的对象IRPerson的Srore()添加的才能用IRPerson()方法读取
MessageBox.Show("Id == 2 的Name:" IRPerson.GetAll().First(m => m.Id == 2).Name); //关羽
//------------------------------------------删除--------------------------------------------
IRPerson.Delete(p1); //删除 刘备
MessageBox.Show("删除刘备后总数:" IRPerson.GetAll().Count()); //5
IRPerson.DeleteById(2); //删除 关羽
MessageBox.Show("删除关羽后总数:" IRPerson.GetAll().Count()); //4
IRPerson.DeleteByIds(new List<int> { 3, 4 }); //删除张飞 曹操
MessageBox.Show("删除张飞曹操后总数:" IRPerson.GetAll().Count()); //2
IRPerson.DeleteAll(); //全部删除
MessageBox.Show("全部删除后总数:" IRPerson.GetAll().Count()); //0
}
}
private void btnTestAddSetReplace_Click(object sender, EventArgs e)
{
using (IRedisClient RClient = clientsManager.GetClient())
{
RClient.Add("c1", "缓存1");
RClient.Set("c1", "缓存2");
RClient.Replace("c1", "缓存3");
MessageBox.Show(RClient.Get<string>("c1"));
RClient.Remove("c1");
MessageBox.Show("移除状态:" (RClient.Get<string>("c1") == null));
}
}
private void btnList_T_Click(object sender, EventArgs e)
{
using (IRedisClient RClient = clientsManager.GetClient())
{
//内部维护一个List<T>集合
RClient.AddItemToList("蜀国", "刘备");
RClient.AddItemToList("蜀国", "关羽");
RClient.AddItemToList("蜀国", "张飞");
List<string> ListString = RClient.GetAllItemsFromList("蜀国");
foreach (string str in ListString)
{
MessageBox.Show(str); //输出 刘备 关羽 张飞
}
}
}
private void btnHash_T_Click(object sender, EventArgs e)
{
using (IRedisClient RClient = clientsManager.GetClient())
{
//Hash<T>
RClient.AddItemToSet("魏国", "曹操");
RClient.AddItemToSet("魏国", "曹操");
RClient.AddItemToSet("魏国", "典韦");
HashSet<string> HashSetString = RClient.GetAllItemsFromSet("魏国");
foreach (string str in HashSetString)
{
MessageBox.Show(str); //输出 典韦 曹操
}
}
}
private void btnList_Range_Click(object sender, EventArgs e)
{
using (IRedisClient RClient = clientsManager.GetClient())
{
//内部维护一个List<T>集合
RClient.AddItemToSortedSet("蜀国1", "刘备", 5);
RClient.AddItemToSortedSet("蜀国1", "关羽", 2);
RClient.AddItemToSortedSet("蜀国1", "张飞", 3);
IDictionary<String, double> DicString = RClient.GetRangeWithScoresFromSortedSet("蜀国1", 0, 2);
foreach (var r in DicString)
{
MessageBox.Show(r.Key ":" r.Value); //输出 关羽 张飞 刘备
}
}
}
private void btnHashTable_Click(object sender, EventArgs e)
{
using (IRedisClient RClient = clientsManager.GetClient())
{
RClient.SetEntryInHash("xxx", "key", "123");
List<KeyValuePair<string, string>> keyValuePairs = new List<KeyValuePair<string, string>>();
KeyValuePair<string, string> kvp = new KeyValuePair<string, string>("key", "1");
keyValuePairs.Add(kvp);
RClient.SetRangeInHash("xxx", keyValuePairs);
MessageBox.Show(string.Join("\r\n", RClient.GetHashValues("xxx").ToArray()));
}
}
private void btnSaveT_Click(object sender, EventArgs e)
{
var keyT = "tkey";
redisClient.Set(keyT, new Person() { Id = 6, Name = "好例子" });
var p = redisClient.Get<Person>(keyT);
MessageBox.Show(p.Name);
}
private void btnBatchAdd_Click_1(object sender, EventArgs e)
{
var seed = DateTime.Now.ToString("yyyyMMddHHmmss");
var count = 10000;
Stopwatch watch = new Stopwatch();
using (IRedisClient RClient = clientsManager.GetClient())
{
watch.Start();
for (var i = 0; i < count; i )
{
RClient.Add(seed "" i.ToString(), "缓存" i);
}
watch.Stop();
MessageBox.Show("单线程插入" count "条数据,用时:" watch.ElapsedMilliseconds "毫秒");
}
}
private void btnBatchQueue_Click(object sender, EventArgs e)
{
var seed = DateTime.Now.ToString("yyyyMMddHHmmss");
var count = 10000;
Stopwatch watch = new Stopwatch();
using (IRedisClient RClient = clientsManager.GetClient())
{
watch.Start();
for (var i = 0; i < count; i )
{
redisClient.EnqueueItemOnList("testQueueLog","操作时间:" i);
}
watch.Stop();
MessageBox.Show("单线程插入" count "条数据,用时:" watch.ElapsedMilliseconds "毫秒");
}
}
private void btnBatchAddMulitThread_Click(object sender, EventArgs e)
{
string message="";
var count = int.Parse(this.txtDataCount.Text);// 10000;
var threadCount = int.Parse(this.txtThreadCount.Text);// 20;
int rand = new Random().Next(1, 10000);
Stopwatch watchTotal = new Stopwatch();
watchTotal.Start();
var tasks = new Task[threadCount];
for (int i = 0; i < tasks.Length; i )
{
int taskIndex = i;
tasks[i] = Task.Factory.StartNew(() =>
{
rand = int.Parse(taskIndex.ToString());
var seed = DateTime.Now.ToString("yyyyMMddHHmmss") "_" rand;
Stopwatch watch = new Stopwatch();
using (IRedisClient RClient = clientsManager.GetClient())
{
watch.Start();
for (var j = 0; j < count; j )
{
RClient.Add(seed "" j.ToString(), "缓存" j);
}
watch.Stop();
message = ("\r\n" rand "该线程插入" count "条数据,用时:" watch.ElapsedMilliseconds "毫秒");
}
}
);
}
Task.WaitAll(tasks);
watchTotal.Stop();
//var startNew = Task<string>.Factory.StartNew((o) => ("holy " o), "cow");
//Console.WriteLine(startNew.Result);
MessageBox.Show(threadCount "个线程插入" threadCount * count "条数据,共用时:" watchTotal.ElapsedMilliseconds "毫秒" ",平均用时:" watchTotal.ElapsedMilliseconds/threadCount "毫秒/万条" message);
}
}
public class Person
{
public int Id { get; set; }
public string Name { get; set; }
}
}