阅读数:212 评论数:0

当然可以自己写redis的工具类，或者使用第三方开源jar包或代码，这里使用spring boot的集成类。

一、pom依赖

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

二、配置文件(yml/properties)

spring boot2对redis的支持不仅仅是丰富的它的api，更是替换掉底层Jedis的依赖，取而代之换成了Lettuce。Jedis在实现上直连redis server，多线程环境下非线程安全，除非使用连接池，为每个jedis实例增加物理连接，原因是jedis的请求流和响应流都是全局变量，当不同的线程在set和get的时候，有可能会出现线程A的set()的响应流，被线程B的get()作为返回。Lettuce基于Netty的连接实例，可以在多线程间并发访问，且线程安全，一个连接实例不够的情况下也可以按需增加连接实例。

#redis
redis:
  #redis机器ip
  hostname: 127.0.0.1
  #redis端口
  port: 6379
  #redis密码
  password:
  #redis超时时间（毫秒），如果不设置，取默认值2000
  timeout: 10000
#最大空闲数
  maxIdle: 300
#连接池的最大数据库连接数。设为0表示无限制,如果是jedis 2.4以后用redis.maxTotal
#maxActive=600
#控制一个pool可分配多少个jedis实例,用来替换上面的redis.maxActive,如果是jedis 2.4以后用该属性
  maxTotal: 1000
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
  maxWaitMillis: 1000
#连接的最小空闲时间 默认1800000毫秒(30分钟)
  minEvictableIdleTimeMillis: 300000
#每次释放连接的最大数目,默认3
  numTestsPerEvictionRun: 1024
#逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
  timeBetweenEvictionRunsMillis: 30000
#是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
  testOnBorrow: true
#在空闲时检查有效性, 默认false
  testWhileIdle: true
 
#redis集群配置
#spring.redis.cluster.nodes=192.168.1.1:7001,192.168.1.1:7002,192.168.1.1:7003,192.168.1.1:7004,192.168.1.1:7005,192.168.1.1:7006
#spring.redis.cluster.max-redirects=3
 
#哨兵模式
#sentinel.host1=192.168.1.1
#sentinel.port1=26379
 
#sentinel.host2=192.168.1.2
#sentinel.port2=26379

三、RedisConfig.java

package com.example.smybatis.configurer;
 
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
 
import java.io.Serializable;
 
@Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class)
public class RedisConfig {
 
 
    @Bean
    public RedisTemplate<String, Serializable> redisCacheTemplate(LettuceConnectionFactory redisConnectionFactory) {
        RedisTemplate<String, Serializable> template = new RedisTemplate<>();
        template.setKeySerializer(new StringRedisSerializer());
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }
}

四、redis的序列化

在使用spring-data-redis时，默认使用的JdkSerializationRedisSerializer，当然也可以改用Spring携带的Jackson序列化类（Jackson2JsonRedisSerializer和GenericJackson2JsonRedisSerializer），另外也可以尽管用FastJson来进行序列化。

1、JdkSerializationRedisSerializer

使用JDK提供的序列化功能，优点是反序列化时不需要提供类型信息（class），但需要实现Serializable接口，还有就是序列化结果偏大。

同时，这种方式序列后的数据，查看时不方便。

2、GenericJackson2JsonRedisSerializer和Jackson2JsonRedisSerializer

使用Jackson2JsonRedisSerializer需要指明序列化的类Class，所以反序列化带泛型的数据时会有问题。

使用GenericJackson2JsonRedisSerializer序列化时，会保存序列化的对象的包名和类名，反序列化时以这个作为标示就可以反序列化成指定的对象。

使用GenericJacksonRedisSerializer比Jackson2JsonRedisSerializer效率低，占用内存高。

    @Bean("userRedistemplate")
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        // 将刚才的redis连接工厂设置到模板类中
        template.setConnectionFactory(redisConnectionFactory);
        // 设置key的序列化器
        template.setKeySerializer(new StringRedisSerializer());
        // 设置value的序列化器
        //使用Jackson 2，将对象序列化为JSON
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        //json转对象类，不设置默认的会将json转成hashmap
        ObjectMapper om = new ObjectMapper();
        // 指定要序列化域（field、get、set）以及修饰符范围（any包括private和public）
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型，类必须是非final修饰的，如果是final修饰的，比如String、Integer会抛出异常
        om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance,
                ObjectMapper.DefaultTyping.NON_FINAL,
                JsonTypeInfo.As.WRAPPER_ARRAY);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setValueSerializer(jackson2JsonRedisSerializer);
       
        return template;
    }

五、StringRedisTemplate

1、与RedisTemplate区别

（1）StringRedisTemplate继承RedisTemplate

（2）StringRedisTemplate只能管理自己的数据，RedisTemplate也一样。

（3）主要区别是使用的序列化类不同，RedisTemplate使用的是JdkSerializationRedisSerializer，StringRedisTemplate使用的是StringRedisSerializer.

（4）当操作的是字符串时，使用StringRedisTemplate，但是当数据是复杂类型时，使用RedisTemplate。

2、5种数据结构操作

redisTemplate.opsForValue();　　//操作字符串
redisTemplate.opsForHash();　　 //操作hash
redisTemplate.opsForList();　　 //操作list
redisTemplate.opsForSet();　　  //操作set
redisTemplate.opsForZSet();　 　//操作有序set

3、常用操作

stringRedisTemplate.opsForValue().set("test", "100",60*10,TimeUnit.SECONDS);//向redis里存入数据和设置缓存时间  
 
stringRedisTemplate.boundValueOps("test").increment(-1);//val做-1操作
 
stringRedisTemplate.opsForValue().get("test")//根据key获取缓存中的val
 
stringRedisTemplate.boundValueOps("test").increment(1);//val +1
 
stringRedisTemplate.getExpire("test")//根据key获取过期时间
 
stringRedisTemplate.getExpire("test",TimeUnit.SECONDS)//根据key获取过期时间并换算成指定单位 
 
stringRedisTemplate.delete("test");//根据key删除缓存
 
stringRedisTemplate.hasKey("546545");//检查key是否存在，返回boolean值 
 
stringRedisTemplate.opsForSet().add("red_123", "1","2","3");//向指定key中存放set集合
 
stringRedisTemplate.expire("red_123",1000 , TimeUnit.MILLISECONDS);//设置过期时间
 
stringRedisTemplate.opsForSet().isMember("red_123", "1")//根据key查看集合中是否存在指定数据
 
stringRedisTemplate.opsForSet().members("red_123");//根据key获取set集合