2024.12.9 RedisCache 模糊匹配和删除命令优化,同时优化mybatis的yml配置

gemho-admin/src/main/resources/application.yml

@@ -93,7 +93,6 @@ mybatis-plus:
   configuration:
     map-underscore-to-camel-case: true
     log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl
-  config-location: classpath:mybatis-config.xml
 
 # PageHelper分页插件
 pagehelper:

gemho-common/src/main/java/com/gemho/common/core/redis/RedisCache.java

 package com.gemho.common.core.redis;
 
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
+
+import com.alibaba.fastjson2.JSONObject;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.redis.core.BoundSetOperations;
-import org.springframework.data.redis.core.HashOperations;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.ValueOperations;
+import org.springframework.data.redis.connection.RedisClusterConnection;
+import org.springframework.data.redis.connection.RedisClusterNode;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.jedis.JedisClusterConnection;
+import org.springframework.data.redis.core.*;
 import org.springframework.stereotype.Component;
 
 /**
@@ -20,6 +21,7 @@ import org.springframework.stereotype.Component;
  **/
 @SuppressWarnings(value = { "unchecked", "rawtypes" })
 @Component
+@Slf4j
 public class RedisCache
 {
     @Autowired
@@ -115,8 +117,7 @@ public class RedisCache
      */
     public boolean deleteObject(final String key)
     {
-        return redisTemplate.delete(key);
-    }
+        return  redisTemplate.unlink(key);}
 
     /**
      * 删除集合对象
@@ -126,7 +127,7 @@ public class RedisCache
      */
     public boolean deleteObject(final Collection collection)
     {
-        return redisTemplate.delete(collection) > 0;
+        return redisTemplate.unlink(collection) > 0;
     }
 
     /**
@@ -243,6 +244,7 @@ public class RedisCache
         return redisTemplate.opsForHash().multiGet(key, hKeys);
     }
 
+
     /**
      * 删除Hash中的某条数据
      *
@@ -265,4 +267,61 @@ public class RedisCache
     {
         return redisTemplate.keys(pattern);
     }
+    private static final Integer SCAN_COUNT = 10000;
+
+    /**
+     * 使用scan遍历key
+     * 为什么不使用keys 因为Keys会引发Redis锁，并且增加Redis的CPU占用,特别是数据庞大的情况下。这个命令千万别在生产环境乱用。
+     * 支持redis单节点和集群调用
+     *
+     * @param matchKey
+     * @return
+     */
+    public Set<String> scanMatch(String matchKey) {
+        Set<String> keys = new HashSet();
+        RedisConnectionFactory connectionFactory = redisTemplate.getConnectionFactory();
+        RedisConnection redisConnection = connectionFactory.getConnection();
+        Cursor<byte[]> scan = null;
+        //集群
+        if (redisConnection instanceof JedisClusterConnection) {
+            RedisClusterConnection clusterConnection = connectionFactory.getClusterConnection();
+            Iterable<RedisClusterNode> redisClusterNodes = clusterConnection.clusterGetNodes();
+            Iterator<RedisClusterNode> iterator = redisClusterNodes.iterator();
+            while (iterator.hasNext()) {
+                RedisClusterNode next = iterator.next();
+                scan = clusterConnection.scan(next, ScanOptions.scanOptions().match(matchKey).count(Integer.MAX_VALUE).build());
+                while (scan.hasNext()) {
+                    keys.add(new String(scan.next()));
+                }
+                try {
+                    if (scan != null) {
+                        scan.close();
+                    }
+                } catch (Exception e) {
+                    log.error("scan遍历key关闭游标异常", e);
+                }
+            }
+            log.info(JSONObject.toJSONString(keys));
+            return keys;
+        }
+        //单机 (redisConnection instanceof JedisConnection)
+        else {
+            scan = redisConnection.scan(ScanOptions.scanOptions().match(matchKey + "*").count(SCAN_COUNT).build());
+            while (scan.hasNext()) {
+                //找到一次就添加一次
+                keys.add(new String(scan.next()));
+            }
+            try {
+                if (scan != null) {
+                    scan.close();
+                }
+            } catch (Exception e) {
+                log.error("scan遍历key关闭游标异常", e);
+            }
+            return keys;
+        }
+
+        //return keys;
+
+    }
 }