本题考察的知识点有如下几个:redis
咱们先来模拟海量数据,使用 Pipeline 添加 10w 条数据,Java 代码实现以下:bash
import redis.clients.jedis.Jedis;import redis.clients.jedis.Pipeline;import utils.JedisUtils;public class ScanExample { public static void main(String[] args) { // 添加 10w 条数据 initData(); } public static void initData(){ Jedis jedis = JedisUtils.getJedis(); Pipeline pipe = jedis.pipelined(); for (int i = 1; i < 100001; i++) { pipe.set("user_token_" + i, "id" + i); } // 执行命令 pipe.sync(); System.out.println("数据插入完成"); }}
复制代码
咱们来查询用户 id 为 9999* 的数据,Scan 命令使用以下:服务器
127.0.0.1:6379> scan 0 match user_token_9999* count 100001) "127064"2) 1) "user_token_99997"127.0.0.1:6379> scan 127064 match user_token_9999* count 100001) "1740"2) 1) "user_token_9999"127.0.0.1:6379> scan 1740 match user_token_9999* count 100001) "21298"2) 1) "user_token_99996"127.0.0.1:6379> scan 21298 match user_token_9999* count 100001) "65382"2) (empty list or set)127.0.0.1:6379> scan 65382 match user_token_9999* count 100001) "78081"2) 1) "user_token_99998" 2) "user_token_99992"127.0.0.1:6379> scan 78081 match user_token_9999* count 100001) "3993"2) 1) "user_token_99994" 2) "user_token_99993"127.0.0.1:6379> scan 3993 match user_token_9999* count 100001) "13773"2) 1) "user_token_99995"127.0.0.1:6379> scan 13773 match user_token_9999* count 100001) "47923"2) (empty list or set)127.0.0.1:6379> scan 47923 match user_token_9999* count 100001) "59751"2) 1) "user_token_99990" 2) "user_token_99991" 3) "user_token_99999"127.0.0.1:6379> scan 59751 match user_token_9999* count 100001) "0"2) (empty list or set)
复制代码
从以上的执行结果,咱们看出两个问题:ide
相关语法:scan cursor [MATCH pattern] [COUNT count]
ui
其中:spa
本文咱们使用 Java 代码来实现 Scan 的查询功能,代码以下:code
import redis.clients.jedis.Jedis;import redis.clients.jedis.Pipeline;import redis.clients.jedis.ScanParams;import redis.clients.jedis.ScanResult;import utils.JedisUtils;public class ScanExample { public static void main(String[] args) { Jedis jedis = JedisUtils.getJedis(); // 定义 match 和 count 参数 ScanParams params = new ScanParams(); params.count(10000); params.match("user_token_9999*"); // 游标 String cursor = "0"; while (true) { ScanResult<String> res = jedis.scan(cursor, params); if (res.getCursor().equals("0")) { // 表示最后一条 break; } cursor = res.getCursor(); // 设置游标 for (String item : res.getResult()) { // 打印查询结果 System.out.println("查询结果:" + item); } } }}
复制代码
以上程序执行结果以下:orm
查询结果:user_token_99997cdn
查询结果:user_token_9999视频
查询结果:user_token_99996
查询结果:user_token_99998
查询结果:user_token_99992
查询结果:user_token_99994
查询结果:user_token_99993
查询结果:user_token_99995
查询结果:user_token_99990
查询结果:user_token_99991
查询结果:user_token_99999
经过本文咱们了解到,Redis 中若是要在海量的数据数据中,查询某个数据应该使用 Scan,Scan 具备如下特征:
视频版:www.bilibili.com/video/av880…
关注下面二维码,订阅更多精彩内容。