Redis之品鉴之旅（三）

3）Set，可以去重的、无序的集合。可以取交集、并集。zset（sorted set），有序的、去重的集合，排序不是根据value排序，而是根据score排序。

using (RedisClient client = new RedisClient("127.0.0.1", 6379, "12345", 10))
{   //删除当前数据库中的所有Key  默认删除的是db0
    client.FlushDb();
    //删除所有数据库中的key 
    //client.FlushAll();
    #region Set 不重复集合
    string key = "world_set";
    //投票 
    #region 添加键值 //就是自动去重，再带去重的功能
    {
        client.FlushDb();
        var litaibai = new UserInfo() { Id = 1, Name = "李太白" };
        client.AddItemToSet(key, JsonConvert.SerializeObject(litaibai));
        client.AddItemToSet(key, JsonConvert.SerializeObject(litaibai));
        client.AddItemToSet(key, JsonConvert.SerializeObject(litaibai));
        client.AddItemToSet(key, JsonConvert.SerializeObject(litaibai));
        Console.WriteLine("***完成了");
    }
    #endregion

    #region 随机获取key集合中的一个值，获取当前setid中的所有值
    {
        client.FlushDb();
        //批量的去操作set 集合  去重
        Console.WriteLine("set 开始了");
        client.AddRangeToSet(key, new List<string>() { "001", "001", "002", "003", "003", "004" });
        //当前setid中的值数量
        Console.WriteLine(client.GetSetCount(key));

        //随机获取key集合中的一个值 如果有需要取随机数也可以用
        Console.WriteLine(client.GetRandomItemFromSet(key));
        //获取当前setid中的所有值
        var lists = client.GetAllItemsFromSet(key);
        Console.WriteLine("展示所有的值");
        foreach (var item in lists)
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #region 随机删除key集合中的一个值
    {
        client.FlushDb();
        client.AddRangeToSet(key, new List<string>() { "001", "001", "002" });
        //随机删除key集合中的一个值 返回当前删掉的这个值
        Console.WriteLine("随机删除的值" + client.PopItemFromSet(key));
        var lists = client.GetAllItemsFromSet(key);
        Console.WriteLine("展示删除之后所有的值");
        foreach (var item in lists)
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #region 根据小key 删除  一个key 对象多个value
    {
        client.FlushDb();
        client.AddRangeToSet(key, new List<string>() { "001", "001", "002" });
        client.RemoveItemFromSet(key, "001");
        var lists = client.GetAllItemsFromSet(key);
        Console.WriteLine("展示删除之后所有的值");
        foreach (var item in lists)
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #region 从fromkey集合中移除值为value的值，并把value添加到tokey集合中
    {
        client.FlushDb();
        client.AddRangeToSet("fromkey", new List<string>() { "003", "001", "002", "004" });
        client.AddRangeToSet("tokey", new List<string>() { "001", "002" });
        //从fromkey 中把元素004 剪切到tokey 集合中去
        client.MoveBetweenSets("fromkey", "tokey", "004");
        Console.WriteLine("fromkey data ~~~~~~");
        foreach (var item in client.GetAllItemsFromSet("fromkey"))
        {
            Console.WriteLine(item);
        }

        Console.WriteLine("tokey data ~~~~~~");
        foreach (var item in client.GetAllItemsFromSet("tokey"))
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #region 并集  把两个集合合并起来，然后去重
    {
        client.FlushDb();
        client.AddRangeToSet("keyone", new List<string>() { "001", "002", "003", "004" });
        client.AddRangeToSet("keytwo", new List<string>() { "001", "002", "005" });
        var unionlist = client.GetUnionFromSets("keyone", "keytwo");
        Console.WriteLine("返回并集结果");
        foreach (var item in unionlist)
        {
            Console.WriteLine(item);
        }
        //把 keyone 和keytwo 并集结果存放到newkey 集合中
        client.StoreUnionFromSets("newkey", "keyone", "keytwo");
        Console.WriteLine("返回并集结果的新集合数据");
        foreach (var item in client.GetAllItemsFromSet("newkey"))
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #region 交集 获取两个集合中共同存在的元素
    {
        client.FlushDb();
        client.AddRangeToSet("keyone", new List<string>() { "001", "002", "003", "004" });
        client.AddRangeToSet("keytwo", new List<string>() { "001", "002", "005" });
        var Intersectlist = client.GetIntersectFromSets("keyone", "keytwo");
        Console.WriteLine("交集的结果");
        foreach (var item in Intersectlist)
        {
            Console.WriteLine(item);
        }
        //把 keyone 和keytwo 交集结果存放到newkey 集合中
        client.StoreIntersectFromSets("newkey", "keyone", "keytwo");
        Console.WriteLine("返回交集结果的新集合数据");
        foreach (var item in client.GetAllItemsFromSet("newkey"))
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #endregion

    #region  sorted set
    {
        client.FlushDb();
        string zsett_key = "world_zset";
        //添加一个kye 如果有相同的值，则会替换（覆盖）进去，不会因为分数保留
        client.AddItemToSortedSet(zsett_key, "cc", 33);
        client.AddItemToSortedSet(zsett_key, "cc", 44);
        client.AddItemToSortedSet(zsett_key, "cc", 22);
        Console.WriteLine("ok");
        //获取当前value的结果
        Console.WriteLine(client.GetItemIndexInSortedSet(zsett_key, "cc"));
        //批量操作多个key ，给多个key 赋值1
        client.AddRangeToSortedSet(zsett_key, new List<string>() { "a", "b" }, 1);

        foreach (var item in client.GetAllItemsFromSortedSet(zsett_key))
        {
            Console.WriteLine(item);
        }
        client.AddItemToSortedSet("蜀国", "刘备", 5);
        client.AddItemToSortedSet("蜀国", "关羽", 2);
        client.AddItemToSortedSet("蜀国", "张飞", 3);
        client.AddItemToSortedSet("魏国", "刘备", 5);
        client.AddItemToSortedSet("魏国", "关羽", 2);
        client.AddItemToSortedSet("蜀国", "张飞", 3);
        //获取 key为蜀国的下标0，到2  //key为蜀国中第0到第2个  ********************
        IDictionary<String, double> Dic = client.GetRangeWithScoresFromSortedSet("蜀国", 0, 2);
        foreach (var r in Dic)
        {
            Console.WriteLine(r.Key + ":" + r.Value);
        }
    }
    #endregion
}

set的数据结构中，存储的形式有两种类型，intzset和hashtable。zset使用了ziplist数据结构。

4）list，各种操作api的代码例子

using (RedisClient client = new RedisClient("127.0.0.1", 6379, "12345", 10))
{
    //删除当前数据库中的所有Key  默认删除的是db0
    client.FlushDb();
    //删除所有数据库中的key 
    //client.FlushAll();

    string listid = "world_list";

    #region 顺序添加
    {
        client.FlushDb();
        var caocao = new UserInfo() { Id = 1, Name = "李太白" };
        client.AddItemToList(listid, JsonConvert.SerializeObject(caocao));
        var jiaxu = new UserInfo() { Id = 2, Name = "贾诩" };
        client.AddItemToList(listid, JsonConvert.SerializeObject(jiaxu));
    }
    #endregion

    #region 从左侧向list中添加值 追加
    {
        client.FlushDb();
        var liubei = new UserInfo() { Id = 1, Name = "刘备" };
        client.PushItemToList(listid, JsonConvert.SerializeObject(liubei));
    }
    #endregion

    #region 从左侧向list中添加值，并设置过期时间
    {
        client.FlushDb();
        var caocao = new UserInfo() { Id = 1, Name = "李太白" };
        client.AddItemToList(listid, JsonConvert.SerializeObject(caocao));
        var liubei = new UserInfo() { Id = 2, Name = "刘备" };
        client.PushItemToList(listid, JsonConvert.SerializeObject(liubei));
        //只在内存中存储一秒，针对一个大key，对应的数据要么全部存在，要么全部消失
        client.ExpireEntryAt(listid, DateTime.Now.AddSeconds(1));
        Console.WriteLine(client.GetListCount(listid));
        Task.Delay(1 * 1000).Wait();
        Console.WriteLine("1秒之后");
        Console.WriteLine(client.GetListCount(listid));
        //雪崩 问题：瞬间大量的数据消失-》大量的数据不要一下的全部消失
    }
    #endregion

    #region 从右侧向list中添加值，并设置过期时间 插队
    {
        client.FlushDb();
        var caocao = new UserInfo() { Id = 1, Name = "李太白" };
        client.AddItemToList(listid, JsonConvert.SerializeObject(caocao));
        var jiaxu = new UserInfo() { Id = 2, Name = "贾诩" };

        client.AddItemToList(listid, JsonConvert.SerializeObject(jiaxu));
        var gaunyu = new UserInfo() { Id = 3, Name = "关羽" };
        //向右追加就是插队
        client.PrependItemToList(listid, JsonConvert.SerializeObject(gaunyu));
        Console.WriteLine("ok");
        var caomegndeng = new UserInfo() { Id = 3, Name = "曹孟德" };
        client.PrependItemToList(listid, JsonConvert.SerializeObject(caomegndeng));
        client.ExpireEntryAt(listid, DateTime.Now.AddSeconds(1));
        Console.WriteLine(client.GetListCount(listid));
        Task.Delay(1 * 1000).Wait();
        Console.WriteLine("1秒之后");
        Console.WriteLine(client.GetListCount(listid));
    }
    #endregion

    #region  为key添加多个值
    {
        client.FlushDb();
        client.AddRangeToList(listid, new List<string>() { "001", "002", "003", "004" });
        //批量去读取list中的元素
        var lists = client.GetAllItemsFromList(listid);
        foreach (var item in lists)
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #region 获取key中下标为star到end的值集合
    {
        //获取listid中第0到第1个  ********************
        client.AddRangeToList(listid, new List<string>() { "001", "002", "003", "004" });
        var lists = client.GetRangeFromList(listid, 0, 1);//从下标0到1的值
        foreach (var item in lists)
        {
            Console.WriteLine(item);
        }
    }
    #endregion

    #region  list 队列和集合操作
    {
        client.FlushDb();
        var caocao = new UserInfo() { Id = 1, Name = "李太白" };
        client.AddItemToList(listid, JsonConvert.SerializeObject(caocao));
        var jiaxu = new UserInfo() { Id = 2, Name = "贾诩" };
        client.AddItemToList(listid, JsonConvert.SerializeObject(jiaxu));
        var gaunyu = new UserInfo() { Id = 3, Name = "关羽" };
        client.AddItemToList(listid, JsonConvert.SerializeObject(gaunyu));
        //移除尾部 并返回移除的数据 先删再给数据
        {
            Console.WriteLine(client.RemoveEndFromList(listid));
            foreach (var item in client.GetAllItemsFromList(listid))
            {
                Console.WriteLine(JsonConvert.DeserializeObject<UserInfo>(item).Name);
            }
        }
        //移除头部并返回移除的数据
        {
            Console.WriteLine(client.RemoveStartFromList(listid));
            foreach (var item in client.GetAllItemsFromList(listid))
            {
                Console.WriteLine(JsonConvert.DeserializeObject<UserInfo>(item).Name);
            }
        }

        //从一个list的尾部移除一个数据，添加到另外一个list的头部，并返回移动的值
        {
            Console.WriteLine(client.PopAndPushItemBetweenLists(listid, "newlist"));
            Console.WriteLine("移动之后新队列的元素结果");
            Console.WriteLine(client.GetItemFromList("newlist", 0));
        }
        //根据下标获取想要的集合元素，不做移除操作
        {
            var userstr = client.GetItemFromList(listid, 0);
            Console.WriteLine(JsonConvert.DeserializeObject<UserInfo>(userstr).Name);
        }
        //修改当前下标的结果
        {
            client.SetItemInList(listid, 0, "new value");
        }
    }
    #endregion

}

list数据结构：双向链表（一个元素的结尾记录了下一个元素的指针，这个元素的开头记录了上一个元素的指针），适合做增删动作，直接把链子打开插进去就可以了。