redis在.NET下的使用

时间:2023-03-09 17:56:46
redis在.NET下的使用

windows SEVER包:http://code.google.com/p/servicestack/wiki/RedisWindowsDownload

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

c#使用:

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

  1. static void Main(string[] args)
  2. {
  3. var Redis = new RedisClient("127.0.0.1", 6379);//redis服务IP和端口
  4. #region =insert=
  5. //var storeMembers = new List<string> { "jj", "lihui", "cc" };
  6. //storeMembers.ForEach(x => Redis.AddItemToList("additemtolist", x));
  7. //注:也可直接使用AddRangeToList方法将一组数据装入如:
  8. //Redis.AddRangeToList("additemtolist", storeMembers);
  9. #endregion
  10. #region =get=
  11. //var members = Redis.GetAllItemsFromList("additemtolist");
  12. //members.ForEach(s => Console.WriteLine("additemtolist :" + s));
  13. //Console.WriteLine(Redis.GetItemFromList("additemtolist", 2));
  14. #endregion
  15. #region =delete=
  16. //var list = Redis.Lists["additemtolist"];
  17. //list.Clear();//清空
  18. //list.Remove("two");//移除指定键值
  19. //list.RemoveAt(2);//移除指定索引位置数据
  20. #endregion
  21. #region =object=
  22. //Redis.Set("userinfo", new UserInfo() { UserName = "李四", Age = 45 });
  23. //UserInfo userinfo = Redis.Get<UserInfo>("userinfo");
  24. //Console.WriteLine(userinfo.UserName);
  25. //Redis.Set<int>("my_age", 12);//或Redis.Set("my_age", 12);
  26. //Console.WriteLine(Redis.Get<int>("my_age"));
  27. #endregion
  28. var ser = new ObjectSerializer();    //位于namespace ServiceStack.Redis.Support;
  29. #region =序列化=
  30. //bool result = Redis.Set<byte[]>("userinfo", ser.Serialize(new UserInfo() { UserName = "张三", Age = 12 }));
  31. //UserInfo userinfo = ser.Deserialize(Redis.Get<byte[]>("userinfo")) as UserInfo;
  32. //Console.WriteLine(userinfo.UserName);
  33. #endregion
  34. //也支持列表
  35. //Redis.Set<byte[]>("userinfolist_serialize", ser.Serialize(userinfoList));
  36. #region =负载均衡=
  37. PooledRedisClientManager prcm = CreateManager(new string[] { "10.0.4.210:6379" }, new string[] { "10.0.4.210:6379" });
  38. List<UserInfo> userinfoList = new List<UserInfo>();
  39. userinfoList.Add(new UserInfo() { UserName = "pool_daizhj", Age = 1 });
  40. userinfoList.Add(new UserInfo() { UserName = "pool_daizhj1", Age = 2 });
  41. // 从池中获取一个链接:
  42. using (IRedisClient Redis2 = prcm.GetClient())
  43. {
  44. Redis2.Set("userinfolist", userinfoList);
  45. List<UserInfo> userList = Redis2.Get<List<UserInfo>>("userinfolist");
  46. }
  47. #endregion
  48. Console.ReadLine();
  49. }
  50. public static PooledRedisClientManager CreateManager(string[] readWriteHosts, string[] readOnlyHosts)
  51. {
  52. //支持读写分离,均衡负载
  53. return new PooledRedisClientManager(readWriteHosts, readOnlyHosts, new RedisClientManagerConfig
  54. {
  55. MaxWritePoolSize = 5,//“写”链接池链接数
  56. MaxReadPoolSize = 5,//“写”链接池链接数
  57. AutoStart = true,
  58. });
  59. }