redis缓存使用

news/2025/11/24 15:58:12/文章来源:https://www.cnblogs.com/xueandfan/p/19264472

1、在pom.xml里面配置如下

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

2、在yml或properties里面的配置（此处是在notepad++里面的截图，下面是在yml文件里面的写法）

spring:
data:
redis:
#ip地址
host: xx.xx.xx.xx
#端口号
port: 6379
#密码(设置密码就有password，没设置就注释)
password: 123456
#redis默认创建 16 个数据库（编号 0-15）
database: 0
#Redis 通信超时时间
timeout: 3000ms
pool:
#最大活跃连接数
max-active: 8
#最大空闲连接数
max-idle: 8
#最小空闲连接数
min-idle: 0
#获取连接的最大等待时间
max-wait: 2000ms

3、编写 Java 配置类（替代配置文件）

import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisConfig extends CachingConfigurerSupport {


    @Bean
    public RedisTemplate<Object,Object> redisTemplate(RedisConnectionFactory connectionFactory){
        RedisTemplate<Object,Object> redisTemplate = new RedisTemplate<>();
        //默认的Key序列化器为:JdkSerializationRedisSerializer
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setConnectionFactory(connectionFactory);
        return redisTemplate;
    }


}

4、测试连接与操作(在自己需要用到redis存数据的地方加入以下代码，例如Controller层、service实现层、或拦截器、或过滤器里面)

package com.realtime.pg.controller;

import com.realtime.pg.model.CommonResultResponse;
import com.realtime.pg.model.User;
import com.realtime.pg.service.TestPgService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.TimeUnit;

@RequestMapping("/testIotdb")
@RestController
public class TestPgController {

    @Autowired
    private TestPgService testPgService;

    @Autowired
    private RedisTemplate redisTemplate;


    @PostMapping("/getTestList")
    public CommonResultResponse getAssemType(User user) {
        User userInfo = new User();
        String  authorization = user.getAuthorization();
        if(authorization != null && !"".equals(authorization)){
            Object objectResult = redisTemplate.opsForValue().get(authorization);
            if(objectResult != null){
                if (objectResult instanceof User) {
                    userInfo = (User) objectResult; // 强制类型转换
                }
            }else{
                userInfo = testPgService.getUser();

                // 1. 存储authorization-> User 键值对
                //可以将authorization和User对象替换成自己要存放的数据
                redisTemplate.opsForValue().set(authorization, user);
                //将authorization对应的user存在redis里面两个小时
                redisTemplate.expire(authorization,2, TimeUnit.HOURS);

            }
        }

        return new CommonResultResponse(200,"success","成功",userInfo);

    } 


}