SpringBoot中的Redis 缓存问题及操作方法

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

#端口号
server:
  port: 8096

# redis配置
spring:
  redis:
    host: 127.0.0.1 #如果是redis远程服务器，此处redis服务器ip地址
    port: 6379 #默认端口
#    database: 0 #指定redis数据库，默认是0
#    password:   # 密码有就写，没有就省略

//自动装配  SpringBoot框架自动配置的redisTemplate
@Autowired
private RedisTemplate<Object,Object> redisTemplate;

//基于SpringBoot框架自动配置的redisTemplate,操作redis缓存
//获取连接
RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
//清空数据库中的所有数据
log.info("清空数据库中的所有数据");
connection.flushDb();

//程序中，添加数据据到redis
log.info("------ 基于SpringBoot框架自动配置的redisTemplate 添加数据 ------");
redisTemplate.opsForValue().set("kh96_class_name","KGC_KH96");
redisTemplate.opsForValue().set("student_num",19);

//程序中，从redis获取数据
log.info("------ 基于SpringBoot框架自动配置的redisTemplate 获取数据 ------");
log.info("****** 根据 班级的key：{},获取班级名称：{} ******","kh96_class_name",redisTemplate.opsForValue().get("kh96_class_name"));
log.info("****** 根据 班级的key：{},获取班级人数：{} ******","student_num",redisTemplate.opsForValue().get("student_num"));

//程序中，基于SpringBoot框架自动配置的redisTemplate,操作redis缓存，存在问题
//场景：对班级人数进行增减操作，比如将班级人数，增加10
log.info("------ 基于SpringBoot框架自动配置的redisTemplate 操作数据 ------");
redisTemplate.opsForValue().increment("student_num",10);
//直接报错，会报500异常： redis.clients.jedis.exceptions.JedisDataException: ERR value is not an integer or out of range
//原因，通过系统默认的 redisTemplate，存放key和value值时，会自动使用Object类的序列化和反序列化，导致redis中真实存放的数据不是原始值，而是序列化后的值

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.62</version>
</dependency>

//Redis自定义配置类，实现一个自定义序列化方式的 redisTemplate,提缓缓掉默认自动配置的 redisTemplate,实现String类型任意类型的value
@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        // 自定义redisTemplate的模板对象
        RedisTemplate<String, Object> template = new RedisTemplate<>();

        // 设置连接工厂
        template.setConnectionFactory(redisConnectionFactory);

        //由于要通过程序操作远程的redis数据库，必须支持序列化，才可以让程序中的数据，在网络中传输
        //定义String类型的序列化方式
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();

        // 定义fastjson序列化方式，可以序列化任何对象
        FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);

        // 需改为新的序列化方式
        template.setKeySerializer(stringRedisSerializer);
        template.setValueSerializer(fastJsonRedisSerializer);
        template.setHashKeySerializer(stringRedisSerializer);
        template.setHashValueSerializer(fastJsonRedisSerializer);

        // 初始化为新的模板
        template.afterPropertiesSet();

        return template;
    }

}

//自动装配自定义 redisTemplate 
@Autowired
private RedisTemplate<String,Object> redisTemplate;

//其他代码不变

@GetMapping("/testRedisUtils")
public String testSpringBootRedisUtils(){

    //基于自定义的redisTemplate 和 RedisUtils 工具类,操作redis缓存
    //程序中，添加数据据到redis
    log.info("------ 基于自定义的redisTemplate 和 RedisUtils 工具类 添加数据 ------");
    redisUtils.set("kh96_class_name_utils","KGC_KH96");
    redisUtils.set("student_num_utils",19);

    //程序中，从redis获取数据
    log.info("------ 基于自定义的redisTemplate 和 RedisUtils 工具类 获取数据 ------");
    log.info("****** 根据 班级的key：{},获取班级名称：{} ******","kh96_class_name_utils",redisUtils.get("kh96_class_name_utils"));
    log.info("****** 根据 班级的key：{},获取班级人数：{} ******","student_num_utils",redisUtils.get("student_num_utils"));

    //程序中，基于SpringBoot框架自动配置的redisTemplate,操作redis缓存
    //场景：对班级人数进行增减操作，比如姜班级人数，增加10
    log.info("------ 基于自定义的redisTemplate 和 RedisUtils 工具类 操作数据 ------");
    redisUtils.incr("student_num_utils",10);

    return "工具类 RedisUtils  操作 redis 成功！";

}

@GetMapping("/testRedisUtils")
public String testSpringBootRedisUtils(){

    //程序中如何存放对象到 redis
    //核心思想：一般都是姜对象转换为json字符串，存入redis,获取对象数据，就先获取json字符串，再转换为对应对象即可

    //模拟用户登录成功后，将用户信息存入redis中，方便后续从redis中获取用户信息
    User loginUser = User.builder().userId(1001).userName("KH96").userTel("135012030404").build();

    //直接将对象存入redis即可
    log.info("------ 基于自定义的redisTemplate 和 RedisUtils 工具类 存储对象 ------");
    //自动把实体，通过fastjson的序列化方式，转发为JSON字符串存储
    redisUtils.set(loginUser.getUserId().toString(),loginUser);

    //模拟获取登录用户信息，直接从redis获取存入的JSON字符串，转换为目标用户对象
    User realUser = JSON.parseObject(redisUtils.get(loginUser.getUserId().toString()).toString(),User.class);

    log.info("------ 基于自定义的redisTemplate 和 RedisUtils 工具类获取对象：{} ",realUser);

    return "工具类 RedisUtils  操作 redis 成功！";

}