Redis和Redis集群模糊匹配删除key

梦里梦外; 2022-02-19 02:45 925阅读 0赞

### Questions ###

在数据库内我们可以通过`like`关键字、`％`、`*`或者`REGEX`关键字进行模糊匹配。而在Redis内我们如何进行模糊匹配呢？集群情况`Redis Cluster`的情况是否和单机一致呢？前段时间我对于这个议题进行了调查和研究。

### 单节点的情况 ###

*  Jedis   
    参考`stackoverflow上的解答`，在Java内使用`Jedis`主要有如下2中写法:
    
        ### 方法1
        Set<String> keys = jedis.keys(pattern);
        for (String key : keys) {
            jedis.del(key);
        } 
        
        ### 方法2
        Jedis jedis = new Jedis("127.0.0.1");
        ScanParams scanParams = new ScanParams();
        scanParams.match("prifix*");
        scanParams.count(1000);
        ScanResult<String> result = jedis.scan(0,scanParams);
        result.getResult().forEach(key -> {
            jedis.del(key);
        });
        
        ### 注意scan方法由于某些bug在2.9版本内scan(int,ScanParams)改为了scan(String,ScanParams)。由于cursor的位数，方法有些调整。
    
     
 *  方法1，通过`keys`命令先寻找到所有符合的key，然后把它们删除；
 *  方法2，通过`scan`命令扫描所有符合的key，然后把它们删除。
 *  注意: Redis饰单线程模式，全局扫描的话有可能会导致`Redis`在一段时间内的卡顿情况发生。
 *  Redis-cli
 *  redis-cli keys 1.cn\*|xargs redis-cli del  
     
    
    ### Redis Cluster情况   在Redis Cluster情况与单节点多情况完全不太一样。 ###
    
    首先，Redis Cluster是将整个Redis 的hash槽分布在三台机器上，要想一下全部扫描出来，显然是不太现实的。  
    Redis内提供Hash-Tag，将相类似的键放在一台机器上。可以通过Hash-Tag进行扫描，可以剪短时间消耗。  
    最后需要考虑，主从集群节点的情况。  
    Hash-Tag  
    Hash-Tag 是用一个花括号将主要的Hash判断部分扩起来，例如\{hello1\}key1、｛hello1｝key2。一般Hash-tag一致的情况，键会存储在集群的同一台机器上。在Jedis 2.9版本提供了这样的扫描方法。   
    (PS . rediscluster是没有keys方法的)  
     
    
        public static void deleteRedisKeyStartWith(String redisKeyStartWith) {
                try{
                    jedisCluster.getClusterNodes();
        
                    ScanParams scanParams = new ScanParams();
        //          scanParams.match("{123}keys*");
        
        //          scanParams.count(1000);
                    ScanResult<String> result = jedisCluster.scan("0", scanParams);
                    result.getResult().forEach(key -> {
                        jedisCluster.del(key);
                    });
        //          jedisCluster.del(wrapperKey(redisKeyStartWith)+".*");
                    log.info("success deleted redisKeyStartWith:{}", redisKeyStartWith);
                }finally{
                }
            }
    
    ### 土办法 分别扫描各个hash槽     ###
    
        public static void deleteRedisKeyStartWith(String redisKeyStartWith) {
                try {
                    Map<String, JedisPool> clusterNodes = jedisCluster.getClusterNodes();
        
                    for (Map.Entry<String, JedisPool> entry : clusterNodes.entrySet()) {
                        Jedis jedis = entry.getValue().getResource();
                        // 判断非从节点(因为若主从复制，从节点会跟随主节点的变化而变化)
                        if (!jedis.info("replication").contains("role:slave")) {
                            Set<String> keys = jedis.keys(redisKeyStartWith + "*");
                            if (keys.size() > 0) {
                                Map<Integer, List<String>> map = new HashMap<>();
                                for (String key : keys) {
                                    // cluster模式执行多key操作的时候，这些key必须在同一个slot上，不然会报:JedisDataException:
                                    // CROSSSLOT Keys in request don't hash to the same slot
                                    int slot = JedisClusterCRC16.getSlot(key);
                                    // 按slot将key分组，相同slot的key一起提交
                                    if (map.containsKey(slot)) {
                                        map.get(slot).add(key);
                                    } else {
                                        map.put(slot, Lists.newArrayList(key));
                                    }
                                }
                                for (Map.Entry<Integer, List<String>> integerListEntry : map.entrySet()) {
                                    jedis.del(integerListEntry.getValue().toArray(new String[integerListEntry.getValue().size()]));
                                }
                            }
                        }
                    }
                    log.info("success deleted redisKeyStartWith:{}", redisKeyStartWith);
                } finally {
                }
            }
    
        //### 未使用slot批次提交(有可能效率略差于前者)
        //获取jedis连接
        
                 private JedisCluster jedisCluster=JedisClusterUtil.getJedisCluster();
        
                 //@param pattern  获取key的前缀  全是是 * 
        
         public static TreeSet<String> keys(String pattern){  
        
        
               TreeSet<String> keys = new TreeSet<>();  
                //获取所有的节点
        
                       Map<String, JedisPool> clusterNodes = jedisCluster.getClusterNodes();  
               //遍历节点 获取所有符合条件的KEY 
        
                       for(String k : clusterNodes.keySet()){  
                   logger.debug("Getting keys from: {}", k);  
                   JedisPool jp = clusterNodes.get(k);  
                   Jedis connection = jp.getResource();  
                   try {  
                       keys.addAll(connection.keys(pattern));  
                   } catch(Exception e){  
                       logger.error("Getting keys error: {}", e);  
                   } finally{  
                       logger.debug("Connection closed.");  
                       connection.close();//用完一定要close这个链接！！！  
                   }  
               }  
               logger.debug("Keys gotten!");  
               return keys;  
          }  
        
                  //main方法
        
         public static void main(String[] args ){
         TreeSet<String> keys=keys("*");
        
         //遍历key  进行删除  可以用多线程
        
         for(String key:keys){
        
                                  jedisCluster.del(key);
         System.out.println(key);
         }
         }
    
     
 *  ### 原文地址:[https://blog.csdn.net/u010416101/article/details/80754171][https_blog.csdn.net_u010416101_article_details_80754171] ###

### [点赞或者评论是我最大的动力,有问题欢迎留言或者联系q:1559810637  ][https_blog.csdn.net_u010416101_article_details_80754171]     ###

[https_blog.csdn.net_u010416101_article_details_80754171]: https://blog.csdn.net/u010416101/article/details/80754171