REDIS05_SpringBoot整合redisRedisTemplate操作各个基本类型工具类的抽取

Posted 2022-09-06 所得皆惊喜

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了REDIS05_SpringBoot整合redisRedisTemplate操作各个基本类型工具类的抽取相关的知识，希望对你有一定的参考价值。

文章目录

①. 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<Stringspringboot整合redis
 SpringBoot整合Redis乱码原因及解决方案
 SpringBoot整合Redis乱码原因及解决方案
 SpringBoot2.0实战（23）整合Redis之集成缓存SpringDataCache
 springboot整合redis异常汇总
 SpringBoot 整合其他框架 -- SpringBoot整合Redis