前言
Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。从2010年3月15日起，Redis的开发工作由VMware主持。从2013年5月开始，Redis的开发由Pivotal赞助。
为什么要使用Redis呢？
举个例子，假如系统中有2千万用户信息，用户信息基本固定，一旦录入很少变动，那么你每次加载所有用户信息时，如果都要请求数据库，数据库编译并执行你的查询语句，这样效率就会低下很多，针对这种信息不经常变动并且数据量。
较大的情况，通常做法，就是把他加入缓存，每次取数前先去判断，如果缓存不为空，那么就从缓存取值，如果为空，再去请求数据库，并将数据加入缓存，这样大大提高系统访问效率。
相关依赖
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
<!-- springboot版本 --><parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.2.7.RELEASE</version></parent><!-- 依赖 --><dependencies> <!-- redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!-- 通用池 --> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> </dependency> <!-- mysql --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <!-- mybatis --> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.1</version> </dependency> <!-- 通用mapper --> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>2.1.5</version> </dependency> <!-- lombok --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> <!-- test --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> </dependency></dependencies> |
配置
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
# 端口server: port: 9998# mysql数据源spring: datasource: username: root password: root url: jdbc:mysql://127.0.0.1:3306/dbtest?serverTimezone=GMT%2B8# redis redis: host: localhost port: 6379 timeout: 1000 jedis: pool: min-idle: 5 max-idle: 10 max-wait: -1# mybatismybatis: mapper-locations: classpath:/mybatis/mapper/*.xml type-aliases-package: cn.kgc.entities# 开启驼峰命名 configuration: map-underscore-to-camel-case: true# loglogging: level: cn.kgc: debug |
数据库
|
1
2
3
4
5
6
7
8
9
10
11
|
#建表CREATE TABLE `emp` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL, `age` int(11) NULL DEFAULT NULL, PRIMARY KEY (`id`) USING BTREE) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;#插入数据INSERT INTO `emp` VALUES (1, '张三', 18);INSERT INTO `emp` VALUES (2, '李四', 20);INSERT INTO `emp` VALUES (3, '王五', 22); |
实体类
Emp
|
1
2
3
4
5
6
7
8
9
|
@Data@Table(name = "emp")public class Emp implements Serializable { @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Integer id; private String name; private Integer age;} |
RedisConfig
指定Redis序列化方式
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
@Configurationpublic class RedisConfig { @Bean public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory){ RedisTemplate<String,Object> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(factory); // 指定kv的序列化方式 Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); redisTemplate.setKeySerializer(new StringRedisSerializer()); return redisTemplate; }} |
Mapper
Emp的Mapper接口继承tk的Mapper类，泛型为实体类Emp
|
1
2
3
|
public interface EmpMapper extends Mapper<Emp> {} |
Service接口
业务接口定义add添加和getEmpById根据id查询的方法
|
1
2
3
4
|
public interface EmpService { public void add(Emp emp); public Object getEmpById(Integer id);} |
Service实现类
先查Redis，Redis没有数据再从数据库中拿数据，同时缓存到Redis中。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
@Service@Slf4jpublic class EmpServiceImpl implements EmpService { @Autowired public RedisTemplate redisTemplate; @Resource private EmpMapper empMapper; @Override public void add(Emp emp) { empMapper.insert(emp); } @Override public Object getEmpById(Integer id) { // 先从缓存获取数据，如果有则直接返回 // 如果无，则查询mysql,并将数据设置到缓存 String key = "user:" + id; Object userObj = redisTemplate.opsForValue().get(key); if(userObj == null){ synchronized (this.getClass()){ userObj = redisTemplate.opsForValue().get(key); if(userObj == null ){ log.debug("----> 查询数据库.............."); // 查数据库 Emp emp = empMapper.selectByPrimaryKey(id); redisTemplate.opsForValue().set(key,emp); return emp; }else{ log.debug("----> 查询缓存(同步代码块)>>>>>>>>>>>>>>>>>"); return userObj; } } }else{ log.debug("----> 查询缓存>>>>>>>>>>>>>>>>>"); } return userObj; }} |
测试Redis
Redis-Controller
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
@RestControllerpublic class RedisContoller { @Autowired private RedisTemplate redisTemplate; @GetMapping("/redis/get/{key}") public Object get(@PathVariable("key") String key){ return redisTemplate.opsForValue().get(key); } @PostMapping("/redis/set/{key}/{value}") public Object set(@PathVariable("key") String key, @PathVariable("value") String value){ redisTemplate.opsForValue().set(key,value); return "set success"; }} |
Controller
Redis+MySQL
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
@RestControllerpublic class EmpController { @Autowired private EmpService empService; @PostMapping("/emp") public String addEmp(Emp emp){ empService.add(emp); return "add ok"; } @GetMapping("/emp/{id}") public Object getEmpById(@PathVariable("id") Integer id){ ExecutorService es = Executors.newFixedThreadPool(200); for(int i=0 ;i<500;i++){ es.submit(new Runnable() { @Override public void run() { empService.getEmpById(id); } }); } return empService.getEmpById(id); }} |
到此这篇关于SpringBoot整合Redis入门之缓存数据的文章就介绍到这了,更多相关SpringBoot整合Redis缓存数据内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://blog.csdn.net/qq_31762741/article/details/121303901
