Redis删除、获取特定前缀key的优雅实现

秒速五厘米 2022-10-07 10:58 309阅读 0赞

# 一、数据量不大情况下，用keys #

Redis的单线程服务模式，命令keys会阻塞正常的业务请求。  
如果你一次keys匹配的数量过多或者在del的时候遇到大key，都会直接导致业务的不可用，甚至造成redis宕机的风险。  
删除

//删除所有以U:INFO:开头的key
         Set<String> keys1 = redisTemplate.keys("U:INFO:" + "*");  
         if (StringUtil.isNotNull(keys)) { 
                redisTemplate.delete(keys);
         }

查询

// *号 必须要加，否则无法模糊查询 
            //String prefix = "ofc-pincode-"+ pincode + "-*";
            // 批量获取所有的key
            Set<String> keys = redisTemplate.keys(prefix);      
            List<MyObject> myObjectListRedis = redisTemplate.opsForValue().multiGet(keys);
            List<MyObject> myObjectList = JSON.parseArray(myObjectListRedis.toString(), MyObject.class);
            log.info("myObjectList:{}",myObjectList.toString());

# 二、数据量大情况下，用scan #

类似的SCAN命令，对于Redis不同的数据类型还有另外几个**SSCAN**、**HSCAN**和**ZSCAN**，使用方法类似

/** * redis扩展工具 */
    public abstract class RedisHelper { 
        private static Logger logger = LoggerFactory.getLogger(RedisHelper.class);
     
        /** * scan 实现 * @param redisTemplate redisTemplate * @param pattern 表达式，如：abc*，找出所有以abc开始的键 */
        public static Set<String> scan(RedisTemplate<String, Object> redisTemplate, String pattern) { 
            return redisTemplate.execute((RedisCallback<Set<String>>) connection -> { 
                Set<String> keysTmp = new HashSet<>();
                try (Cursor<byte[]> cursor = connection.scan(new ScanOptions.ScanOptionsBuilder()
                        .match(pattern)
                        .count(10000).build())) { 
     
                    while (cursor.hasNext()) { 
                        keysTmp.add(new String(cursor.next(), "Utf-8"));
                    }
                } catch (Exception e) { 
                    logger.error(e.getMessage(), e);
                    throw new RuntimeException(e);
                }
                return keysTmp;
            });
        }
    }

SCAN 命令及其相关的 SSCAN 命令、 HSCAN 命令和 ZSCAN 命令都**用于增量地迭代** ，它们每次执行都**只会返回少量元素，不会阻塞服务器**， 所以这些命令可以用于生产环境， 而不会出现像 KEYS 命令、 SMEMBERS 命令带来的问题。

SCAN一样有它自己的问题：

> 1.因为是分段获取key，所以它会多次请求redis服务器，这样势必取同样的key，scan耗时更长。

> 2.在对键进行增量式迭代的过程中， 键可能会被修改， 所以增量式迭代命令只能对被返回的元素提供有限的保证。

**参考文章**  
https://www.cnblogs.com/37Y37/p/11037923.html  
https://blog.csdn.net/qq\_42643690/article/details/106234530  
https://javazhiyin.blog.csdn.net/article/details/104890232  
https://www.cnblogs.com/thiaoqueen/p/10919538.html