基于C#的MongoDB数据库开发应用（4）--Redis的安装及使用

        //创建一个Redis的客户端类
        RedisClient client = new RedisClient("127.0.0.1", 6379);

            //Redis FlushAll 命令用于清空整个 Redis 服务器的数据(删除所有数据库的所有 key )。
            client.FlushAll();

            #region string类型的测试代码client.Add<string>("StringValueTime", "带有有效期的字符串", DateTime.Now.AddMilliseconds(10000));while (true)

            {if (client.ContainsKey("StringValueTime"))

                {

                    Console.WriteLine("String.键:StringValue, 值:{0} {1}", client.Get<string>("StringValueTime"), DateTime.Now);

                    Thread.Sleep(10000);

                }else{

                    Console.WriteLine("键:StringValue, 值:已过期 {0}", DateTime.Now);break;

                }

            }



            client.Add<string>("StringValue", "String和Memcached操作方法差不多");

            Console.WriteLine("数据类型为：String.键:StringValue, 值:{0}", client.Get<string>("StringValue"));



            Student stud= new Student() { id = "1001", name = "李四"};

            client.Add<Student>("StringEntity", stud);

            Student Get_stud= client.Get<Student>("StringEntity");

            Console.WriteLine("数据类型为：String.键:StringEntity, 值:{0} {1}", Get_stud.id, Get_stud.name);#endregion

            #region Hash类型的测试代码client.SetEntryInHash("HashID", "Name", "张三");

            client.SetEntryInHash("HashID", "Age", "24");

            client.SetEntryInHash("HashID", "Sex", "男");

            client.SetEntryInHash("HashID", "Address", "上海市XX号XX室");



            List<string> HaskKey = client.GetHashKeys("HashID");foreach (string key inHaskKey)

            {

                Console.WriteLine("HashID--Key:{0}", key);

            }



            List<string> HaskValue = client.GetHashValues("HashID");foreach (string value inHaskValue)

            {

                Console.WriteLine("HashID--Value:{0}", value);

            }



            List<string> AllKey = client.GetAllKeys(); //获取所有的key。
            foreach (string Key inAllKey)

            {

                Console.WriteLine("AllKey--Key:{0}", Key);

            }#endregion

            #region List类型的测试代码
            /** list是一个链表结构，主要功能是push,pop,获取一个范围的所有的值等，操作中key理解为链表名字。 

             * Redis的list类型其实就是一个每个子元素都是string类型的双向链表。我们可以通过push,pop操作从链表的头部或者尾部添加删除元素，

             * 这样list既可以作为栈，又可以作为队列。Redis list的实现为一个双向链表，即可以支持反向查找和遍历，更方便操作，不过带来了部分额外的内存开销，

             * Redis内部的很多实现，包括发送缓冲队列等也都是用的这个数据结构*/client.EnqueueItemOnList("QueueListId", "1.张三");  //入队
            client.EnqueueItemOnList("QueueListId", "2.张四");

            client.EnqueueItemOnList("QueueListId", "3.王五");

            client.EnqueueItemOnList("QueueListId", "4.王麻子");long q = client.GetListCount("QueueListId");



            Console.WriteLine(client.GetItemFromList("QueueListId", 0));for (int i = 0; i < q; i++)

            {

                Console.WriteLine("QueueListId出队值：{0}", client.DequeueItemFromList("QueueListId"));   //出队(队列先进先出)
}



            q= client.GetListCount("QueueListId");

            Console.WriteLine(q);



            client.PushItemToList("StackListId", "1.张三");  //入栈
            client.PushItemToList("StackListId", "2.张四");

            client.PushItemToList("StackListId", "3.王五");

            client.PushItemToList("StackListId", "4.王麻子");long p = client.GetListCount("StackListId");for (int i = 0; i < p; i++)

            {

                Console.WriteLine("StackListId出栈值：{0}", client.PopItemFromList("StackListId"));   //出栈(栈先进后出)
}

            q= client.GetListCount("StackListId");

            Console.WriteLine(q);#endregion

            #region Set无序集合的测试代码
            /*它是string类型的无序集合。set是通过hash table实现的，添加，删除和查找,对集合我们可以取并集，交集，差集*/client.AddItemToSet("Set1001", "小A");

            client.AddItemToSet("Set1001", "小B");

            client.AddItemToSet("Set1001", "小C");

            client.AddItemToSet("Set1001", "小D");

            HashSet<string> hastsetA = client.GetAllItemsFromSet("Set1001");foreach (string item inhastsetA)

            {

                Console.WriteLine("Set无序集合ValueA:{0}", item); //出来的结果是无须的
}



            client.AddItemToSet("Set1002", "小K");

            client.AddItemToSet("Set1002", "小C");

            client.AddItemToSet("Set1002", "小A");

            client.AddItemToSet("Set1002", "小J");

            HashSet<string> hastsetB = client.GetAllItemsFromSet("Set1002");foreach (string item inhastsetB)

            {

                Console.WriteLine("Set无序集合ValueB:{0}", item); //出来的结果是无须的
}



            HashSet<string> hashUnion = client.GetUnionFromSets(new string[] { "Set1001", "Set1002"});foreach (string item inhashUnion)

            {

                Console.WriteLine("求Set1001和Set1002的并集:{0}", item); //并集
}



            HashSet<string> hashG = client.GetIntersectFromSets(new string[] { "Set1001", "Set1002"});foreach (string item inhashG)

            {

                Console.WriteLine("求Set1001和Set1002的交集:{0}", item);  //交集
}



            HashSet<string> hashD = client.GetDifferencesFromSet("Set1001", new string[] { "Set1002" });  //[返回存在于第一个集合，但是不存在于其他集合的数据。差集]
            foreach (string item inhashD)

            {

                Console.WriteLine("求Set1001和Set1002的差集:{0}", item);  //差集
}#endregion

            #region  SetSorted 有序集合的测试代码
            /*sorted set 是set的一个升级版本，它在set的基础上增加了一个顺序的属性，这一属性在添加修改.元素的时候可以指定，

             * 每次指定后，zset(表示有序集合)会自动重新按新的值调整顺序。可以理解为有列的表，一列存 value,一列存顺序。操作中key理解为zset的名字.*/client.AddItemToSortedSet("SetSorted1001", "1.刘仔");

            client.AddItemToSortedSet("SetSorted1001", "2.星仔");

            client.AddItemToSortedSet("SetSorted1001", "3.猪仔");

            List<string> listSetSorted = client.GetAllItemsFromSortedSet("SetSorted1001");foreach (string item inlistSetSorted)

            {

                Console.WriteLine("SetSorted有序集合{0}", item);

            }#endregion

IRedisTypedClient<Phone> phones = client.As<Phone>();

        /// <summary>
        ///Redis对对象类的处理例子/// </summary>
        private void btnTypeValue_Click(objectsender, EventArgs e)

        {

            IRedisTypedClient<Phone> phones = client.As<Phone>();

            Phone phoneFive= phones.GetValue("5");if (phoneFive == null)

            {

                Thread.Sleep(50);

                phoneFive= newPhone

                {

                    Id= 5,

                    Manufacturer= "Apple",

                    Model= "xxxxx",

                    Owner= newPerson

                    {

                        Id= 1,

                        Age= 100,

                        Name= "伍华聪",

                        Profession= "计算机",

                        Surname= "wuhuacong"}

                };



                phones.SetEntry(phoneFive.Id.ToString(), phoneFive);

            }



            client.Store<Phone>(newPhone

                {

                    Id= 2,

                    Manufacturer= "LG",

                    Model= "test-xxx",

                    Owner= newPerson

                    {

                        Id= 2,

                        Age= 40,

                        Name= "test",

                        Profession= "teacher",

                        Surname= "wuhuacong"}

                });var message = "Phone model is" + phoneFive.Manufacturer + ",";

            message+= "Phone Owner Name is:" +phoneFive.Owner.Name;

            Console.WriteLine(message);

        }