Redis集群key查询和批量查询key

一、Redis集群key查询实现（scan）

1.  
   CommandObjects commandObjects = new CommandObjects();
2.  
   Set<String> keys = new HashSet<>();
3.  
   Map<String, ConnectionPool> map = jedisCluster.getClusterNodes();
4.  
   for(Map.Entry<String, ConnectionPool> entry: map.entrySet()){
5.  
   Connection connection = entry.getValue().getResource();
6.  
   ScanResult<String> scanResult = connection.executeCommand(commandObjects.scan("0", new ScanParams().match(keyMatch).count(Integer.MAX_VALUE)));
7.  
   if(scanResult.getResult()!=null){
8.  
   keys.addAll(scanResult.getResult());
9.  
   }
10.  
    }

二、Redis集群key批量查询实现（mget）

1.  
    
2.  
   CommandObjects commandObjects = new CommandObjects();
3.  
    
4.  
   Map<Connection, List<String>> keyMap = new HashMap<>();
5.  
   for(String key: keys){
6.  
   Connection connection = jedisCluster.getConnectionFromSlot(JedisClusterCRC16.getSlot(key));
7.  
   List<String> keyList = keyMap.get(connection);
8.  
   if(keyList == null){
9.  
   keyList = new LinkedList<>();
10.  
    keyMap.put(connection, keyList);
11.  
    }
12.  
    keyList.add(key);
13.  
    }
14.  
     
15.  
    Map<String, String> keyValueMap = new HashMap<>();
16.  
    for(Map.Entry<Connection, List<String>> entry: keyMap.entrySet()){
17.  
    Connection connection = entry.getKey();
18.  
    String[] keyArr = entry.getValue().toArray(new String[0]);
19.  
    List<String> values = connection.executeCommand(commandObjects.mget(keyArr));
20.  
    for(int i=0; i< keyArr.length; i ){
21.  
    String value = values.get(i);
22.  
    if(value != null){
23.  
    keyValueMap.put(keyArr[i], value);
24.  
    }
25.  
    }
26.  
    }