SpringBoot整合redis、RedisTemplate操作各个基本类型

mhr18 2024-11-13 11:07 33 浏览 0 评论

文章目录

①. SPRINGBOOT整合REDIS
②. redisTemplate操作String类型
③. redisTemplate操作list类型
④. redisTemplate操作hash类型
⑤. redisTemplate操作Set类型
⑥. redisTemplate操作zSet类型
⑦. redisTemplate其他操作

①. SPRINGBOOT整合REDIS

①. 引入data-redis-starter依赖

<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
   </dependency>

②. 简单配置redis的host等信息

spring:
  redis:
    host: 192.168.56.11
    port: 6379
    password: root

③. 查看RedisAutoConfiguration可以知道、封装了StringRedisTemplate给到我们使用,也导入了 LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class 这两个都是底层操作redis的

@Configuration
@ConditionalOnClass(RedisOperations.class)
@EnableConfigurationProperties(RedisProperties.class)
@Import({
  LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class })
public class RedisAutoConfiguration {
 
	@Bean
	//我们可以定义一个redisTemplate来替换这个默认的
	@ConditionalOnMissingBean(name = "redisTemplate")
	public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory)
			throws UnknownHostException {
 
		// 默认的RedisTemplate直接使用此类内部默认设置操作数据,但是Redis对象需要序列化
        // 泛型都是Object,后面使用的话,大都是RedisTemplate<String, Object>
		RedisTemplate<Object, Object> template = new RedisTemplate<>();
		template.setConnectionFactory(redisConnectionFactory);
		return template;
	}
	@Bean
	@ConditionalOnMissingBean
	//由于String是redis中最常用的类型,所以说单独提取出来一个bean
	public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory)
			throws UnknownHostException {
 
		StringRedisTemplate template = new StringRedisTemplate();
		template.setConnectionFactory(redisConnectionFactory);
		return template;
	}
}

④. 从SpringBoot2.x之后,原来使用的Jedis被lettuce替代。为什么会这样替换呢？

Jedis：采用直连,模拟多个线程操作会出现安全问题。为避免此问题,需要使用Jedis Pool连接池！类似于BIO模式
lettuce：采用netty网络框架,对象可以在多个线程中被共享,完美避免线程安全问题,减少线程数据,类似于NIO模式

⑤. redisTemplate使用的是JDK默认的序列化

127.0.0.1:6379> keys *
1) "ord:102"  序列化过
2) "\xac\xed\x00\x05t\x00\aord:102"  (野生,没有序列化过)

⑥. 抽取redisTemplate工具类,以后在公司中可以直接使用

@Configuration
public class RedisConfig {
 

  @Bean
  @SuppressWarnings("all")
  public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
 
      RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
      //配置具体的序列化方式
      template.setConnectionFactory(factory);
      //使用JSON取解析任意对象
      Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
      ObjectMapper om = new ObjectMapper();
      om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
      om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
      jackson2JsonRedisSerializer.setObjectMapper(om);

      // String的序列化
      StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
      // key采用String的序列化方式
      template.setKeySerializer(stringRedisSerializer);
      // hash的key也采用String的序列化方式
      template.setHashKeySerializer(stringRedisSerializer);
      // value序列化方式采用jackson
      template.setValueSerializer(jackson2JsonRedisSerializer);
      // hash的value序列化方式采用jackson
      template.setHashValueSerializer(jackson2JsonRedisSerializer);
      template.afterPropertiesSet();

      return template;
  }
}

②. redisTemplate操作String类型

1. 设置当前的key以及value值:
	redisTemplate.opsForValue().set(key, value)
2. 设置当前的key以及value值并且设置过期时间:
	redisTemplate.opsForValue().set(key, value, timeout, unit)
	TimeUnit.DAYS //天
	TimeUnit.HOURS //小时
	TimeUnit.MINUTES //分钟
	TimeUnit.SECONDS //秒
	TimeUnit.MILLISECONDS //毫秒
3. 在原有的值基础上新增字符串到末尾:
	redisTemplate.opsForValue().append(key, value)
4. 获取字符串的长度
	redisTemplate.opsForValue().size(key)
5. 重新设置key对应的值,如果存在返回false,否则返回true
	redisTemplate.opsForValue().setIfAbsent("name", "tangzhi",10, TimeUnit.SECONDS);
6. 设置map集合到redis
	Map valueMap = new HashMap();  
	valueMap.put("valueMap1","map1");  
	valueMap.put("valueMap2","map2");  
	valueMap.put("valueMap3","map3");  
	redisTemplate.opsForValue().multiSet(valueMap); 
如果对应的map集合名称不存在,则添加否则不做修改
Map valueMap = new HashMap();  
valueMap.put("valueMap1","map1");  
valueMap.put("valueMap2","map2");  
valueMap.put("valueMap3","map3");  
redisTemplate.opsForValue().multiSetIfAbsent(valueMap); 
7. 通过increment(K key, long delta)方法以增量方式存储long值(正值则自增,负值则自减)
	redisTemplate.opsForValue().increment(key, increment);
8. 批量获取值
	public List<String> multiGet(Collection<String> keys) {
 
    return redisTemplate.opsForValue().multiGet(keys);
 }
9. 返回传入key所存储的值的类型
	redisTemplate.type(key);
10. 判断是否有key所对应的值,有则返回true,没有则返回false
	redisTemplate.hasKey(key)
11. 删除单个key值
	redisTemplate.delete(key)
	redisTemplate.delete(keys) //其中keys:Collection<K> keys
12. 设置过期时间
	public Boolean expire(String key, long timeout, TimeUnit unit) {
 
	    return redisTemplate.expire(key, timeout, unit);
	 }
	 public Boolean expireAt(String key, Date date) {
 
	    return redisTemplate.expireAt(key, date);
	  }
13. 返回当前key所对应的剩余过期时间
	redisTemplate.getExpire(key);
14. 返回剩余过期时间并且指定时间单位
	public Long getExpire(String key, TimeUnit unit) {
 
	    return redisTemplate.getExpire(key, unit);
	}

③. redisTemplate操作list类型

1. 通过索引获取列表中的元素
	redisTemplate.opsForList().index(key, index)
2. 获取列表指定范围内的元素(start开始位置, 0是开始位置,end 结束位置, -1返回所有)
	redisTemplate.opsForList().range(key, start, end)
3. 存储在list的头部,即添加一个就把它放在最前面的索引处
	redisTemplate.opsForList().leftPush(key, value)
4. 把多个值存入List中(value可以是多个值,也可以是一个Collection value)
	redisTemplate.opsForList().leftPushAll(key, value)
5. List存在的时候再加入
	redisTemplate.opsForList().leftPushIfPresent(key, value)
6. 按照先进先出的顺序来添加(value可以是多个值,或者是Collection var2)
	redisTemplate.opsForList().rightPush(key, value)
	redisTemplate.opsForList().rightPushAll(key, value)
7. 设置指定索引处元素的值
	redisTemplate.opsForList().set(key, index, value)
8. 移除并获取列表中第一个元素(如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止)
	redisTemplate.opsForList().leftPop(key)
	redisTemplate.opsForList().leftPop(key, timeout, unit)	
9. 移除并获取列表最后一个元素
	redisTemplate.opsForList().rightPop(key)
	redisTemplate.opsForList().rightPop(key, timeout, unit)
10. 从一个队列的右边弹出一个元素并将这个元素放入另一个指定队列的最左边
	redisTemplate.opsForList().rightPopAndLeftPush(sourceKey, destinationKey)
	redisTemplate.opsForList().rightPopAndLeftPush(sourceKey, destinationKey, timeout, unit)
11. 删除集合中值等于value的元素(index=0, 删除所有值等于value的元素; index>0, 从头部开始删除第一个值等于value的元素; index<0, 从尾部开始删除第一个值等于value的元素)
	redisTemplate.opsForList().remove(key, index, value)
12. 将List列表进行剪裁
	redisTemplate.opsForList().trim(key, start, end)
13. 获取当前key的List列表长度
	redisTemplate.opsForList().size(key)

④. redisTemplate操作hash类型

1. 获取变量中的指定map键是否有值,如果存在该map键则获取值,没有则返回null。
	redisTemplate.opsForHash().get(key, field)
2. 获取变量中的键值对
	public Map<Object, Object> hGetAll(String key) {
 
    return redisTemplate.opsForHash().entries(key);
	}
3. 新增hashMap值
	redisTemplate.opsForHash().put(key, hashKey, value)
4. 以map集合的形式添加键值对
	public void hPutAll(String key, Map<String, String> maps) {
 
    redisTemplate.opsForHash().putAll(key, maps);
	}
5. 仅当hashKey不存在时才设置
	public Boolean hashPutIfAbsent(String key, String hashKey, String value) {
 
    return redisTemplate.opsForHash().putIfAbsent(key, hashKey, value);
	}
6. 删除一个或者多个hash表字段
	public Long hashDelete(String key, Object... fields) {
 
    return redisTemplate.opsForHash().delete(key, fields);
	}
7. 查看hash表中指定字段是否存在
	public boolean hashExists(String key, String field) {
 
    return redisTemplate.opsForHash().hasKey(key, field);
	}
8. 给哈希表key中的指定字段的整数值加上增量increment
	public Long hashIncrBy(String key, Object field, long increment) {
 
    	return redisTemplate.opsForHash().increment(key, field, increment);
	}
 public Double hIncrByDouble(String key, Object field, double delta) {
 
   		 return redisTemplate.opsForHash().increment(key, field, delta);
	}
9. 获取所有hash表中字段
	redisTemplate.opsForHash().keys(key)
10. 获取hash表中存在的所有的值
	public List<Object> hValues(String key) {
 
    	return redisTemplate.opsForHash().values(key);
	}
11. 获取hash表中字段的数量	
	redisTemplate.opsForHash().size(key)

⑤. redisTemplate操作Set类型

1. 添加元素
	redisTemplate.opsForSet().add(key, values)
2. 移除元素(单个值、多个值)
	redisTemplate.opsForSet().remove(key, values)
3. 获取集合的大小
	redisTemplate.opsForSet().size(key)
4. 判断集合是否包含value
	redisTemplate.opsForSet().isMember(key, value)
5. 获取两个集合的交集(key对应的无序集合与otherKey对应的无序集合求交集)
	redisTemplate.opsForSet().intersect(key, otherKey)
6. 获取多个集合的交集(Collection var2)
	redisTemplate.opsForSet().intersect(key, otherKeys)
7. key集合与otherKey集合的交集存储到destKey集合中(其中otherKey可以为单个值或者集合)
	redisTemplate.opsForSet().intersectAndStore(key, otherKey, destKey)
8. key集合与多个集合的交集存储到destKey无序集合中
	redisTemplate.opsForSet().intersectAndStore(key, otherKeys, destKey)
9. 获取两个或者多个集合的并集(otherKeys可以为单个值或者是集合)
	redisTemplate.opsForSet().union(key, otherKeys)
10. key集合与otherKey集合的并集存储到destKey中(otherKeys可以为单个值或者是集合)
	redisTemplate.opsForSet().unionAndStore(key, otherKey, destKey)
11. 获取两个或者多个集合的差集(otherKeys可以为单个值或者是集合)
	redisTemplate.opsForSet().difference(key, otherKeys)
12. 差集存储到destKey中(otherKeys可以为单个值或者集合)
	redisTemplate.opsForSet().differenceAndStore(key, otherKey, destKey)
13. 获取集合中的所有元素
	redisTemplate.opsForSet().members(key)
14. 随机获取集合中count个元素
	redisTemplate.opsForSet().randomMembers(key, count)
15. 随机获取集合中的一个元素
	redisTemplate.opsForSet().randomMember(key)
16. 遍历set类似于Interator(ScanOptions.NONE为显示所有的)
	redisTemplate.opsForSet().scan(key, options)

String key1="myRedisSetA";
        String key2="myRedisSetB";
        redisTemplate.opsForSet().add("myRedisSetA","a","b","c","d");
        redisTemplate.opsForSet().add("myRedisSetB","c","d","e","f");
        System.out.println("myRedisSetA元素为:"+redisTemplate.opsForSet().members("myRedisSetA")+",总数量为:"+redisTemplate.opsForSet().size("myRedisSetA"));
        System.out.println(redisTemplate.opsForSet().members("myRedisSetB"));
        Set<String> intersect = redisTemplate.opsForSet().intersect(key1, key2);
        System.out.println("交集:intersect:"+intersect);
        Set<String> difference = redisTemplate.opsForSet().difference(key1, key2);
        System.out.println("差集:difference:"+difference);
        Set<String> union = redisTemplate.opsForSet().union(key1, key2);
        System.out.println("并集:union:"+union);
        /**
         * myRedisSetA元素为:[d, a, c, b],总数量为:4
         * [e, d, f, c]
         * 交集:intersect:[d, c]
         * 差集:difference:[a, b]
         * 并集:union:[e, d, f, a, b, c]
         */

⑥. redisTemplate操作zSet类型

1. 添加元素(有序集合是按照元素的score值由小到大进行排列)
	redisTemplate.opsForZSet().add(key, value, score)
2. 删除对应的value,value可以为多个值
	redisTemplate.opsForZSet().remove(key, values)
3. 增加元素的score值,并返回增加后的值
	redisTemplate.opsForZSet().incrementScore(key, value, delta)
4. 返回元素在集合的排名,有序集合是按照元素的score值由小到大排列
	redisTemplate.opsForZSet().rank(key, value)
5. 返回元素在集合的排名,按元素的score值由大到小排列
	redisTemplate.opsForZSet().reverseRank(key, value)
6. 获取集合中给定区间的元素(start 开始位置,end 结束位置, -1查询所有)
	redisTemplate.opsForZSet().reverseRangeWithScores(key, start,end)
7. 按照Score值查询集合中的元素,结果从小到大排序
	redisTemplate.opsForZSet().reverseRangeByScore(key, min, max)
8. 从高到低的排序集中获取分数在最小和最大值之间的元素
	redisTemplate.opsForZSet().reverseRangeByScore(key, min, max, start, end)
9. 根据score值获取集合元素数量
	redisTemplate.opsForZSet().count(key, min, max)
10. 获取集合的大小
	redisTemplate.opsForZSet().size(key)
11. 获取集合中key、value元素对应的score值
	redisTemplate.opsForZSet().score(key, value)
12. 移除指定索引位置处的成员
	redisTemplate.opsForZSet().removeRange(key, start, end)
13. 移除指定score范围的集合成员
	redisTemplate.opsForZSet().removeRangeByScore(key, min, max)
14. 获取key和otherKey的并集并存储在destKey中(其中otherKeys可以为单个字符串或者字符串集合)
	redisTemplate.opsForZSet().unionAndStore(key, otherKey, destKey)
15. 获取key和otherKey的交集并存储在destKey中(其中otherKeys可以为单个字符串或者字符串集合)
	redisTemplate.opsForZSet().intersectAndStore(key, otherKey, destKey)

⑦. redisTemplate其他操作

//开启事务
redisTemplate.exec();
//redisTemplate.keys()
//获取连接,再通过连接执行命令
RedisConnection conn =  redisTemplate.getConnectionFactory().getConnection();
//通过 conn 清库
conn.flushAll();

⑧. 关于工具类的抽取

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;

@Component
public final class RedisUtil {
 

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    // =============================common============================
    /**
     * 指定缓存失效时间
     * @param key  键
     * @param time 时间(秒)
     */
    public boolean expire(String key, long time) {
 
        try {
 
            if (time > 0) {
 
                redisTemplate.expire(key, time, TimeUnit.SECONDS);
            }
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }

    /**
     * 根据key 获取过期时间
     * @param key 键 不能为null
     * @return 时间(秒) 返回0代表为永久有效
     */
    public long getExpire(String key) {
 
        return redisTemplate.getExpire(key, TimeUnit.SECONDS);
    }


    /**
     * 判断key是否存在
     * @param key 键
     * @return true 存在 false不存在
     */
    public boolean hasKey(String key) {
 
        try {
 
            return redisTemplate.hasKey(key);
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 删除缓存
     * @param key 可以传一个值 或多个
     */
    @SuppressWarnings("unchecked")
    public void del(String... key) {
 
        if (key != null && key.length > 0) {
 
            if (key.length == 1) {
 
                redisTemplate.delete(key[0]);
            } else {
 
                redisTemplate.delete(CollectionUtils.arrayToList(key));
            }
        }
    }


    // ============================String=============================

    /**
     * 普通缓存获取
     * @param key 键
     * @return 值
     */
    public Object get(String key) {
 
        return key == null ? null : redisTemplate.opsForValue().get(key);
    }

    /**
     * 普通缓存放入
     * @param key   键
     * @param value 值
     * @return true成功 false失败
     */

    public boolean set(String key, Object value) {
 
        try {
 
            redisTemplate.opsForValue().set(key, value);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 普通缓存放入并设置时间
     * @param key   键
     * @param value 值
     * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
     * @return true成功 false 失败
     */

    public boolean set(String key, Object value, long time) {
 
        try {
 
            if (time > 0) {
 
                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
            } else {
 
                set(key, value);
            }
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 递增
     * @param key   键
     * @param delta 要增加几(大于0)
     */
    public long incr(String key, long delta) {
 
        if (delta < 0) {
 
            throw new RuntimeException("递增因子必须大于0");
        }
        return redisTemplate.opsForValue().increment(key, delta);
    }


    /**
     * 递减
     * @param key   键
     * @param delta 要减少几(小于0)
     */
    public long decr(String key, long delta) {
 
        if (delta < 0) {
 
            throw new RuntimeException("递减因子必须大于0");
        }
        return redisTemplate.opsForValue().increment(key, -delta);
    }


    // ================================Map=================================

    /**
     * HashGet
     * @param key  键 不能为null
     * @param item 项 不能为null
     */
    public Object hget(String key, String item) {
 
        return redisTemplate.opsForHash().get(key, item);
    }

    /**
     * 获取hashKey对应的所有键值
     * @param key 键
     * @return 对应的多个键值
     */
    public Map<Object, Object> hmget(String key) {
 
        return redisTemplate.opsForHash().entries(key);
    }

    /**
     * HashSet
     * @param key 键
     * @param map 对应多个键值
     */
    public boolean hmset(String key, Map<String, Object> map) {
 
        try {
 
            redisTemplate.opsForHash().putAll(key, map);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * HashSet 并设置时间
     * @param key  键
     * @param map  对应多个键值
     * @param time 时间(秒)
     * @return true成功 false失败
     */
    public boolean hmset(String key, Map<String, Object> map, long time) {
 
        try {
 
            redisTemplate.opsForHash().putAll(key, map);
            if (time > 0) {
 
                expire(key, time);
            }
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 向一张hash表中放入数据,如果不存在将创建
     *
     * @param key   键
     * @param item  项
     * @param value 值
     * @return true 成功 false失败
     */
    public boolean hset(String key, String item, Object value) {
 
        try {
 
            redisTemplate.opsForHash().put(key, item, value);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }

    /**
     * 向一张hash表中放入数据,如果不存在将创建
     *
     * @param key   键
     * @param item  项
     * @param value 值
     * @param time  时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
     * @return true 成功 false失败
     */
    public boolean hset(String key, String item, Object value, long time) {
 
        try {
 
            redisTemplate.opsForHash().put(key, item, value);
            if (time > 0) {
 
                expire(key, time);
            }
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 删除hash表中的值
     *
     * @param key  键 不能为null
     * @param item 项 可以使多个 不能为null
     */
    public void hdel(String key, Object... item) {
 
        redisTemplate.opsForHash().delete(key, item);
    }


    /**
     * 判断hash表中是否有该项的值
     *
     * @param key  键 不能为null
     * @param item 项 不能为null
     * @return true 存在 false不存在
     */
    public boolean hHasKey(String key, String item) {
 
        return redisTemplate.opsForHash().hasKey(key, item);
    }


    /**
     * hash递增 如果不存在,就会创建一个 并把新增后的值返回
     *
     * @param key  键
     * @param item 项
     * @param by   要增加几(大于0)
     */
    public double hincr(String key, String item, double by) {
 
        return redisTemplate.opsForHash().increment(key, item, by);
    }


    /**
     * hash递减
     *
     * @param key  键
     * @param item 项
     * @param by   要减少记(小于0)
     */
    public double hdecr(String key, String item, double by) {
 
        return redisTemplate.opsForHash().increment(key, item, -by);
    }


    // ============================set=============================

    /**
     * 根据key获取Set中的所有值
     * @param key 键
     */
    public Set<Object> sGet(String key) {
 
        try {
 
            return redisTemplate.opsForSet().members(key);
        } catch (Exception e) {
 
            e.printStackTrace();
            return null;
        }
    }


    /**
     * 根据value从一个set中查询,是否存在
     *
     * @param key   键
     * @param value 值
     * @return true 存在 false不存在
     */
    public boolean sHasKey(String key, Object value) {
 
        try {
 
            return redisTemplate.opsForSet().isMember(key, value);
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 将数据放入set缓存
     *
     * @param key    键
     * @param values 值 可以是多个
     * @return 成功个数
     */
    public long sSet(String key, Object... values) {
 
        try {
 
            return redisTemplate.opsForSet().add(key, values);
        } catch (Exception e) {
 
            e.printStackTrace();
            return 0;
        }
    }


    /**
     * 将set数据放入缓存
     *
     * @param key    键
     * @param time   时间(秒)
     * @param values 值 可以是多个
     * @return 成功个数
     */
    public long sSetAndTime(String key, long time, Object... values) {
 
        try {
 
            Long count = redisTemplate.opsForSet().add(key, values);
            if (time > 0)
                expire(key, time);
            return count;
        } catch (Exception e) {
 
            e.printStackTrace();
            return 0;
        }
    }


    /**
     * 获取set缓存的长度
     *
     * @param key 键
     */
    public long sGetSetSize(String key) {
 
        try {
 
            return redisTemplate.opsForSet().size(key);
        } catch (Exception e) {
 
            e.printStackTrace();
            return 0;
        }
    }


    /**
     * 移除值为value的
     *
     * @param key    键
     * @param values 值 可以是多个
     * @return 移除的个数
     */

    public long setRemove(String key, Object... values) {
 
        try {
 
            Long count = redisTemplate.opsForSet().remove(key, values);
            return count;
        } catch (Exception e) {
 
            e.printStackTrace();
            return 0;
        }
    }

    // ===============================list=================================

    /**
     * 获取list缓存的内容
     *
     * @param key   键
     * @param start 开始
     * @param end   结束 0 到 -1代表所有值
     */
    public List<Object> lGet(String key, long start, long end) {
 
        try {
 
            return redisTemplate.opsForList().range(key, start, end);
        } catch (Exception e) {
 
            e.printStackTrace();
            return null;
        }
    }


    /**
     * 获取list缓存的长度
     *
     * @param key 键
     */
    public long lGetListSize(String key) {
 
        try {
 
            return redisTemplate.opsForList().size(key);
        } catch (Exception e) {
 
            e.printStackTrace();
            return 0;
        }
    }


    /**
     * 通过索引 获取list中的值
     *
     * @param key   键
     * @param index 索引 index>=0时, 0 表头,1 第二个元素,依次类推；index<0时,-1,表尾,-2倒数第二个元素,依次类推
     */
    public Object lGetIndex(String key, long index) {
 
        try {
 
            return redisTemplate.opsForList().index(key, index);
        } catch (Exception e) {
 
            e.printStackTrace();
            return null;
        }
    }


    /**
     * 将list放入缓存
     *
     * @param key   键
     * @param value 值
     */
    public boolean lSet(String key, Object value) {
 
        try {
 
            redisTemplate.opsForList().rightPush(key, value);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 将list放入缓存
     * @param key   键
     * @param value 值
     * @param time  时间(秒)
     */
    public boolean lSet(String key, Object value, long time) {
 
        try {
 
            redisTemplate.opsForList().rightPush(key, value);
            if (time > 0)
                expire(key, time);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }

    }


    /**
     * 将list放入缓存
     *
     * @param key   键
     * @param value 值
     * @return
     */
    public boolean lSet(String key, List<Object> value) {
 
        try {
 
            redisTemplate.opsForList().rightPushAll(key, value);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }

    }


    /**
     * 将list放入缓存
     *
     * @param key   键
     * @param value 值
     * @param time  时间(秒)
     * @return
     */
    public boolean lSet(String key, List<Object> value, long time) {
 
        try {
 
            redisTemplate.opsForList().rightPushAll(key, value);
            if (time > 0)
                expire(key, time);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 根据索引修改list中的某条数据
     *
     * @param key   键
     * @param index 索引
     * @param value 值
     * @return
     */

    public boolean lUpdateIndex(String key, long index, Object value) {
 
        try {
 
            redisTemplate.opsForList().set(key, index, value);
            return true;
        } catch (Exception e) {
 
            e.printStackTrace();
            return false;
        }
    }


    /**
     * 移除N个值为value
     *
     * @param key   键
     * @param count 移除多少个
     * @param value 值
     * @return 移除的个数
     */

    public long lRemove(String key, long count, Object value) {
 
        try {
 
            Long remove = redisTemplate.opsForList().remove(key, count, value);
            return remove;
        } catch (Exception e) {
 
            e.printStackTrace();
            return 0;
        }

    }
}

redis map

上一篇：Redis的数据类型以及使用场景，看这一篇就够啦
下一篇：Redis 21问，你接得住不?（redis llen）

SpringBoot整合redis、RedisTemplate操作各个基本类型

文章目录

①. SPRINGBOOT整合REDIS

②. redisTemplate操作String类型

③. redisTemplate操作list类型

④. redisTemplate操作hash类型

⑤. redisTemplate操作Set类型

⑥. redisTemplate操作zSet类型

⑦. redisTemplate其他操作

⑧. 关于工具类的抽取

相关推荐

取消回复欢迎你发表评论:

生产系统数据库操作规范(2):（数据库生产库是什么意思）

Redis客户端 Jedis 与 Lettuce

高并发架构系列:Redis并发竞争key的解决方案详解

redis如何防止并发（redis如何防止高并发）

开源推荐:如何实现的一个高性能 Redis 服务器

redis安装与调优部署文档(WinServer)

Redis 入门 - 安装最全讲解(Windows、Linux、Docker)

一文带你了解 Redis 的发布与订阅的底层原理

Java SE Development Kit 8u441下载地址【windows版本】

Redis如何应对并发访问（redis控制并发量）

SpringBoot整合redis、RedisTemplate操作各个基本类型

文章目录

①. SPRINGBOOT整合REDIS

②. redisTemplate操作String类型

③. redisTemplate操作list类型

④. redisTemplate操作hash类型

⑤. redisTemplate操作Set类型

⑥. redisTemplate操作zSet类型

⑦. redisTemplate其他操作

⑧. 关于工具类的抽取

相关推荐

取消回复欢迎 你 发表评论:

生产系统数据库操作规范(2):（数据库生产库是什么意思）

Redis客户端 Jedis 与 Lettuce

高并发架构系列:Redis并发竞争key的解决方案详解

redis如何防止并发（redis如何防止高并发）

开源推荐:如何实现的一个高性能 Redis 服务器

redis安装与调优部署文档(WinServer)

Redis 入门 - 安装最全讲解(Windows、Linux、Docker)

一文带你了解 Redis 的发布与订阅的底层原理

Java SE Development Kit 8u441下载地址【windows版本】

Redis如何应对并发访问（redis控制并发量）

取消回复欢迎你发表评论: