本题考察的知识点有如下几个: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 10000 1) "127064" 2) 1) "user_token_99997" 127.0.0.1:6379> scan 127064 match user_token_9999* count 10000 1) "1740" 2) 1) "user_token_9999" 127.0.0.1:6379> scan 1740 match user_token_9999* count 10000 1) "21298" 2) 1) "user_token_99996" 127.0.0.1:6379> scan 21298 match user_token_9999* count 10000 1) "65382" 2) (empty list or set) 127.0.0.1:6379> scan 65382 match user_token_9999* count 10000 1) "78081" 2) 1) "user_token_99998" 2) "user_token_99992" 127.0.0.1:6379> scan 78081 match user_token_9999* count 10000 1) "3993" 2) 1) "user_token_99994" 2) "user_token_99993" 127.0.0.1:6379> scan 3993 match user_token_9999* count 10000 1) "13773" 2) 1) "user_token_99995" 127.0.0.1:6379> scan 13773 match user_token_9999* count 10000 1) "47923" 2) (empty list or set) 127.0.0.1:6379> scan 47923 match user_token_9999* count 10000 1) "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 10000 1) "0" 2) (empty list or set) 复制代码
从以上的执行结果,咱们看出两个问题:markdown
相关语法:scan cursor [MATCH pattern] [COUNT count]
ide
其中:oop
本文咱们使用 Java 代码来实现 Scan 的查询功能,代码以下:spa
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); } } } } 复制代码
以上程序执行结果以下:code
查询结果:user_token_99997orm
查询结果: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…
关注下面二维码,订阅更多精彩内容。