Spring RedisTemplate常用方法(List,Hash)

Posted 2022-04-23 passedbylove

@Autowired
private RedisTemplate<String, String> redisTemplate;

 @Override
    public List<String> getCachedList(String key)
    
        Long size = getCachedListSize(key);
        Long end = size - 1;
        return getCachedListByRange(key,0L,end);
    

@Override
    public Long getCachedListSize(String key)
    
        return redisTemplate.opsForList().size(key);
    

 @Override
    public List<String> getCachedListByRange(String key, Long start, Long end)
    
        return redisTemplate.opsForList().range(key,start,end);
    

@Override
    public <T> List<T> getCachedList(List<String> jsons, Class<T> targetClass)
    
        if(CollectionUtils.isEmpty(jsons))
        
            return Collections.emptyList();
        
        return jsons.stream().map(json->JSON.parseObject(json,targetClass)).collect(Collectors.toCollection(LinkedList::new));
    


  @Override
    public <T> List<T> getCachedList(String snapshotKey, String ipAddr, final Predicate<? super T> filter, Class<T> targetClass)
    
        List<T> list = getCachedList(snapshotKey,ipAddr, targetClass);

        if(CollectionUtils.isEmpty(list))
        
            return Collections.emptyList();
        
        return list.parallelStream().filter(filter).collect(Collectors.toList());
    

 

hash操作

    @Override
    public <T> Map<String,T>  getCachedKV(String cachedKey, String hashKey, Long nodeId, Class<T> targetClass)
    
        String statusId = String.format("%s:nodeId%d", cachedKey,nodeId);

        List<Map<String,T>> list = getCachedKV(statusId,targetClass);
        if(CollectionUtils.isEmpty(list))
        
            return Collections.emptyMap();
        
        Optional<Map<String, T>> matched = list.stream().filter(map -> 
            return map.keySet().contains(hashKey);
        ).findFirst();

        if(matched.isPresent()) 
            return matched.get();
        
        return Collections.emptyMap();
    
    @Override
    public <T> List<Map<String,T>> getCachedKV(String cachedId, Class<T> targetClass)
    
        Map<Object, Object> memCached = redisTemplate.opsForHash().entries(cachedId);
        if (MapUtils.isEmpty(memCached)) 
            return Collections.emptyList();
        
        List<Map<String,T>> list = new LinkedList<Map<String,T>>();

        for(Map.Entry<Object,Object> entry:memCached.entrySet())
        
            String key = (String)entry.getKey();
            String json = (String)entry.getValue();
            list.add(Collections.singletonMap(key,JSON.parseObject(json,targetClass)));
        
        return list;
    

    @Override
    public <T> T getStatus(String statusKey, String hashKey, Long nodeId, Class<T> targetClass)
    
        Map<String, T> result = getCachedKV(statusKey, hashKey, nodeId, targetClass);

        if(!result.isEmpty())
        
            Optional<T> entity = result.values().stream().findFirst();
            if(entity.isPresent())
            
                return entity.get();
            
        

        return null;
    

    @Override
    public <T> T getCachedObjectFromList(String cacheId, Class<T> targetClass)
    
        List<T> list = new LinkedList<>();

        Map<Object, Object> memCached = redisTemplate.opsForHash().entries(cacheId);

        Optional<String> matched = memCached.values().stream().map(String::valueOf).findFirst();
        if(matched.isPresent())
        
            String json = matched.get();
            return JSON.parseObject(json,targetClass);
        
        return null;
    

    @Override
    public List<SnmpNode> getCachedNodes()
    
        return getHashValues(CACHED_NODE,SnmpNode.class);
    

    @Override
    public <T> List<T> getHashValues(String cacheId, Class<T> targetClass)
    
        List<T> list = new LinkedList<>();

        Map<Object, Object> memCached = redisTemplate.opsForHash().entries(cacheId);
        if(MapUtils.isEmpty(memCached))
        
            return Collections.synchronizedList(Collections.emptyList());
        

        for (Map.Entry<Object, Object> entry : memCached.entrySet()) 
            String key = (String) entry.getKey();
            String json = (String) entry.getValue();
            T instance = JSON.parseObject(json,targetClass);
            log.debug("[email protected]查询到的数据,key:,val:",cacheId,key,json);
            list.add(instance);
        
        return list;