您的位置:首页 > 数据库 > Redis

redis在.NET下的使用

2013-06-23 21:23 381 查看
windows SEVER包:http://code.google.com/p/servicestack/wiki/RedisWindowsDownload

windows仅用来测试,性能不如在linux下高.

c#使用:

引用的ServiceStackRedis:https://github.com/mythz/ServiceStack.Redis

[csharp] view plaincopy

static void Main(string[] args)

{

var Redis = new RedisClient("127.0.0.1", 6379);//redis服务IP和端口

#region =insert=

//var storeMembers = new List<string> { "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>("userinfo");

//Console.WriteLine(userinfo.UserName);

//Redis.Set<int>("my_age", 12);//或Redis.Set("my_age", 12);

//Console.WriteLine(Redis.Get<int>("my_age"));

#endregion

var ser = new ObjectSerializer(); //位于namespace ServiceStack.Redis.Support;

#region =序列化=

//bool result = Redis.Set<byte[]>("userinfo", ser.Serialize(new UserInfo() { UserName = "张三", Age = 12 }));

//UserInfo userinfo = ser.Deserialize(Redis.Get<byte[]>("userinfo")) as UserInfo;

//Console.WriteLine(userinfo.UserName);

#endregion

//也支持列表

//Redis.Set<byte[]>("userinfolist_serialize", ser.Serialize(userinfoList));

#region =负载均衡=

PooledRedisClientManager prcm = CreateManager(new string[] { "10.0.4.210:6379" }, new string[] { "10.0.4.210:6379" });

List<UserInfo> userinfoList = new List<UserInfo>();

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<UserInfo> userList = Redis2.Get<List<UserInfo>>("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,

});

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: