C# 通过ServiceStack 操作Redis——ZSet类型的使用及示例

2023-10-21 18:40:17 浏览数 (1)

Sorted Sets是将 Set 中的元素增加了一个权重参数 score,使得集合中的元素能够按 score 进行有序排列

代码语言:javascript复制
    /// <summary>
    /// Sorted Sets是将 Set 中的元素增加了一个权重参数 score,使得集合中的元素能够按 score 进行有序排列
    /// 1.带有权重的元素,比如一个游戏的用户得分排行榜
    /// 2.比较复杂的数据结构,一般用到的场景不算太多
    /// </summary>
    public class RedisZSetService : RedisBase
    {
        #region 添加
        /// <summary>
        /// 添加key/value,默认分数是从1.多*10的9次方以此递增的,自带自增效果
        /// </summary>
        public bool Add(string key, string value)
        {
            return base.iClient.AddItemToSortedSet(key, value);
        }
        /// <summary>
        /// 添加key/value,并设置value的分数
        /// </summary>
        public bool AddItemToSortedSet(string key, string value, double score)
        {
            return base.iClient.AddItemToSortedSet(key, value, score);
        }
        /// <summary>
        /// 为key添加values集合,values集合中每个value的分数设置为score
        /// </summary>
        public bool AddRangeToSortedSet(string key, List<string> values, double score)
        {
            return base.iClient.AddRangeToSortedSet(key, values, score);
        }
        /// <summary>
        /// 为key添加values集合,values集合中每个value的分数设置为score
        /// </summary>
        public bool AddRangeToSortedSet(string key, List<string> values, long score)
        {
            return base.iClient.AddRangeToSortedSet(key, values, score);
        }
        #endregion

        #region 获取
        /// <summary>
        /// 获取key的所有集合
        /// </summary>
        public List<string> GetAll(string key)
        {
            return base.iClient.GetAllItemsFromSortedSet(key);
        }
        /// <summary>
        /// 获取key的所有集合,倒叙输出
        /// </summary>
        public List<string> GetAllDesc(string key)
        {
            return base.iClient.GetAllItemsFromSortedSetDesc(key);
        }
        /// <summary>
        /// 获取集合,带分数
        /// </summary>
        public IDictionary<string, double> GetAllWithScoresFromSortedSet(string key)
        {
            return base.iClient.GetAllWithScoresFromSortedSet(key);
        }
        /// <summary>
        /// 获取key为value的下标值
        /// </summary>
        public long GetItemIndexInSortedSet(string key, string value)
        {
            return base.iClient.GetItemIndexInSortedSet(key, value);
        }
        /// <summary>
        /// 倒叙排列获取key为value的下标值
        /// </summary>
        public long GetItemIndexInSortedSetDesc(string key, string value)
        {
            return base.iClient.GetItemIndexInSortedSetDesc(key, value);
        }
        /// <summary>
        /// 获取key为value的分数
        /// </summary>
        public double GetItemScoreInSortedSet(string key, string value)
        {
            return base.iClient.GetItemScoreInSortedSet(key, value);
        }
        /// <summary>
        /// 获取key所有集合的数据总数
        /// </summary>
        public long GetSortedSetCount(string key)
        {
            return base.iClient.GetSortedSetCount(key);
        }
        /// <summary>
        /// key集合数据从分数为fromscore到分数为toscore的数据总数
        /// </summary>
        public long GetSortedSetCount(string key, double fromScore, double toScore)
        {
            return base.iClient.GetSortedSetCount(key, fromScore, toScore);
        }
        /// <summary>
        /// 获取key集合从高分到低分排序数据,分数从fromscore到分数为toscore的数据
        /// </summary>
        public List<string> GetRangeFromSortedSetByHighestScore(string key, double fromscore, double toscore)
        {
            return base.iClient.GetRangeFromSortedSetByHighestScore(key, fromscore, toscore);
        }
        /// <summary>
        /// 获取key集合从低分到高分排序数据,分数从fromscore到分数为toscore的数据
        /// </summary>
        public List<string> GetRangeFromSortedSetByLowestScore(string key, double fromscore, double toscore)
        {
            return base.iClient.GetRangeFromSortedSetByLowestScore(key, fromscore, toscore);
        }
        /// <summary>
        /// 获取key集合从高分到低分排序数据,分数从fromscore到分数为toscore的数据,带分数
        /// </summary>
        public IDictionary<string, double> GetRangeWithScoresFromSortedSetByHighestScore(string key, double fromscore, double toscore)
        {
            return base.iClient.GetRangeWithScoresFromSortedSetByHighestScore(key, fromscore, toscore);
        }
        /// <summary>
        ///  获取key集合从低分到高分排序数据,分数从fromscore到分数为toscore的数据,带分数
        /// </summary>
        public IDictionary<string, double> GetRangeWithScoresFromSortedSetByLowestScore(string key, double fromscore, double toscore)
        {
            return base.iClient.GetRangeWithScoresFromSortedSetByLowestScore(key, fromscore, toscore);
        }
        /// <summary>
        ///  获取key集合数据,下标从fromRank到分数为toRank的数据
        /// </summary>
        public List<string> GetRangeFromSortedSet(string key, int fromRank, int toRank)
        {
            return base.iClient.GetRangeFromSortedSet(key, fromRank, toRank);
        }
        /// <summary>
        /// 获取key集合倒叙排列数据,下标从fromRank到分数为toRank的数据
        /// </summary>
        public List<string> GetRangeFromSortedSetDesc(string key, int fromRank, int toRank)
        {
            return base.iClient.GetRangeFromSortedSetDesc(key, fromRank, toRank);
        }
        /// <summary>
        /// 获取key集合数据,下标从fromRank到分数为toRank的数据,带分数
        /// </summary>
        public IDictionary<string, double> GetRangeWithScoresFromSortedSet(string key, int fromRank, int toRank)
        {
            return base.iClient.GetRangeWithScoresFromSortedSet(key, fromRank, toRank);
        }
        /// <summary>
        ///  获取key集合倒叙排列数据,下标从fromRank到分数为toRank的数据,带分数
        /// </summary>
        public IDictionary<string, double> GetRangeWithScoresFromSortedSetDesc(string key, int fromRank, int toRank)
        {
            return base.iClient.GetRangeWithScoresFromSortedSetDesc(key, fromRank, toRank);
        }
        #endregion

        #region 删除
        /// <summary>
        /// 删除key为value的数据
        /// </summary>
        public bool RemoveItemFromSortedSet(string key, string value)
        {
            return base.iClient.RemoveItemFromSortedSet(key, value);
        }
        /// <summary>
        /// 删除下标从minRank到maxRank的key集合数据
        /// </summary>
        public long RemoveRangeFromSortedSet(string key, int minRank, int maxRank)
        {
            return base.iClient.RemoveRangeFromSortedSet(key, minRank, maxRank);
        }
        /// <summary>
        /// 删除分数从fromscore到toscore的key集合数据
        /// </summary>
        public long RemoveRangeFromSortedSetByScore(string key, double fromscore, double toscore)
        {
            return base.iClient.RemoveRangeFromSortedSetByScore(key, fromscore, toscore);
        }
        /// <summary>
        /// 删除key集合中分数最大的数据
        /// </summary>
        public string PopItemWithHighestScoreFromSortedSet(string key)
        {
            return base.iClient.PopItemWithHighestScoreFromSortedSet(key);
        }
        /// <summary>
        /// 删除key集合中分数最小的数据
        /// </summary>
        public string PopItemWithLowestScoreFromSortedSet(string key)
        {
            return base.iClient.PopItemWithLowestScoreFromSortedSet(key);
        }
        #endregion

        #region 其它
        /// <summary>
        /// 判断key集合中是否存在value数据
        /// </summary>
        public bool SortedSetContainsItem(string key, string value)
        {
            return base.iClient.SortedSetContainsItem(key, value);
        }
        /// <summary>
        /// 为key集合值为value的数据,分数加scoreby,返回相加后的分数
        /// </summary>
        public double IncrementItemInSortedSet(string key, string value, double scoreBy)
        {
            return base.iClient.IncrementItemInSortedSet(key, value, scoreBy);
        }
        /// <summary>
        /// 获取keys多个集合的交集,并把交集添加的newkey集合中,返回交集数据的总数
        /// </summary>
        public long StoreIntersectFromSortedSets(string newkey, string[] keys)
        {
            return base.iClient.StoreIntersectFromSortedSets(newkey, keys);
        }
        /// <summary>
        /// 获取keys多个集合的并集,并把并集数据添加到newkey集合中,返回并集数据的总数
        /// </summary>
        public long StoreUnionFromSortedSets(string newkey, string[] keys)
        {
            return base.iClient.StoreUnionFromSortedSets(newkey, keys);
        }
        #endregion
    }

ServiceStack 程序集里面没有方法注解,我在这里将注解添加上去,有不当之处,欢迎指正、

代码语言:javascript复制
                //添加setId/value,默认分数是从1.多*10的9次方以此递增的,自带自增效果
                client.AddItemToSortedSet(setId, value);
                // 添加setId/value,并设置value的分数
                client.AddItemToSortedSet(setId, value, score);
                //获取setId的所有集合
                client.GetAllItemsFromSortedSet(setId);
                //获取setId的所有集合,倒叙输出
                client.GetAllItemsFromSortedSetDesc(setId);
                //获取setId集合,带分数
                client.GetAllWithScoresFromSortedSet(setId);
                //获取setId为value的下标值
                client.GetItemIndexInSortedSet(setId, value);
                //获取setId为value的分数
                client.GetItemScoreInSortedSet(setId, value);
                //获取setId所有集合的数据总数
                client.GetSortedSetCount(setId);
                // 获取setId集合从高分到低分排序数据,分数从fromScore到分数为toScore的数据
                client.GetRangeFromSortedSetByHighestScore(setId, fromScore, toScore);
                //获取setId集合从高分到低分排序数据,分数从fromScore到分数为toScore的数据,带分数
                client.GetRangeWithScoresFromSortedSetByHighestScore(setId, fromScore, toScore);
                //获取setId集合数据,下标从fromRank到分数为toRank的数据
                client.GetRangeFromSortedSet(setId, fromRank, toRank);
                ///获取setId集合数据,下标从fromRank到分数为toRank的数据,带分数
                client.GetRangeWithScoresFromSortedSet(setId, fromRank, toRank);
                // 删除setId集合中值为value的数据
                client.RemoveItemFromSortedSet(setId, value);
                //删除下标从minRank到maxRank的setId集合数据
                client.RemoveRangeFromSortedSet(setId, minRank, maxRank);
                //删除分数从fromScore到toScore的setId集合数据
                client.RemoveRangeFromSortedSetByScore(setId, fromScore, toScore);
                // 删除key集合中分数最大的数据
                client.PopItemWithHighestScoreFromSortedSet(setId);
                //判断setId集合中是否存在value数据
                client.SortedSetContainsItem(setId, value);
                //为setId集合值为value的数据,分数加incrementBy,返回相加后的分数
                client.IncrementItemInSortedSet(setId, value, incrementBy);
                // 获取setId多个集合的交集,并把交集添加的intoSetId集合中,返回交集数据的总数
                client.StoreIntersectFromSortedSets(intoSetId, setIds);
                /// 获取setId多个集合的并集,并把交集添加的intoSetId集合中,返回交集数据的总数
                client.StoreUnionFromSortedSets(intoSetId, setIds);

添加

代码语言:javascript复制
                //1. 增加
                client.AddItemToSortedSet("一年级", "zxl_1", 1);
                for (int i = 2; i < 11; i  )
                {
                    client.AddItemToSortedSet("一年级", "zxl_" i, i);
                }
                //会覆盖前面的score
                client.AddItemToSortedSet("一年级", "zxl_1", 100);
                //1.1  如果没有这个value,会默认添加进去
                var dd1= client.IncrementItemInSortedSet("一年级", "zxl", 100);

                var dd2 = client.IncrementItemInSortedSet("一年级", "zxl", -30);

 获取

代码语言:javascript复制
                //2.获取
                //2.1 升序获取setId="一年级"的value值
                var dd3 = client.GetAllItemsFromSortedSet("一年级");
                //2.2降序获取setId="一年级"的value值
                var dd4 = client.GetAllItemsFromSortedSetDesc("一年级");
                //2.3 降序获取排名前4的value值
                var dd5 = client.GetRangeFromSortedSet("一年级", 0, 3);
                //2.3 降序获取排名前4的value值,带分数
                var dd6 = client.GetRangeWithScoresFromSortedSet("一年级", 0, 3);
                //2.4 降序获取分数在【2,6】分内的值
                var dd7 = client.GetRangeFromSortedSetByHighestScore("一年级", 2, 6);
                //2.5 获取指定setId集合中 zxl_2值得 分数
                var dd8=  client.GetItemScoreInSortedSet("一年级", "zxl_2");
                //2.6 获取集合的数量
               var dd9= client.GetSortedSetCount("一年级");

删除

代码语言:javascript复制
                //3.删除
                //3.1 setId集合中删除最高分
                client.PopItemWithHighestScoreFromSortedSet("一年级");
代码语言:javascript复制
                //3.2 setId集合中删除setId中指定value
                client.RemoveItemFromSortedSet("一年级", "zxl_2");
代码语言:javascript复制
                //3.3 setId集合中删除下标从1到2的数据
                client.RemoveRangeFromSortedSet("一年级", 1, 2);
代码语言:javascript复制
                //3.4 setId集合中删除分数从fromScore到toScore的setId集合数据
                client.RemoveRangeFromSortedSetByScore("一年级", 8, 8);

 集合类型的操作,同Set类型一样的写法,这里就不重复了。

0 人点赞