redis-redisTemplate模糊匹配删除

前几天需要一个模糊删除redis中key的功能, 没有多想,  直接

　　　　　　　　String key = "noteUserListenedPoi:*";
            redisTemplate.delete(key);
            LOGGER.info("redis中用户收听历史被清空");

结果发现不行, 

后来测试发现模糊查询是可以用的, 找了下资料, 改成

Set<String> keys = redisTemplate.keys("noteUserListenedPoi:" + "*");
            redisTemplate.delete(keys);
            LOGGER.info("{}, redis中用户收听历史被清空"

可以用了

Redis模糊查询

可以通过Redis中keys命令进行获取key值，具体命令格式：keys pattern

文中提到redis中允许模糊查询的有3个通配符，分别是：*，?，[]

其中：

*：通配任意多个字符

?：通配单个字符

[]：通配括号内的某一个字符

public Set keys(String pattern){
　　return stringRedisTemplate.keys("*" + pattern + "*");
   // return stringRedisTemplate.keys("?" + pattern);
　　// return stringRedisTemplate.keys("[" + pattern + "]");
}

批量查询

Set<String> keysList = stringRedisTemplate.keys(keys);
List<String> strings = stringRedisTemplate.opsForValue().multiGet(keysList);

单个

 redisTemplate.opsForValue().set(keys+1,"this is a test content!",1000,TimeUnit.SECONDS);
        String content=redisTemplate.opsForValue().get(keys+1).toString();
        System.out.println("---------》获取到缓存的内容为："+content);
        redisTemplate.delete(redisTemplate.keys(keys+"*"));
        Object msg=redisTemplate.opsForValue().get(keys+1);

批量设置或者查询

1、利用mGet

List<String> keys = new ArrayList<>();
//初始keys
List<YourObject> list = this.redisTemplate.opsForValue().multiGet(keys);

2、利用PipeLine

public void getBatch(List<String> keys, long expireTime) {
        //使用pipeline方式
        redisTemplate.executePipelined(new RedisCallback<List<Object>>() {
            @Override
            public List<Object> doInRedis(RedisConnection connection) throws DataAccessException {
                keys.forEach(e -> {
                    connection.get(redisTemplate.getKeySerializer().serialize(e))
                });
               
                return null;
            }
        });


    }

其实2者底层都是用到execute方法，multiGet在使用连接是没用到pipeline，一条命令直接传给Redis，Redis返回结果。而executePipelined实际上一条或多条命令，但是共用一个连接。

还有一点，就是查询返回的结果，和键的顺序是一一对应的，如果没查到，会返回null值。

批量设置Set 

1、利用mSet

Map<String,String> map= new HashMap<>();

this.redisTemplate.opsForValue().multiSet(map);

2、利用PipeLine

public void setBatch(Map<String, Map> map, long expireTime) {
        //使用pipeline方式
        redisTemplate.executePipelined(new RedisCallback<List<Object>>() {
            @Override
            public List<Object> doInRedis(RedisConnection connection) throws DataAccessException {
                map.forEach((key, value) -> {
                    if (expireTime > 0) {
                        connection.setEx(redisTemplate.getKeySerializer().serialize(key), expireTime, redisTemplate.getValueSerializer().serialize(value));
                    } else {
                        connection.set(redisTemplate.getKeySerializer().serialize(key), redisTemplate.getValueSerializer().serialize(value));
                    }

                });
                return null;
            }
        });


    }