Spring Boot（4）—— Spring Boot中Redis的使用

太过爱你忘了你带给我的痛 2022-06-17 06:14 256阅读 0赞

**1、redis介绍**

Redis是目前业界使用最广泛的内存数据存储。相比memcached，Redis支持更丰富的数据结构，例如hashes, lists, sets等，同时支持数据持久化。除此之外，Redis还提供一些类数据库的特性，比如事务，HA，主从库。可以说Redis兼具了缓存系统和数据库的一些特性，因此有着丰富的应用场景。本文介绍Redis在Spring Boot中两个典型的应用场景。

**2、场景一：数据缓存**

第一个应用场景是数据缓存，最典型的当属缓存数据库查询结果。对于高频读低频写的数据，使用缓存可以，第一加速读取过程，第二降低数据库压力。通过引入spring-boot-starter-redis依赖和注册RedisCacheManager，Redis可以无缝的集成进Spring的缓存系统，自动绑定@Cacheable, @CacheEvict等缓存注解。

**2.1 pom.xml配置**

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

**2.2 添加配置文件**

# REDIS (RedisProperties)
    # Redis数据库索引（默认为0）
    spring.redis.database=0  
    # Redis服务器地址
    spring.redis.host=xxx
    # Redis服务器连接端口
    spring.redis.port=6379  
    # Redis服务器连接密码（默认为空）
    spring.redis.password=  
    # 连接池最大连接数（使用负值表示没有限制）
    spring.redis.pool.max-active=8  
    # 连接池最大阻塞等待时间（使用负值表示没有限制）
    spring.redis.pool.max-wait=-1  
    # 连接池中的最大空闲连接
    spring.redis.pool.max-idle=8  
    # 连接池中的最小空闲连接
    spring.redis.pool.min-idle=0  
    # 连接超时时间（毫秒）
    spring.redis.timeout=0

**2.3 添加cache的配置类**

@Configuration
    @EnableCaching
    public class RedisConfig extends CachingConfigurerSupport{ 
    
        @Bean
        public KeyGenerator keyGenerator() {
            return new KeyGenerator() {
                @Override
                public Object generate(Object target, Method method, Object... params) {
                    StringBuilder sb = new StringBuilder();
                    sb.append(target.getClass().getName());
                    sb.append(method.getName());
                    for (Object obj : params) {
                        sb.append(obj.toString());
                    }
                    return sb.toString();
                }
            };
        }
    
        @SuppressWarnings("rawtypes")
        @Bean
        public CacheManager cacheManager(RedisTemplate redisTemplate) {
            RedisCacheManager rcm = new RedisCacheManager(redisTemplate);
            //设置缓存过期时间
            //rcm.setDefaultExpiration(60);//秒
            return rcm;
        }
    
        @Bean
        public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
            StringRedisTemplate template = new StringRedisTemplate(factory);
            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);
            template.setValueSerializer(jackson2JsonRedisSerializer);
            template.afterPropertiesSet();
            return template;
        }
    }

**2.4 使用**

@RunWith(SpringJUnit4ClassRunner.class)
    @SpringApplicationConfiguration(Application.class)
    public class TestRedis { 
    
        @Autowired
        private StringRedisTemplate stringRedisTemplate;
    
        @Autowired
        private RedisTemplate redisTemplate;
    
        @Test
        public void test() throws Exception {
            stringRedisTemplate.opsForValue().set("aaa", "111");
            Assert.assertEquals("111", stringRedisTemplate.opsForValue().get("aaa"));
        }
    
        @Test
        public void testObj() throws Exception {
            User user=new User("aa@126.com", "aa", "aa123456", "aa","123");
            ValueOperations<String, User> operations=redisTemplate.opsForValue();
            operations.set("com.neox", user);
            operations.set("com.neo.f", user,1,TimeUnit.SECONDS);
            Thread.sleep(1000);
            //redisTemplate.delete("com.neo.f");
            boolean exists=redisTemplate.hasKey("com.neo.f");
            if(exists){
                System.out.println("exists is true");
            }else{
                System.out.println("exists is false");
            }
           // Assert.assertEquals("aa", operations.get("com.neo.f").getUserName());
        }
    }

2.5 以上都是手动使用的方式，如何在查找数据库的时候自动使用缓存呢，自动根据方法生成缓存，看下面；

@RestController
    public class UserController { 
    
        @Autowired
        private UserRepository userRepository;
    
        @RequestMapping("/getUser")
        @Cacheable(value="user-key")
        public User getUser() {
            User user = userRepository.findByUserName("aa");
            System.out.println("若下面没出现“无缓存的时候调用”字样且能打印出数据表示测试成功");  
            return user;
        }
    
        @RequestMapping("/getUsers")
        @Cacheable(value="users-key")
        public List<User> getUsers() {
            List<User> users = userRepository.findAll();
            System.out.println("若下面没出现“无缓存的时候调用”字样且能打印出数据表示测试成功");  
            return users;
        }
    }

说明：

@Cacheable //插入缓存
        value  //缓存名称
        key   //缓存键，一般包含被缓存对象的主键，支持Spring EL表达式
        unless //只有当查询结果不为空时，才放入缓存
    
    @CacheEvict //失效缓存

注意：

（1）Spring Redis默认使用JDK进行序列化和反序列化，因此被缓存对象需要实现java.io.Serializable接口，否则缓存出错。  
（2）当被缓存对象发生改变时，可以选择更新缓存或者失效缓存，但一般而言，后者优于前者，因为执行速度更快。  
（3）特别注意在同一个Class内部调用带有缓存注解的方法，缓存并不会生效。

**3、场景二：共享session**

共享Session是第二个典型应用场景，这是利用了Redis的堆外内存特性。要保证分布式应用的可伸缩性，带状态的Session对象是绕不过去的一道坎。一种方式是将Session持久化到数据库中，缺点是读写成本太高。另一种方式是去Session化，比如Play直接将Session存到客户端的Cookie中，缺点是存储信息的大小受限。将Session缓存到Redis中，既保证了可伸缩性，同时又避免了前面两者的限制。

分布式系统中，sessiong共享有很多的解决方案，其中使用spring-session-data-redis托管到缓存中应该是最常用的方案之一。

**3.1 pom.xml**

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

**3.2 Session配置**

@Configuration
    @EnableRedisHttpSession(maxInactiveIntervalInSeconds = 86400*30)
    public class SessionConfig { 
    }
    
    maxInactiveIntervalInSeconds //设置Session失效时间，使用Redis Session之后，原Boot的server.session.timeout属性不再生效

好了，这样就配置好了

**3.3 测试**

添加测试方法获取sessionid

@RestController //类中的方法都会以json的格式返回
    public class HelloController { 
    
        @RequestMapping("/uid")
        String uid(HttpSession session) {
            UUID uid = (UUID) session.getAttribute("uid");
            if (uid == null) {
                uid = UUID.randomUUID();
            }
            session.setAttribute("uid", uid);
            return session.getId();
        }
    }

登录redis 输入keys ‘*sessions*’

t<spring:session:sessions:db031986-8ecc-48d6-b471-b137a3ed6bc4
    t(spring:session:expirations:1472976480000

其中 1472976480000为失效时间，意思是这个时间后session失效，db031986-8ecc-48d6-b471-b137a3ed6bc4 为sessionId,登录[http://localhost:8080/uid][http_localhost_8080_uid] 发现会一致，就说明session 已经在redis里面进行有效的管理了。

[http_localhost_8080_uid]: http://localhost:8080/uid