StackExchange.Redis 之 SortedSet 类型示例
2024-09-06 21:01:49
1,增加操作
RedisCacheHelper.Instance.ZSortadd("zsortkey", "A1", );
RedisCacheHelper.Instance.ZSortadd("zsortkey", "B1", );
RedisCacheHelper.Instance.ZSortadd("zsortkey", "C1", );
RedisCacheHelper.Instance.ZSortadd("zsortkey", "D1", );
RedisCacheHelper.Instance.ZSortadd("zsortkey", "", );
RedisCacheHelper.Instance.ZSortadd("zsortkey", "", );
RedisCacheHelper.Instance.ZSortadd("zsortkey", "", );
RedisCacheHelper.Instance.ZSortadd("zsortkey", "", );
RedisCacheHelper.Instance.ZSortIncr("zsortkey", "D1", ); //增加2
RedisCacheHelper.Instance.ZSortDecr("zsortkey", "A1", ); //减去1
//获取长度
var getlength = RedisCacheHelper.Instance.SortedSetLength("zsortkey");
Console.WriteLine(getlength); //移除某个元素
var getok = RedisCacheHelper.Instance.ZSortedRemove("zsortkey", "");
Console.WriteLine(getok); //获取榜单某个元素的排名
var getsort = RedisCacheHelper.Instance.ZSortedRank("zsortkey", "");
Console.WriteLine(getsort); //获取有序集合中的某个元素的值
//扩展的有
//SortedSetRangeByRank 根据索引获取member值,默认是升序,可以获取指定索引内的member值
//SortedSetRangeByScore：根据score获取member值,默认是升序,可以获取指定score开始和结束的member值,后面的skip和take用于分页
//SortedSetRangeByValue：根据member获取member值,默认是升序,可以获取指定member开始和结束的值,后面的skip和take用于分页
//SortedSetRangeByRankWithScores：获取member和score值，可以只返回 start-stop 这个索引排序内的值（默认升序），后面的skip和take用于分页 var getvalue = RedisCacheHelper.Instance.ZSortedScore("zsortkey", "");
Console.WriteLine(getvalue);
使用场景：
Redis sorted set 的使用场景与 set 类似，区别是 set 不是自动有序的，而 sorted set 可以通过用户额外提供一个优先级 (score) 的参数来为成员排序，并且是插入有序的，即自动排序。当你需要一个有序的并且不重复的集合列表，那么可以选择 sorted set 数据结构，比如 twitter 的 public timeline 可以以发表时间作为 score 来存储，这样获取时就是自动按时间排好序的。
实现方式：
Redis sorted set 的内部使用 HashMap 和跳跃表 (SkipList) 来保证数据的存储和有序，HashMap 里放的是成员到 score 的映射，而跳跃表里存放的是所有的成员，排序依据是 HashMap 里存的 score, 使用跳跃表的结构可以获得比较高的查找效率，并且在实现上比较简单。
这里附上Helper类
#region SortSet类型 有序集合
/// <summary>
/// 增加,可以一次增加一个member，也可以一次增加多个member
/// </summary>
/// <param name="key"></param>
/// <param name="member"></param>
/// <param name="score"></param>
/// <param name="db"></param>
/// <returns></returns>
public bool ZSortadd(string key, string member, double score, int db = -)
{
try
{
var _db = GetDatabase(db);
if ((object)key == null)
return false;
else
return _db.SortedSetAdd(key, member, score);
}
catch (Exception ex)
{
throw;
}
}
/// <summary>
/// 对Score值自增
/// 如果不存在这member值，则执行增加member操作，并返回当前Score值
/// </summary>
/// <param name="key">The key.</param>
/// <param name="member">The member.</param>
/// <param name="score">The score.</param>
/// <param name="db">The database.</param>
/// <returns></returns>
public double ZSortIncr(string key, string member, double score, int db = -)
{
try
{
var _db = GetDatabase(db);
if ((object)key == null)
return ;
else
return _db.SortedSetIncrement(key, member, score);
}
catch (Exception ex)
{
throw;
}
}
/// <summary>
/// 对Score值自减
/// 如果不存在这member值，则执行增加member操作，并返回当前Score值
/// </summary>
/// <param name="key">The key.</param>
/// <param name="member">The member.</param>
/// <param name="score">The score.</param>
/// <param name="db">The database.</param>
/// <returns></returns>
public double ZSortDecr(string key, string member, double score, int db = -)
{
try
{
var _db = GetDatabase(db);
if ((object)key == null)
return ;
else
return _db.SortedSetDecrement(key, member, score);
}
catch (Exception ex)
{
throw;
}
}
/// <summary>
/// 长度
/// </summary>
/// <param name="redisKey"></param>
/// <param name="db"></param>
/// <returns></returns>
public long SortedSetLength(string redisKey, int db = -)
{
var _db = GetDatabase(db);
return _db.SortedSetLength(redisKey);
}
/// <summary>
/// 移除某个元素
/// </summary>
/// <param name="key"></param>
/// <param name="memebr"></param>
/// <param name="db"></param>
/// <returns></returns>
public bool ZSortedRemove(string key, string memebr, int db = -)
{
try
{
var _db = GetDatabase(db);
if ((object)key == null)
return false;
else
return _db.SortedSetRemove(key, memebr);
}
catch (Exception)
{
return false;
}
}
/// <summary>
/// 获取榜单某个元素的排名、排行
/// </summary>
/// <param name="key"></param>
/// <param name="mumber"></param>
/// <param name="db"></param>
/// <returns></returns>
public double ZSortedRank(string key, string mumber, int db = -)
{
try
{
var _db = GetDatabase(db);
if ((object)key == null)
return ;
else
return _db.SortedSetRank(key, mumber) ?? ;
}
catch (Exception)
{
return ;
}
}
/// <summary>
/// 获取有序集合中的某个元素的值
/// </summary>
/// <param name="key">The key.</param>
/// <param name="member">The member.</param>
/// <param name="db">The database.</param>
/// <returns></returns>
public double ZSortedScore(string key, string member, int db = -)
{
try
{
var _db = GetDatabase(db);
if ((object)key == null)
return ;
else
return Convert.ToDouble(_db.SortedSetScore(key, member));
}
catch (Exception ex)
{
throw;
}
}
#endregion
最新文章
- android 自定义控件——（四）圆形进度条
- scheduletask任务调度
- Kaggle入门教程
- Microsoft Dynamics CRM 2013 and 2011 Update Rollups and Service Packs
- WAF指纹探测及识别技术<freebuf>
- Java虚拟机的启动与程序的执行
- QTP数据驱动之读取Excel数据
- mvn开发可执行的java程序
- AVAudioPlayer音频播放器－备用
- 更新-----Scripts：执行双网卡绑定
- Android中实现静态的默认安装和卸载应用
- 掌握下面常用函数，学php不再难
- python 学习 ［day7］面向对象
- [SinGuLaRiTy] ZKW线段树
- 第四十一篇-android studio 关闭自动保存功能
- Jupyter notbook& REVEAL.JS& nbconvert 使用jupyter notebook制作slides
- wpf 获取Image的图片并保存到本地
- file 文件处理
- Underscore.js 入门-常用方法介绍
- ELK 性能(1) — Logstash 性能及其替代方案