springboot整合redis-SpringBoot（22）

1. 在 Spring Boot 中集成 Redis

  （1）完成配置基础项。

    添加 Redis、MySQL、MyBatis 依赖。
  （2）配置MySQL、Redis服务器

    可以直接在application.yml文件中逬行配置，具体配置方法见以下代码：
查看代码

1. # 应用名称
2. spring:
3.   redis:
4.     host: 127.0.0.1
5.     port: 6379
6.     jedis:
7.       pool:
8.         max-active: 8
9.         max-wait: -1
10.         max-idle: 8
11.         min-idle: 0
12.     timeout: 5000
13.   datasource:
14.     druid:
15.       driver-class-name: com.mysql.cj.jdbc.Driver
16.       url: jdbc:mysql://localhost:3306/springboot?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&useSSL=true
17.       username: root
18.       password: 123456
19.     thymeleaf:
20.       mode: HTML
21.       encoding: UTF-8
22.       servlet:
23.         content-type: text/html
24.       cache: false
25.       prefix: classpath:/static/
27. mybatis:
28.   # spring boot集成mybatis的方式打印sql
29.   configuration:
30.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
31. # 应用服务 WEB 访问端口
32. server:
33.   port: 8080

复制代码

  （3）在入口类加上@EnableCaching注解，开启缓存支持。

2. 配置Redis类

  要想启用Spring缓存支持，需创建一个CacheManager的Bean

1. package com.intehel.demo.config;
3. import org.springframework.cache.CacheManager;
4. import org.springframework.cache.annotation.CachingConfigurerSupport;
5. import org.springframework.cache.interceptor.KeyGenerator;
6. import org.springframework.context.annotation.Bean;
7. import org.springframework.context.annotation.Configuration;
8. import org.springframework.data.redis.cache.RedisCacheManager;
9. import org.springframework.data.redis.connection.RedisConnectionFactory;
10. import org.springframework.data.redis.core.RedisTemplate;
11. import org.springframework.data.redis.core.StringRedisTemplate;
12. import java.lang.reflect.Method;
14. @Configuration
15. public class RedisConfig extends CachingConfigurerSupport {
17.     //在缓存对象集合中，缓存是以key-value形式保存的
18.     //如果没有指定缓存的key，则Spring Boot 会使用SimpleKeyGenerator生成key
19.     @Override
20.     @Bean
21.     public KeyGenerator keyGenerator() {
22.         return new KeyGenerator() {
23.             @Override
24.             //定义缓存key的生成策略
25.             public Object generate(Object target, Method method, Object... params) {
26.                 StringBuilder sb = new StringBuilder();
27.                 sb.append(target.getClass().getName());
28.                 sb.append(method.getName());
29.                 for (Object obj : params) {
30.                     sb.append(obj.toString());
31.                 }
32.                 return sb.toString();
33.             }
34.         };
35.     }
36.     @SuppressWarnings("rawtypes")
37.     @Bean
38.     //缓存管理器 2.X版本
39.     public CacheManager cacheManager(RedisConnectionFactory connectionFactory) {
40.         RedisCacheManager cacheManager = RedisCacheManager.create(connectionFactory);
41.         return cacheManager;
42.     }
43.     //缓存管理器 1.X版本
44. /*    public CacheManager cacheManager(@SuppressWarnings("rawtypes")RedisTemplate redisTemplate){
45.         return new RedisCacheManager(redisTemplate);
46.     }*/
48.     @Bean
49.     //注册成Bean被Spring管理，如果没有这个Bean，则Redis可视化工具中的中文内容都会以二进制存储，不易检查
50.     public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory){
51.         RedisTemplate<String,Object> redisTemplate = new RedisTemplate<String,Object>();
52.         redisTemplate.setConnectionFactory(factory);
53.         return redisTemplate;
54.     }
56.     @Bean
57.     public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory factory){
58.         StringRedisTemplate stringRedisTemplate = new StringRedisTemplate();
59.         stringRedisTemplate.setConnectionFactory(factory);
60.         return stringRedisTemplate;
61.     }
62. }

复制代码

3.创建测试实体类

  创建用于数据操作的测试实体类，见以下代码:

1. package com.intehel.demo.domain;
3. import lombok.AllArgsConstructor;
4. import lombok.Data;
5. import lombok.NoArgsConstructor;
6. import java.io.Serializable;
8. @Data
9. @NoArgsConstructor
10. @AllArgsConstructor
11. public class Person implements Serializable {
12.     private Long id;
13.     private String name;
14.     private Integer age;
15.     private String address;
16. }

复制代码

4. 实现实体和数据表的映射关系

1. package com.intehel.demo.mapper;
3. import com.intehel.demo.domain.Person;
4. import org.apache.ibatis.annotations.*;
5. import org.springframework.stereotype.Repository;
7. @Repository
8. @Mapper
9. public interface PersonMapper {
10.     @Insert("insert into person(name, age,address) values(#{name},#{age},#{address})")
11.     int addPerson(@Param("name")String name, @Param("age")String age, @Param("address")String address);
12.     @Select("select * from person where id = #{id}")
13.     Person findById(@Param("id")String id);
14.     @Update("update person set age = #{age},name = #{name},address = #{address} where id = #{id}")
15.     int updateById(Person person);
16.     @Delete("delete from person where id = #{id}")
17.     void deleteById(@Param("id")String id);
18. }

复制代码

5. 创建Redis缓存服务层

1. package com.intehel.demo.service;
3. import com.intehel.demo.domain.Person;
4. import com.intehel.demo.mapper.PersonMapper;
5. import org.springframework.beans.factory.annotation.Autowired;
6. import org.springframework.cache.annotation.CacheConfig;
7. import org.springframework.cache.annotation.CacheEvict;
8. import org.springframework.cache.annotation.CachePut;
9. import org.springframework.cache.annotation.Cacheable;
10. import org.springframework.stereotype.Service;
12. @Service
13. @CacheConfig(cacheNames = "person")
14. public class PersonService {
15.     @Autowired
16.     PersonMapper personMapper;
17.     @Cacheable(key = "#p0")
18.     public Person selectPerson(String id){
19.         System.out.println("selectPerson");
20.         return personMapper.findById(id);
21.     }
22.     @CachePut(key = "#p0")
23.     public void updatePerson(Person person){
24.         System.out.println("updatePerson");
25.         personMapper.updateById(person);
26.     }
27.     @CacheEvict(key = "#p0",allEntries = true)
28.     public void deletePerson(String id){
29.         System.out.println("deletePerson");
30.         personMapper.deleteById(id);}
31. }

复制代码

代码解释如下。

• @Cacheable：将查询结果缓存到Redis中。
  
• key="#p0"：指定传入的第1个参数作为Redis的key。
  
• @CachePut：指定key, 将更新的结果同步到Redis中。
  
• @CacheEvict：指定key, 删除缓存数据。
  
• @allEntries=true:方法调用后将立即清除缓存
  

6.完成增加、删除、修改和查询测试API

1. package com.intehel.demo.controller;
3. import com.intehel.demo.service.PersonService;
4. import com.intehel.demo.domain.Person;
5. import org.springframework.beans.factory.annotation.Autowired;
6. import org.springframework.web.bind.annotation.PathVariable;
7. import org.springframework.web.bind.annotation.RequestBody;
8. import org.springframework.web.bind.annotation.RequestMapping;
9. import org.springframework.web.bind.annotation.RestController;
11. @RestController
12. @RequestMapping("/user")
13. public class PersonController {
14.     @Autowired
15.     PersonService personService;
16.     @RequestMapping(value = "/{id}")
17.     public Person selectPerson(@PathVariable String id){
18.         return personService.selectPerson(id);
19.     }
20.     @RequestMapping(value = "/update")
21.     public String updatePerson(@RequestBody Person person){
22.         personService.updatePerson(person);
23.         return "success";
24.     }
25.     @RequestMapping(value = "/delete/{id}")
26.     public String deletePerson(@PathVariable String id){
27.         personService.deletePerson(id);
28.         return "delete success";
29.     }
30. }

复制代码

  启动项目，多次访问http://localhost:8080/user/1 第一次时控制台会出现select信息，代表对数据库进行了查询操作。后面再访问时则不会出现提示，表示没有对数据库执行操作，而是使用 Redis中的缓存数据。


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