开启生长之旅!这是我参加「日新计划 12 月更文挑战」的第6天,点击查看活动详情
前语
在上一节中,壹哥 带大家学习了Spring Boot中供给的缓存完成计划,尤其是Spring Cache这种完成计划,接下来在本章节中,我将带大家经过代码来详细完成缓存功用。
一. Spring Boot完成默认缓存
1. 创立Web项目
咱们按照之前的经历,创立一个SpringBoot的Web程序,详细过程略。
2. 增加依赖包
在pom.xml文件中增加如下核心依赖包。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId>
</dependency>
3. 创立application.yml装备文件
创立一个application.yml文件,在这里装备数据库和jpa的信息。
server:
port: 8080
spring:
application:
name: cache-demo
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: syc
url: jdbc:mysql://localhost:3306/spring-security?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&serverTimezone=UTC
#cache:
#type: generic #由redis进行缓存,一共有10种缓存计划
jpa:
database: mysql
show-sql: true #开发阶段,打印要履行的sql语句.
hibernate:
ddl-auto: update
4. 开启缓存功用
创立一个缓存装备类,主要是在该类上增加@EnableCaching注解,开启缓存功用。
package com.yyg.boot.config;
import org.springframework.cache.annotation.EnableCaching;
/**
* @Author 一一哥Sun
* @Date Created in 2020/4/14
* @Description Description
* EnableCaching启用缓存
*/
@Configuration
@EnableCaching
public class CacheConfig {
}
5. 创立User实体类
接着创立一个User实体类,封装用户信息。
package com.yyg.boot.domain;
import lombok.Data;
import lombok.ToString;
import javax.persistence.*;
import java.io.Serializable;
@Entity
@Table(name="user")
@Data
@ToString
public class User implements Serializable {
//IllegalArgumentException: DefaultSerializer requires a Serializable payload
// but received an object of type [com.syc.redis.domain.User]
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
private Long id;
@Column
private String username;
@Column
private String password;
}
6. 创立User仓库类
咱们再创立一个JpaRepository,完成对数据库的CRUD操作。
package com.yyg.boot.repository;
import com.yyg.boot.domain.User;
import org.springframework.data.jpa.repository.JpaRepository;
public interface UserRepository extends JpaRepository<User,Long> {
}
7. 创立Service服务类
7.1 定义UserService接口
package com.yyg.boot.service;
import com.yyg.boot.domain.User;
public interface UserService {
User findById(Long id);
User save(User user);
void deleteById(Long id);
}
7.2 完成UserServiceImpl类
package com.yyg.boot.service.impl;
import com.yyg.boot.domain.User;
import com.yyg.boot.repository.UserRepository;
import com.yyg.boot.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
@Service
public class UserServiceImpl implements UserService {
@Autowired
private UserRepository userRepository;
//普通的缓存+数据库查询代码完成逻辑:
//User user=RedisUtil.get(key);
// if(user==null){
// user=userDao.findById(id);
// //redis的key="product_item_"+id
// RedisUtil.set(key,user);
// }
// return user;
/**
* 注解@Cacheable:查询的时分才使用该注解!
* 注意:在Cacheable注解中支撑EL表达式
* redis缓存的key=user_1/2/3....
* redis的缓存雪崩,缓存穿透,缓存预热,缓存更新...
* condition = "#result ne null",条件表达式,当满意某个条件的时分才进行缓存
* unless = "#result eq null":当user目标为空的时分,不进行缓存
*/
@Cacheable(value = "user", key = "#id", unless = "#result eq null")
@Override
public User findById(Long id) {
return userRepository.findById(id).orElse(null);
}
/**
* 注解@CachePut:一般用在增加和修改办法中
* 既往数据库中增加一个新的目标,于此同时也往redis缓存中增加一个对应的缓存.
* 这样能够达到缓存预热的目的.
*/
@CachePut(value = "user", key = "#result.id", unless = "#result eq null")
@Override
public User save(User user) {
return userRepository.save(user);
}
/**
* CacheEvict:一般用在删去办法中
*/
@CacheEvict(value = "user", key = "#id")
@Override
public void deleteById(Long id) {
userRepository.deleteById(id);
}
}
8. 创立Controller接口办法
然后创立一个Controller,定义几个URL接口进行测验。
package com.yyg.boot.web;
import com.yyg.boot.domain.User;
import com.yyg.boot.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("/user")
@Slf4j
public class UserController {
@Autowired
private UserService userService;
@PostMapping
public User saveUser(@RequestBody User user) {
return userService.save(user);
}
@GetMapping("/{id}")
public ResponseEntity<User> getUserById(@PathVariable("id") Long id) {
User user = userService.findById(id);
log.warn("user="+user.hashCode());
HttpStatus status = user == null ? HttpStatus.NOT_FOUND : HttpStatus.OK;
return new ResponseEntity<>(user, status);
}
@DeleteMapping("/{id}")
public String removeUser(@PathVariable("id") Long id) {
userService.deleteById(id);
return "ok";
}
}
9. 创立进口类
最终创立一个项目进口类,发动项目。
package com.yyg.boot;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class CacheApplication {
public static void main(String[] args) {
SpringApplication.run(CacheApplication.class, args);
}
}
10. 项目代码结构
这是完好的项目代码结构,各位能够参阅创立。
11. 发动项目进行测验
11.1 测验数据增加
咱们首要调用增加接口在Postman中履行,往数据库中增加一条数据。
能够看到数据库中,已经成功的增加了一条数据。
11.2 测验查询功用
然后咱们再测验一下查询接口办法。
此时能够看到操控台中,会打印出User目标的hashCode。
11.3 验证缓存作用
咱们再屡次履行查询接口,发现User目标的hashCode值不变,阐明数据都是来自于缓存,而不是每次都重新查询。
结语
至此,咱们就利用Spring Cache的注解,在Spring Boot中完成了缓存功用,你会发现这种缓存的完成是很简单的,你学会了吗?
今日小作业:
对学生信息管理体系进行缓存优化。