C# Redis

引用：ServiceStackRedis

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,
	  });
  }

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,
	});
}