Springboot缓存-基本环境搭建

一、缓存- 搭建步骤如下

1、使用idea工具创建springboot工程 步骤：

File---->----New---->Project

Spring Initializr---->Next

选择插件 2、第二步，启动数据库并用navicat客户端连接数据库，并创建两张表，分别是：department、employee 3、第三步，在bean层编写实体类 实体类(创建javaBean封装数据)

Department.java

package spring.mystudy.springbootcache.bean; public class Department { private Integer id; private String departmentName; public Department() { super(); // TODO Auto-generated constructor stub } public Department(Integer id, String departmentName) { super(); this.id = id; this.departmentName = departmentName; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getDepartmentName() { return departmentName; } public void setDepartmentName(String departmentName) { this.departmentName = departmentName; } @Override public String toString() { return "Department [id=" + id + ", departmentName=" + departmentName + "]"; } }

Employee.java

package spring.mystudy.springbootcache.bean; public class Employee { private Integer id; private String lastName; private String email; private Integer gender; //性别 1男 0女 private Integer dId; public Employee() { super(); } public Employee(Integer id, String lastName, String email, Integer gender, Integer dId) { super(); this.id = id; this.lastName = lastName; this.email = email; this.gender = gender; this.dId = dId; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getLastName() { return lastName; } public void setLastName(String lastName) { this.lastName = lastName; } public String getEmail() { return email; } public void setEmail(String email) { this.email = email; } public Integer getGender() { return gender; } public void setGender(Integer gender) { this.gender = gender; } public Integer getdId() { return dId; } public void setdId(Integer dId) { this.dId = dId; } @Override public String toString() { return "Employee [id=" + id + ", lastName=" + lastName + ", email=" + email + ", gender=" + gender + ", dId=" + dId + "]"; } }

3、第三步，整合MyBatis操作数据库：分两步操作： 3.1 配置数据源信息

application.properties

spring.datasource.url=jdbc:mysql://localhost:3306/spring_cache spring.datasource.username=root spring.datasource.password=123456 #spring.datasource.driver-class-name=com.mysql.jdbc.Driver

3.2 使用注解版的MyBatis； 3.2.1 @MapperScan指定需要扫描的mapper接口所在的包 3.3 在mapper包下，编写两个接口，分别是： DepartmentMapper、EmployeeMapper

DepartmentMapper.java

package spring.mystudy.springbootcache.mapper; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Select; import spring.mystudy.springbootcache.bean.Department; @Mapper public interface DepartmentMapper { @Select("SELECT * FROM department WHERE id = #{id}") Department getDeptById(Integer id); }

EmployeeMapper.java

package spring.mystudy.springbootcache.mapper; import org.apache.ibatis.annotations.*; import spring.mystudy.springbootcache.bean.Employee; @Mapper public interface EmployeeMapper { @Select("SELECT * FROM employee WHERE id = #{id}") public Employee getEmpById(Integer id); @Update("UPDATE employee SET lastName=#{lastName},email=#{email},gender=#{gender},d_id=#{dId} WHERE id=#{id}") public void updateEmp(Employee employee); @Delete("DELETE FROM employee WHERE id=#{id}") public void deleteEmpById(Integer id); @Insert("INSERT INTO employee(lastName,email,gender,d_id) VALUES(#{lastName},#{email},#{gender},#{dId})") public void insertEmployee(Employee employee); @Select("SELECT * FROM employee WHERE lastName = #{lastName}") Employee getEmpByLastName(String lastName); }

3.4、第四步，在src\test\java\spring\mystudy\springbootcache目录下的SpringbootCacheApplicationTests.java 编写

SpringbootCacheApplicationTests

package spring.mystudy.springbootcache; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import spring.mystudy.springbootcache.bean.Employee; import spring.mystudy.springbootcache.mapper.EmployeeMapper; @SpringBootTest class SpringbootCacheApplicationTests { @Autowired EmployeeMapper employeeMapper; @Test void contextLoads() { Employee empById = employeeMapper.getEmpById(1); System.out.println(empById); } }

**4、在数据库随便插入一条

5、测试与运行

6、接着，我们再创建servic和controller层

如图所示：

servicece层

EmployeeService.java

package spring.mystudy.springbootcache.service; import spring.mystudy.springbootcache.bean.Employee; import spring.mystudy.springbootcache.mapper.EmployeeMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @Service public class EmployeeService { @Autowired EmployeeMapper employeeMapper; public Employee getEmp(Integer id){ System.out.println("查询"+id+"号员工"); Employee emp = employeeMapper.getEmpById(id); return emp; }

controller层

EmployeeController.java

package spring.mystudy.springbootcache.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import spring.mystudy.springbootcache.bean.Employee; import spring.mystudy.springbootcache.service.EmployeeService; @RestController public class EmployeeController { @Autowired EmployeeService employeeService; @GetMapping("/emp/{id}") public Employee getEmployee(@PathVariable("id") Integer id){ Employetie employee = employeeService.getEmp(id); return employee; }

接着在数据库添加一条数据 然后，我们需要在全局配置文件：application.properties，加一个配置参数： mybatis.configuration.map-underscore-to-camel-case=true

7、启动SpringBootApplication的启动类

访问出现错误 控制台打印错误信息： 解决方案： 根据提示需要在配置数据库的连接信息中，在MySQL的URL后面加上“?serverTimezone=UTC” 再次启动： 访问： http://127.0.0.1:8080/emp/1 http://127.0.0.1:8080/emp/2 http://127.0.0.1:8080/emp/3

基本ok

总结： 搭建基本环境 1、导入数据库文件 创建出department和employee表 2、创建javaBean封装数据 3、整合MyBatis操作数据库 3.1 配置数据源信息 3.2 使用注解版的MyBatis； 3.2.1 @MapperScan指定需要扫描的mapper接口所在的包

二、缓存-@Cacheable初始体验

快速体验缓存

步骤： 1、开启基于注解的缓存 @EnableCaching 2、标注缓存注解即可 @Cacheable @CachePut 默认使用的是ConcurrentMapCacheManager==ConcurrentMapCache；将数据保存在 ConcurrentMap<Object, Object>中

开发中使用缓存中间件；redis、memcached、ehcache；

2.0 实践操作 首先在启动器类上加入@EnableCaching注解 2.0.1 比如我们吧控制台的日志文件清空，这个缓存的注解会一次发送请求查询的 发送请求1号员工与2号员工 控制台也会打印号员工与2号员工信息 2.0.2 如果想要在控制台打印出1号员工和2号员工发送请求的日志信息，只需要在全局配置文件application.properties加入一个参数即可： logging.level.spring.mystudy.springbootcache.mapper=debug

3个员工发送请求： http://127.0.0.1:8080/emp/1 http://127.0.0.1:8080/emp/2 http://127.0.0.1:8080/emp/3 日志打印信息： 2.0.3 如果想要把相同的数据，直接从缓存中获取，不用调用方法我们可以在service层的的方法上加入一个@Cacheable注解即可 而CacheManager管理多个Cache组件的，对缓存的真正CRUD操作在Cache组件中，每一个缓存组件有自己唯一一个名字；

原理：

1、自动配置类；CacheAutoConfiguration 2、缓存的配置类 org.springframework.boot.autoconfigure.cache.GenericCacheConfiguration org.springframework.boot.autoconfigure.cache.JCacheCacheConfiguration org.springframework.boot.autoconfigure.cache.EhCacheCacheConfiguration org.springframework.boot.autoconfigure.cache.HazelcastCacheConfiguration org.springframework.boot.autoconfigure.cache.InfinispanCacheConfiguration org.springframework.boot.autoconfigure.cache.CouchbaseCacheConfiguration org.springframework.boot.autoconfigure.cache.RedisCacheConfiguration org.springframework.boot.autoconfigure.cache.CaffeineCacheConfiguration org.springframework.boot.autoconfigure.cache.GuavaCacheConfiguration org.springframework.boot.autoconfigure.cache.SimpleCacheConfiguration【默认】 org.springframework.boot.autoconfigure.cache.NoOpCacheConfiguration 3、哪个配置类默认生效：SimpleCacheConfiguration； 4、给容器中注册了一个CacheManager：ConcurrentMapCacheManager 5、可以获取和创建ConcurrentMapCache类型的缓存组件；他的作用将数据保存在ConcurrentMap中；

运行流程：

1、方法运行之前，先去查询Cache（缓存组件），按照cacheNames指定的名字获取； （CacheManager先获取相应的缓存），第一次获取缓存如果没有Cache组件会自动创建。 2、去Cache中查找缓存的内容，使用一个key，默认就是方法的参数； key是按照某种策略生成的；默认是使用keyGenerator生成的，默认使用SimpleKeyGenerator生成key； SimpleKeyGenerator生成key的默认策略； 如果没有参数；key=new SimpleKey()； 如果有一个参数：key=参数的值 如果有多个参数：key=new SimpleKey(params)； 3、没有查到缓存就调用目标方法； 4、将目标方法返回的结果，放进缓存中 @Cacheable标注的方法执行之前先来检查缓存中有没有这个数据，默认按照参数的值作为key去查询缓存， 如果没有就运行方法并将结果放入缓存；以后再来调用就可以直接使用缓存中的数据；

核心：

1）、使用CacheManager【ConcurrentMapCacheManager】按照名字得到Cache【ConcurrentMapCache】组件 2）、key使用keyGenerator生成的，默认是SimpleKeyGenerator

几个属性：

cacheNames/value：指定缓存组件的名字;将方法的返回结果放在哪个缓存中，是数组的方式，可以指定多个缓存；

key：缓存数据使用的key；可以用它来指定。默认是使用方法参数的值 1-方法的返回值 编写SpEL； #i d;参数id的值 #a0 #p0 #root.args[0] getEmp[2] keyGenerator：key的生成器；可以自己指定key的生成器的组件id key/keyGenerator：二选一使用; cacheManager：指定缓存管理器；或者cacheResolver指定获取解析器 condition：指定符合条件的情况下才缓存； ,condition = "#id>0" condition = "#a0>1"：第一个参数的值》1的时候才进行缓存 unless:否定缓存；当unless指定的条件为true，方法的返回值就不会被缓存；可以获取到结果进行判断 unless = "#result == null" unless = "#a0==2":如果第一个参数的值是2，结果不缓存； sync：是否使用异步模式

@CacheEvict：缓存清除 key：指定要清除的数据 allEntries = true：指定清除这个缓存中所有的数据 beforeInvocation = false：缓存的清除是否在方法之前执行 默认代表缓存清除操作是在方法执行之后执行;如果出现异常缓存就不会清除 beforeInvocation = true： 代表清除缓存操作是在方法运行之前执行，无论方法是否出现异常，缓存都清除

20.4 测试一个缓存是否起效，首先我们把控制台的日志文件清空，接着，比如我们发送请求2号员工，发现控制台没有打印任何信息。说明缓存起效了！ 当我们在数据库插入一条新数据 发送请求4号员工 由于4号员工是新数据，没有被缓存过的，所以能在控制台能打印日志信息 当第二次发送请求4号员工，发现控制台没有打印任何信息，说明4号员工已经被缓存进来了！

三、缓存Cacheable其他属性

缓存config 1、首先创建config层，并创建MyCacheConfig类

MyCacheConfig.java

package spring.mystudy.springbootcache.config; import org.springframework.cache.interceptor.KeyGenerator; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.lang.reflect.Method; import java.util.Arrays; @Configuration public class MyCacheConfig { @Bean("myKeyGenerator") public KeyGenerator keyGenerator(){ return new KeyGenerator(){ @Override public Object generate(Object target, Method method, Object... params) { return method.getName()+"["+ Arrays.asList(params).toString()+"]"; } }; } }

也可以用另一种方式指定，比如： 比如缓存指定2号员工

四、缓存–CachePut

@CachePut：既调用方法，又更新缓存数据；同步更新缓存 运行时机：

1、先调用目标方法 2、将目标方法的结果缓存起来

@CachePut(value = "emp") public Employee updateEmp(Employee employee){ System.out.println("updateEmp:"+employee); employeeMapper.updateEmp(employee); return employee; }

测试步骤： 1、查询1号员工；查到的结果会放在缓存中； key：1 value：lastName：张三 2、以后查询还是之前的结果 3、更新1号员工；【lastName:zhangsan；gender:0】 将方法的返回值也放进缓存了； key：传入的employee对象 值：返回的employee对象； 4、查询1号员工？ 应该是更新后的员工； key = “#employee.id”:使用传入的参数的员工id； key = “#result.id”：使用返回后的id @Cacheable的key是不能用#result 为什么是没更新前的？【1号员工没有在缓存中更新】

五、@CacheEvict：缓存清除

key：指定要清除的数据 allEntries = true：指定清除这个缓存中所有的数据 beforeInvocation = false：缓存的清除是否在方法之前执行 默认代表缓存清除操作是在方法执行之后执行;如果出现异常缓存就不会清除 beforeInvocation = true： 代表清除缓存操作是在方法运行之前执行，无论方法是否出现异常，缓存都清除

service层添加

@CacheEvict(value="emp",key = "#id") public void deleteEmp(Integer id){ System.out.println("deleteEmp:"+id); //employeeMapper.deleteEmpById(id); int i = 10/0; }

controller层添加

@GetMapping("/delemp") public String deleteEmp(Integer id){ employeeService.deleteEmp(id); return "success"; }

修改数据库访问： http://127.0.0.1:8080/emp?id=3&lastName=张三&email=lisi@123.com&gender=2&d_id=1 修改前： 修改后：