SCAN 命令及其相关的 SSCAN 命令、 HSCAN 命令和 ZSCAN 命令都用于增量地迭代(incrementally iterate)一集元素(a collection of elements):
- SCAN 命令用于迭代当前数据库中的数据库键。
- SSCAN 命令用于迭代集合键中的元素。
- HSCAN 命令用于迭代哈希键中的键值对。
- ZSCAN 命令用于迭代有序集合中的元素(包括元素成员和元素分值)。
SCAN
redis库所有KEY的数据集增量迭代器,可用于生产环境
时间复杂度
增量式迭代命令每次执行的复杂度为 O(count) , 对数据集进行一次完整迭代的复杂度为 O(N) , 其中 N 为数据集中的元素数量。
保证:
在遍历期间存在的元素在遍历的完整周期肯定在某次的遍历结果中;
游标从0开始,下次参数的游标使用上次返回的游标,游标结果重回0表示迭代完成。
缺点:
由于存在不断地添加,修改操作,迭代结果可能存在重复结果
其他特征
- 1、只要返回的游标不是初始状态(初始游标必须为 0),即使返回的结果集是空的也要继续迭代下去。
- 2、count选项的数量不一定等于结果集中的数量,大于或者为空都有可能,默认值为10
- 3、match使用glob风格的模式参数,值匹配跌的结果集中的数据
- 4、可以并发迭代,结果的游标代码当前的所有信息,无需记录
- 5、中途停止迭代、错误游标迭代无影响,- 6、错
- 6、只要count控制得当,相比keys、 smembers命令不会存在阻塞服务场景。
命令格式
scan 游标 [match "aa*"] [count 100]
返回结果
1)增量游标
2)key集合[每个元素都是一个数据库键]
match可以匹配scan的结果集,
count 可一直指定游标扫描数量 不易太大,测试5000以上会产生10ms的慢日志,建议不要超过1000
例如
192.168.0.7:20010> scan 0
1) "0"
2) 1) "test_hmap"
2) "test_sortset"
3) "maxmemory"
4) "test_set"
192.168.0.7:20010> scan 0 match test* count 10
1) "0"
2) 1) "test_hmap"
2) "test_sortset"
3) "test_set"
192.168.0.7:20010> scan 0 match "test*" count 10
1) "0"
2) 1) "test_hmap"
2) "test_sortset"
3) "test_set"
ZSCAN
命令格式
scan SORTSET集合KEY 游标 [match "aa*"] [count 100]
返回结果
1)增量游标
2)SortSet 成员元素集合[每个元素都是一个有序集合元素,一个有序集合元素由一个成员(member)和一个分值(score)组成。]
例如
192.168.0.7:20010> select 0
OK
192.168.0.7:20010> zadd test_sortset 1 1
(integer) 1
192.168.0.7:20010> zadd test_sortset 2 2
(integer) 1
192.168.0.7:20010> zscan test_sortset 0
1) "0"
2) 1) "1"
2) "1"
3) "2"
4) "2"
HSCAN
命令格式
scan 哈希表集合KEY 游标 [match "aa*"] [count 100]
返回结果
1)增量游标
2)hash表元素集合[每个元素都是一个键值对,一个键值对由一个键和一个值组成]
例如
192.168.0.7:20010> hset test_hmap 1 1
(integer) 1
192.168.0.7:20010> hset test_hmap 2 2
(integer) 1
192.168.0.7:20010> hget test_hmap 1
"1"
192.168.0.7:20010> hscan test_hmap 0
1) "0"
2) 1) "1"
2) "1"
3) "2"
4) "2"
SSCAN
返回结果
1)增量游标
2)set元素集合[每个元素都是一个集合成员。]
例如
192.168.0.7:20010> sadd test_set 1
(integer) 1
192.168.0.7:20010> sadd test_set 2
(integer) 1
192.168.0.7:20010> sscan test_set 0
1) "0"
2) 1) "1"
2) "2"
public static void main(String[] args) {
ScanParams scanParams = new ScanParams();
scanParams.count(1000);
ScanResult<String> s0 = MyJedis.scan("test", "0", scanParams);
if (s0 != null) {
String newCurSor = s0.getStringCursor();
System.out.println("newCurSor:" + newCurSor);
List<String> resultList = s0.getResult();
for (String t : resultList) {
System.out.println(t);
}
}
scanParams = new ScanParams();
scanParams.count(1000);
scanParams.match("1*");
ScanResult<Tuple> s1 = MyJedis.zscan("test", "test_sortset", "0", scanParams);
if (s1 != null) {
String newCurSor = s1.getStringCursor();
System.out.println("newCurSor:" + newCurSor);
List<Tuple> resultList = s1.getResult();
for (Tuple t : resultList) {
System.out.println(t.getElement() + " " + t.getScore());
}
}
ScanResult<Map.Entry<String, String>> s2 = MyJedis.hscan("test", "test_hmap", "0", scanParams);
if (s2 != null) {
String newCurSor = s2.getStringCursor();
System.out.println("newCurSor:" + newCurSor);
List<Map.Entry<String, String>> resultList = s2.getResult();
for (Map.Entry<String, String> t : resultList) {
System.out.println(t.getKey() + " " + t.getValue());
}
}
ScanResult<String> s3 = MyJedis.sscan("test", "test_set", "0", scanParams);
if (s3 != null) {
String newCurSor = s3.getStringCursor();
System.out.println("newCurSor:" + newCurSor);
List<String> resultList = s3.getResult();
for (String t : resultList) {
System.out.println(t);
}
}
}
newCurSor:0
test_hmap
test_sortset
maxmemory
test_set
newCurSor:0
1 1.0
newCurSor:0
1 1
newCurSor:0
1