SpringBoot中Redis的基础使用

基础使用

首先引入依赖

2.         <dependency>
3.             <groupId>org.springframework.boot</groupId>
4.             <artifactId>spring-boot-starter-data-redis</artifactId>
5.         </dependency>
6.         <dependency>
7.             <groupId>redis.clients</groupId>
8.             <artifactId>jedis</artifactId>
9.             <version>2.9.0</version>
10.         </dependency>

复制代码

然后在application.yml的spring下增加redis配置：

代码如下

1. redis:
2.     # Redis数据库索引（默认为0）
3.     database: 0
4.     # Redis服务器地址
5.     host: 127.0.0.1
6.     # Redis服务器连接端口
7.     port: 6379
8.     password: '123456'
9.     jedis:
10.       pool:
11.         # 连接池最大连接数（使用负值表示没有限制）
12.         max-active: 8
13.         # 连接池最大阻塞等待时间（使用负值表示没有限制）
14.         max-wait: 1
15.         # 连接池中的最大空闲连接
16.         max-idle: 8
17.         # 连接池中的最小空闲连接
18.         min-idle: 0
19.     # 连接超时时间（毫秒）
20.     timeout: 5000

复制代码

然后在根包下创建一个service的文件夹加，然后在里面增加redis文件夹，redis文件夹里编写redis的基础操作函数。
编写IRedisService接口，编写增删改查函数，代码如下：

1. import java.util.Map;
2. ​
3. @Service
4. public interface IRedisService {
5.     /**
6.      * 加入元素
7.      * @param key
8.      * @param value
9.      */
10.     void  setValue(String key, Map<String, Object> value);
11.     /**
12.      * 加入元素
13.      * @param key
14.      * @param value
15.      */
16.     void  setValue(String key, String value);
17.     /**
18.      * 加入元素
19.      * @param key
20.      * @param value
21.      */
22.     void   setValue(String key, Object value);
23.     /**
24.      * 获取元素
25.      * @param key
26.      */
27.     Object getMapValue(String key);
28.     /**
29.      * 获取元素
30.      * @param key
31.      */
32.     Object getValue(String key);
33. ​
34. }

复制代码

编写RedisServiceImpl实现，实现Redis的增删改查。

1. package com.example.dynamicdb.service.redis;
2. ​
3. import org.springframework.beans.factory.annotation.Autowired;
4. ​
5. import org.springframework.data.redis.core.RedisTemplate;
6. import org.springframework.data.redis.core.ValueOperations;
7. import org.springframework.stereotype.Service;
8. ​
9. import java.util.Map;
10. import java.util.concurrent.TimeUnit;
11. ​
12. @Service("RedisServiceImpl")
13. public class RedisServiceImpl implements IRedisService {
14. ​
15.     public RedisServiceImpl(){}
16. ​
17.     @Autowired
18.     private RedisTemplate redisTemplate;
19. ​
20. ​
21.     @Override
22.     public void setValue(String key, Map<String, Object> value) {
23.         ValueOperations<String, Object> vo = redisTemplate.opsForValue();
24.         vo.set(key, value);
25.         redisTemplate.expire(key, 1, TimeUnit.HOURS);
26.     }
27. ​
28.     @Override
29.     public Object getValue(String key) {
30.         ValueOperations<String, String> vo = redisTemplate.opsForValue();
31.         return vo.get(key);
32.     }
33. ​
34.     @Override
35.     public void setValue(String key, String value) {
36.         ValueOperations<String, Object> vo = redisTemplate.opsForValue();
37.         vo.set(key, value);
38.         redisTemplate.expire(key, 1, TimeUnit.HOURS);
39.     }
40. ​
41.     @Override
42.     public void setValue(String key, Object value) {
43.         ValueOperations<String, Object> vo = redisTemplate.opsForValue();
44.         vo.set(key, value);
45.         redisTemplate.expire(key, 1, TimeUnit.HOURS);
46.     }
47. ​
48.     @Override
49.     public Object getMapValue(String key) {
50.         ValueOperations<String, String> vo = redisTemplate.opsForValue();
51.         return vo.get(key);
52.     }
53. ​
54. }

复制代码

然后创建一个RedisController，编写一个测试接口，如下：

1. @RestController
2. public class RedisController {
3.     @Resource(name = "RedisServiceImpl")//使用resource实例化对象，name是指定实例化的类,用于一个接口多个类继承的情况
4.     private IRedisService iRedisService;
5.     @PostMapping(value = "/Redis/TestRedis")
6.     @ApiOperation(value = "redis测试接口", notes = "redis测试接口", httpMethod = "POST")
7.     public String TestRedis(){
8.         iRedisService.setValue("redis", "这是redis的测试数据");
9.         Object redis = iRedisService.getValue("redis");
10.         return redis.toString();
11.     }
12. }

复制代码

redis缓存使用

首先创建一个config文件夹，然后创建一个RedisCacheConfig文件，代码如下：

1. ​
2. import com.fasterxml.jackson.annotation.JsonAutoDetect;
3. import com.fasterxml.jackson.annotation.PropertyAccessor;
4. import com.fasterxml.jackson.databind.ObjectMapper;
5. import org.springframework.cache.annotation.EnableCaching;
6. import org.springframework.context.annotation.Bean;
7. import org.springframework.context.annotation.Configuration;
8. import org.springframework.data.redis.cache.RedisCacheConfiguration;
9. import org.springframework.data.redis.cache.RedisCacheManager;
10. import org.springframework.data.redis.cache.RedisCacheWriter;
11. import org.springframework.data.redis.connection.RedisConnectionFactory;
12. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
13. import org.springframework.data.redis.serializer.RedisSerializationContext;
14. ​
15. import java.time.Duration;
16. import java.util.HashMap;
17. import java.util.Map;
18. ​
19. @EnableCaching
20. @Configuration
21. public class RedisCacheConfig {
22. ​
23. ​
24.     /**
25.      * 最新版，设置redis缓存过期时间
26.      */
27. ​
28.     @Bean
29.     public RedisCacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
30.         return new RedisCacheManager(
31.                 RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory),
32.                 this.getRedisCacheConfigurationWithTtl( 60), // 默认策略，未配置的 key 会使用这个
33.                 this.getRedisCacheConfigurationMap() // 指定 key 策略
34.         );
35.     }
36. ​
37.     private Map<String, RedisCacheConfiguration> getRedisCacheConfigurationMap() {
38.         Map<String, RedisCacheConfiguration> redisCacheConfigurationMap = new HashMap<>();
39.         //SsoCache和BasicDataCache进行过期时间配置
40.         redisCacheConfigurationMap.put("messagCache", this.getRedisCacheConfigurationWithTtl(30 * 60));
41. ​
42.         //自定义设置缓存时间
43.         redisCacheConfigurationMap.put("studentCache", this.getRedisCacheConfigurationWithTtl(60 ));
44. ​
45.         return redisCacheConfigurationMap;
46.     }
47. ​
48.     private RedisCacheConfiguration getRedisCacheConfigurationWithTtl(Integer seconds) {
49.         Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
50.         ObjectMapper om = new ObjectMapper();
51.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
52.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
53.         jackson2JsonRedisSerializer.setObjectMapper(om);
54.         RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig();
55.         redisCacheConfiguration = redisCacheConfiguration.serializeValuesWith(
56.                 RedisSerializationContext
57.                         .SerializationPair
58.                         .fromSerializer(jackson2JsonRedisSerializer)
59.         ).entryTtl(Duration.ofSeconds(seconds));
60. ​
61.         return redisCacheConfiguration;
62.     }
63. }

复制代码

类名上有注解@Configuration，代表该类会在启动时加入进bean集合。
然后在RedisController下编写测试函数，如下：

1. @Autowired
2.     private SqlSession sqlSession;
3.     @GetMapping(value = "/Redis/TestRedisCache")
4.     @ResponseBody
5.     @DS("db2")
6.     @Cacheable(cacheNames = "userCache", key = "#id")
7.     @ApiOperation(value="查询单条记录",notes = "查询")
8.     public List<user> TestRedisCache(Integer id) {
9.         //读取第二个数据库的值
10.         UserMapper mapper = sqlSession.getMapper(UserMapper.class);
11.         List<user> users = mapper.test();
12.         return users;
13.     }

复制代码

使用@Cacheable注解缓存接口的返回值，cacheNames的值和key的值，组合起来成为是缓存中的键值对的key值，如下图。

----------------------------------------------------------------------------------------------------
到此，SpringBoot中Redis的基础使用就已经介绍完了。
代码已经传到Github上了，欢迎大家下载。
Github地址：https://github.com/kiba518/dynamicdb
----------------------------------------------------------------------------------------------------
注：此文章为原创，任何形式的转载都请联系作者获得授权并注明出处！
若您觉得这篇文章还不错，请点击下方的【推荐】，非常感谢！
https://www.cnblogs.com/kiba/p/17480377.html
 
 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！