C#操作REDIS例子

永不落伍 · 发表于 2015-7-20 07:31:07

C#操作REDIS例子

　　windows　SEVER包：http://code.google.com/p/servicestack/wiki/RedisWindowsDownload
　　windows仅用来测试，性能不如在linux下高．
　　
　　c#使用：
　　引用的ServiceStackRedis:https://github.com/mythz/ServiceStack.Redis
　　

static void Main(string[] args)
{
var Redis = new RedisClient(“127.0.0.1″, 6379);//redis服务IP和端口
#region =insert=
//var storeMembers = new List { ”jj”, ”lihui”, ”cc” };
//storeMembers.ForEach(x => Redis.AddItemToList(“additemtolist”, x));
//注：也可直接使用AddRangeToList方法将一组数据装入如：
//Redis.AddRangeToList(“additemtolist”, storeMembers);
#endregion
#region =get=
//var members = Redis.GetAllItemsFromList(“additemtolist”);
//members.ForEach(s => Console.WriteLine(“additemtolist :” + s));
//Console.WriteLine(Redis.GetItemFromList(“additemtolist”, 2));
#endregion
#region =delete=
//var list = Redis.Lists["additemtolist"];
//list.Clear();//清空
//list.Remove(“two”);//移除指定键值
//list.RemoveAt(2);//移除指定索引位置数据
#endregion
#region =object=
//Redis.Set(“userinfo”, new UserInfo() { UserName = ”李四”, Age = 45 });
//UserInfo userinfo = Redis.Get(“userinfo”);
//Console.WriteLine(userinfo.UserName);
//Redis.Set(“my_age”, 12);//或Redis.Set(“my_age”, 12);
//Console.WriteLine(Redis.Get(“my_age”));
#endregion
var ser = new ObjectSerializer(); //位于namespace ServiceStack.Redis.Support;
#region =序列化=
//bool result = Redis.Set(“userinfo”, ser.Serialize(new UserInfo() { UserName = ”张三”, Age = 12 }));
//UserInfo userinfo = ser.Deserialize(Redis.Get(“userinfo”)) as UserInfo;
//Console.WriteLine(userinfo.UserName);
#endregion
//也支持列表
//Redis.Set(“userinfolist_serialize”, ser.Serialize(userinfoList));
#region =负载均衡=
PooledRedisClientManager prcm = CreateManager(new string[] { “10.0.4.210:6379″ }, new string[] { “10.0.4.210:6379″ });
List userinfoList = new List();
userinfoList.Add(new UserInfo() { UserName = “pool_daizhj”, Age = 1 });
userinfoList.Add(new UserInfo() { UserName = “pool_daizhj1″, Age = 2 });
// 从池中获取一个链接：
using (IRedisClient Redis2 = prcm.GetClient())
{
Redis2.Set(“userinfolist”, userinfoList);
List userList = Redis2.Get(“userinfolist”);
}
#endregion
Console.ReadLine();
}
public static PooledRedisClientManager CreateManager(string[] readWriteHosts, string[] readOnlyHosts)
{
//支持读写分离，均衡负载
return new PooledRedisClientManager(readWriteHosts, readOnlyHosts, new RedisClientManagerConfig
{
MaxWritePoolSize = 5,//“写”链接池链接数
MaxReadPoolSize = 5,//“写”链接池链接数
AutoStart = true,
});
}
static void Main(string[] args)
{
var Redis = new RedisClient(“127.0.0.1″, 6379);//redis服务IP和端口
#region =insert=
//var storeMembers = new List { ”jj”, ”lihui”, ”cc” };
//storeMembers.ForEach(x => Redis.AddItemToList(“additemtolist”, x));
//注：也可直接使用AddRangeToList方法将一组数据装入如：
//Redis.AddRangeToList(“additemtolist”, storeMembers);
#endregion
#region =get=
//var members = Redis.GetAllItemsFromList(“additemtolist”);
//members.ForEach(s => Console.WriteLine(“additemtolist :” + s));
//Console.WriteLine(Redis.GetItemFromList(“additemtolist”, 2));
#endregion
#region =delete=
//var list = Redis.Lists["additemtolist"];
//list.Clear();//清空
//list.Remove(“two”);//移除指定键值
//list.RemoveAt(2);//移除指定索引位置数据
#endregion
#region =object=
//Redis.Set(“userinfo”, new UserInfo() { UserName = ”李四”, Age = 45 });
//UserInfo userinfo = Redis.Get(“userinfo”);
//Console.WriteLine(userinfo.UserName);
//Redis.Set(“my_age”, 12);//或Redis.Set(“my_age”, 12);
//Console.WriteLine(Redis.Get(“my_age”));
#endregion
var ser = new ObjectSerializer(); //位于namespace ServiceStack.Redis.Support;
#region =序列化=
//bool result = Redis.Set(“userinfo”, ser.Serialize(new UserInfo() { UserName = ”张三”, Age = 12 }));
//UserInfo userinfo = ser.Deserialize(Redis.Get(“userinfo”)) as UserInfo;
//Console.WriteLine(userinfo.UserName);
#endregion
//也支持列表
//Redis.Set(“userinfolist_serialize”, ser.Serialize(userinfoList));
#region =负载均衡=
PooledRedisClientManager prcm = CreateManager(new string[] { “10.0.4.210:6379″ }, new string[] { “10.0.4.210:6379″ });
List userinfoList = new List();
userinfoList.Add(new UserInfo() { UserName = “pool_daizhj”, Age = 1 });
userinfoList.Add(new UserInfo() { UserName = “pool_daizhj1″, Age = 2 });
// 从池中获取一个链接：
using (IRedisClient Redis2 = prcm.GetClient())
{
Redis2.Set(“userinfolist”, userinfoList);
List userList = Redis2.Get(“userinfolist”);
}
#endregion
Console.ReadLine();
}
public static PooledRedisClientManager CreateManager(string[] readWriteHosts, string[] readOnlyHosts)
{
//支持读写分离，均衡负载
return new PooledRedisClientManager(readWriteHosts, readOnlyHosts, new RedisClientManagerConfig
{
MaxWritePoolSize = 5,//“写”链接池链接数
MaxReadPoolSize = 5,//“写”链接池链接数
AutoStart = true,
});
}

　　从网上收集而来，仅作自己资料记录．

账号		自动登录	找回密码
密码			立即注册

wirelessnetview好用的无线分析工具

亿图图示专家(EDraw Max) V7.9 中文破解版

zabbix3.4.1安装部署+微信推送信息+大屏显

Red Hat OpenShift I: Containers & Kubern

2025 年，C++ 还能“硬核”多久？

RH199 RHCSA Rapid Track

Red Hat RHCE 8 (EX294) Cert Guide

[经验分享] C#操作REDIS例子

浏览过的版块

扫码加入运维网微信交流群