Redis 有序集合(sorted set)

Redis 有序集合和集合一样也是string类型元素的集合,且不允许重复的成员。

不同的是每个元素都会关联一个double类型的分数。redis正是通过分数来为集合中的成员进行从小到大的排序。

有序集合的成员是唯一的,但分数(score)却可以重复。

集合是通过哈希表实现的,所以添加,删除,查找的复杂度都是O(1)。 集合中最大的成员数为 232 - 1 (4294967295, 每个集合可存储40多亿个成员)。

操作方法

方法列表

方法名称参数说明备注
zAdd$key, $score1, $member1, …$data向有序集合添加一个或多个成员,或者更新已存在成员的分数
zCard$key获取有序集合的成员数
zCount$key, $min, $max计算在有序集合中指定区间分数的成员数
zInCrBy$key, $increment, $member有序集合中对指定成员的分数加上增量 increment
zInTerStore$destination, array $keys, array $weights = [], $aggregate = ‘SUM’计算给定的一个或多个有序集的交集并将结果集存储在新的有序集合 key 中
zLexCount$key, $min, $max在有序集合中计算指定字典区间内成员数量
zRange$key, $start, $stop, $withScores = false通过索引区间返回有序集合指定区间内的成员
zRangeByLex$key, $min, $max, …$data通过字典区间返回有序集合的成员
zRangeByScore$key, $min, $max, array $options通过分数返回有序集合指定区间内的成员
zRank$key, $member返回有序集合中指定成员的索引
zRem$key, $member, …$members移除有序集合中的一个或多个成员
zRemRangeByLex$key, $min, $max移除有序集合中给定的字典区间的所有成员
zRemRangeByRank$key, $start, $stop移除有序集合中给定的排名区间的所有成员
zRemRangeByScore$key, $min, $max移除有序集合中给定的分数区间的所有成员
zRevRange$key, $start, $stop, $withScores = false返回有序集中指定区间内的成员,通过索引,分数从高到低
zRevRangeByScore$key, $max, $min, array $options返回有序集中指定分数区间内的成员,分数从高到低排序
zRevRank$key, $member返回有序集合中指定成员的排名,有序集成员按分数值递减(从大到小)排序
zScore$key, $member返回有序集中,成员的分数值
zUnionStore$destination, array $keys, array $weights = [], $aggregate = ‘SUM’计算给定的一个或多个有序集的并集,并存储在新的 key 中
zScan$key,&$cursor, $pattern=null, $count=null迭代有序集合中的元素(包括元素成员和元素分值)

在集群模式中,zInTerStore,zUnionStore 等方法不能使用

基本使用

  1. go(function (){
  2. $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  3. 'host' => '127.0.0.1',
  4. 'port' => '6379',
  5. 'auth' => 'easyswoole',
  6. 'serialize' => \EasySwoole\Redis\Config\RedisConfig::SERIALIZE_NONE
  7. ]));
  8. $key = [
  9. 'sortMuster1',
  10. 'sortMuster2',
  11. 'sortMuster3',
  12. 'sortMuster4',
  13. 'sortMuster5',
  14. ];
  15. $member = [
  16. 'member1',
  17. 'member2',
  18. 'member3',
  19. 'member4',
  20. 'member5',
  21. ];
  22. $score = [
  23. 1,
  24. 2,
  25. 3,
  26. 4,
  27. ];
  28. $redis->del($key[0]);
  29. $data = $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1]);
  30. var_dump($data);
  31. $data = $redis->zCard($key[0]);
  32. var_dump($data);
  33. $data = $redis->zCount($key[0], 0, 3);
  34. var_dump($data);
  35. $data = $redis->zInCrBy($key[0], 1, $member[1]);
  36. var_dump($data);
  37. $redis->del($key[0]);
  38. $redis->del($key[1]);
  39. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1]);
  40. $redis->zAdd($key[1], $score[0], $member[0], $score[3], $member[3]);
  41. $data = $redis->zInTerStore($key[2], [$key[0], $key[1]], [1, 2]);
  42. var_dump($data);
  43. $data = $redis->zLexCount($key[0], '-', '+');
  44. var_dump($data);
  45. $redis->del($key[0]);
  46. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1], $score[2], $member[2]);
  47. $data = $redis->zRange($key[0], 0, -1, true);
  48. var_dump($data);
  49. $data = $redis->zRangeByLex($key[0], '-', '+');
  50. var_dump($data);
  51. $data = $redis->zRangeByScore($key[0], 2, 3, ['withScores' => true, 'limit' => array(0, 2)]);
  52. var_dump($data);
  53. $data = $redis->zRank($key[0], $member[1]);
  54. var_dump($data);
  55. $data = $redis->zRem($key[0], $member[1], $member[2]);
  56. var_dump($data);
  57. $redis->del($key[0]);
  58. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1], $score[2], $member[2]);
  59. $data = $redis->zRemRangeByLex($key[0], '-', '+');
  60. var_dump($data);
  61. $redis->del($key[0]);
  62. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1], $score[2], $member[2]);
  63. $data = $redis->zRemRangeByRank($key[0], 0, 2);
  64. var_dump($data);
  65. $redis->del($key[0]);
  66. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1], $score[2], $member[2]);
  67. $data = $redis->zRemRangeByScore($key[0], 0, 3);
  68. var_dump($data);
  69. $redis->del($key[0]);
  70. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1], $score[2], $member[2]);
  71. $data = $redis->zRevRange($key[0], 0, 3, true);
  72. var_dump($data);
  73. $redis->del($key[0]);
  74. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1], $score[2], $member[2]);
  75. $data = $redis->zRevRangeByScore($key[0], 3, 0, ['withScores' => true, 'limit' => array(0, 3)]);
  76. var_dump($data);
  77. $data = $redis->zRevRank($key[0], $member[0]);
  78. var_dump($data);
  79. $data = $redis->zScore($key[0], $member[0]);
  80. var_dump($data);
  81. $redis->del($key[0]);
  82. $redis->del($key[1]);
  83. $redis->del($key[2]);
  84. $redis->zAdd($key[0], $score[0], $member[0], $score[1], $member[1]);
  85. $redis->zAdd($key[1], $score[0], $member[0], $score[3], $member[3]);
  86. $data = $redis->zUnionStore($key[2], [$key[1], $key[0]]);
  87. var_dump($data);
  88. $cursor = 0;
  89. $redis->del('a');
  90. $redis->zAdd('a',1,'a1',2,'a2',3,'a3',4,'a4',5,'a5');
  91. $data = [];
  92. do {
  93. $keys = $redis->zScan('a',$cursor,'*',1);
  94. $data = array_merge($data,$keys);
  95. } while ($cursor);
  96. var_dump($data);
  97. })