• SpringBoot整合第三方技术----缓存、任务、邮件、消息


    一、缓存

    1.基本介绍

    缓存是一种介于数据永久存储介质与数据应用之间的数据临时存储介质

    目的:使用缓存可以有效减少低俗数据读取过程的此数(例如磁盘IO),提高系统性能(如果当前缓存中没有本次要查询的数据,则进行查询,否则就从缓存中获取,就不用再访问数据库,同时也减少了数据库的压力)

    缓存不仅可以用于提高永久性存储介质的数据读取效率,还可以提供临时的数据存储空间

    2.Spring缓存使用方式(默认Simple方式演示)

    springboot提供了缓存技术

        需要的maven坐标

    1. <dependency>
    2. <groupId>org.springframework.boot</groupId>
    3. <artifactId>spring-boot-starter-cache</artifactId>
    4. </dependency>

       基本配置 

    1. #第二种方法:Druid专用配置 推荐
    2. spring:
    3. datasource:
    4. druid:
    5. driver-class-name: com.mysql.cj.jdbc.Driver
    6. url: jdbc:mysql://localhost:3306/user_db?serverTimezone=GMT
    7. username: root
    8. password: admin
    9. #开启MP运行日志
    10. mybatis-plus:
    11. configuration:
    12. # 标准输出 打印到控制台上 以后我们就不用sout输出了, 这个东西会帮我们输出
    13. log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

     开启缓存功能

    1. @SpringBootApplication
    2. @EnableCaching // 这个注解的作用是开启缓存功能
    3. public class Springboot19CacheApplication {
    4. public static void main(String[] args) {
    5. SpringApplication.run(Springboot19CacheApplication.class, args);
    6. }
    7. }

    代码演示

    1. @RestController
    2. @RequestMapping("/books")
    3. public class BookController {
    4. @Autowired
    5. private BookService bookService;
    6. @GetMapping("{id}")
    7. public Book get(@PathVariable Integer id){
    8. return bookService.getById(id);
    9. }
    10. @PostMapping
    11. public boolean save (@RequestBody Book book){
    12. return bookService.save(book);
    13. }
    14. @PutMapping
    15. public boolean updata(@RequestBody Book book){
    16. return bookService.update(book);
    17. }
    18. @DeleteMapping("{id}")
    19. public boolean delete(@RequestBody Integer id){
    20. return bookService.delete(id);
    21. }
    22. @GetMapping
    23. public List<Book> getAll(){
    24. return bookService.getAll();
    25. }
    26. }
    1. @Mapper //通过这个实现数据库的操作 里面有数据库中各种各样的操作
    2. public interface BookDao extends BaseMapper<Book> {//指定泛型才能知道操作谁
    3. }
    1. @Data //get+set+toString+hashcode+equals 但是没有构造方法
    2. @TableName(value = "t_book")
    3. public class Book {
    4. // 这里的属性名 要和数据库表中的属性名一致,要不然最终的查询结果是null
    5. // 将数据库中的结果对此变量名进行注入
    6. @TableId(value="id",type = IdType.AUTO) //代表自增算法
    7. @TableField(value = "id")
    8. private int id;
    9. @TableField(value = "bookName")
    10. private String bookName;
    11. @TableField(value = "statue")
    12. private String statue;
    13. @TableField(value="type")
    14. private String type;
    15. public Book() {
    16. }
    17. public Book(int id, String bookName, String statue, String type) {
    18. this.id = id;
    19. this.bookName = bookName;
    20. this.statue = statue;
    21. this.type = type;
    22. }
    23. }
    1. public interface BookService extends IService<Book> {
    2. public Book getById(Integer id);
    3. public boolean save(Book book);
    4. public boolean update(Book book);
    5. public boolean delete(Integer id);
    6. public List<Book> getAll();
    7. }

    对getById方法设置缓存机制 

       就下面这个图而言,如果这个cacheSpace空间中有key的这个操作,那就从CacheSpace中找出来,如果没有的话,再执行方法体中的内容,从而达到了缓存的操作

    1. @Service
    2. public class BookServiceImpl extends ServiceImpl<BookDao, Book> implements BookService {
    3. @Autowired
    4. private BookDao bookDao;
    5. @Override
    6. @Cacheable(value = "catchSpace",key = "#id")
    7. //是否是课缓存的,其中要指定两个参数,value 就是放的位置,随便定义;下次找用id找,所以key=id
    8. // 运行之后,我们就会把查询之后的数据放到上面这个“id”里面,作为key
    9. public Book getById(Integer id){
    10. return bookDao.selectById(id);
    11. }
    12. @Override
    13. public boolean save(Book book) {
    14. return bookDao.insert(book) >0;
    15. }
    16. @Override
    17. public boolean update(Book book) {
    18. return bookDao.updateById(book) >0;
    19. }
    20. @Override
    21. public boolean delete(Integer id) {
    22. return bookDao.deleteById(id) >0;
    23. }
    24. @Override
    25. public List<Book> getAll() {
    26. return bookDao.selectList(null);
    27. }
    28. }

    运行下面这个程序

    1. @SpringBootApplication
    2. @EnableCaching // 这个注解的作用是开启缓存功能
    3. public class Springboot19CacheApplication {
    4. public static void main(String[] args) {
    5. SpringApplication.run(Springboot19CacheApplication.class, args);
    6. }
    7. }

    接下来在postman中执行下面的语句两次

     但是我们发现在idea中只有一条运行结果,所以我们缓存成功

    3.手机验证码利用缓存的方式验证

    controller.SMSCodeController

    1. @RestController
    2. @RequestMapping("/sms")
    3. public class SMSCodeController {
    4. @Autowired
    5. private SMSCodeService service;
    6. // 通过接受到的电话,得到code码
    7. @GetMapping
    8. public String getCode(String tele){
    9. String code = service.sendCodeToSMS(tele);
    10. return code;
    11. }
    12. // 检验一下code码是否正确
    13. // 把电话号码和验证码都给我们,然后验证是否正确
    14. @PostMapping
    15. public boolean checkCode( SMSCode smsCode){//SMSCode类型属性中包含tele和code
    16. return service.checkCode(smsCode);
    17. }
    18. }

    domain.SMSCode

    1. @Data
    2. public class SMSCode {
    3. private String tele; //手机号码
    4. private String code; //手机验证码
    5. }

    service.serviceImpl.SMSCodeServiceImpl

    1. @Service
    2. public class SMSCodeServiceImpl implements SMSCodeService {
    3. @Autowired
    4. private CodeUtils codeUtils;
    5. @Override
    6. // 开启缓存功能
    7. // @Cacheable(value = "cacheSpace" , key = "#tele") 这个语句在这里其实并不适用,因为我们一般的验证码都是一分钟以内,如果再次获取验证码,就不是这个了
    8. // value = "smsCode" 缓存空间
    9. @CachePut(value="smsCode",key="#tele") //这个注解可以做到往缓存中放入return的code值,把指定的返回值放到指定的key的位置
    10. public String sendCodeToSMS(String tele) {
    11. String code= codeUtils.generator(tele);
    12. return code;
    13. }
    14. @Override
    15. public boolean checkCode(SMSCode smsCode) {
    16. // 取出内存中的验证码与传递过来的验证码进行对比,如果相同,返回true
    17. String code = smsCode.getCode();
    18. String cacheCode =codeUtils.get(smsCode.getTele()); //这是缓存中的验证码,因为tele是key,所以在此处要传入一个tele
    19. return code.equals(cacheCode);
    20. }
    21. }

    service.SMSCodeService

    1. public interface SMSCodeService {
    2. public String sendCodeToSMS(String tele);
    3. public boolean checkCode(SMSCode smsCode);
    4. }

    utils.CodeUtils

    1. @Component
    2. public class CodeUtils {
    3. private String[] patch = {"00000","0000","000","00","0",""}; //利用数据结构的优化,进行补零
    4. public String generator(String tele){
    5. int hash = tele.hashCode(); //这个得到的tele的哈希值和我们即将要生成的验证码有很必要的关系
    6. int encryption = 20206666;
    7. // 第一次加密
    8. long result = hash ^ encryption;
    9. // 第二次加密
    10. long nowTime = System.currentTimeMillis();
    11. result = result^nowTime;
    12. // 取某result的某些位数作为 验证码
    13. long code = result%1000000; //六个余数
    14. code = code<0 ? -code :code; //将验证码的复数排除
    15. // 如果我们生成的code前面几位是零的话,就会省略了前面的零,但是省略的之后,就不足六位了,我们现在要对不足六位的数据进行补零
    16. String codeStr = code+"";
    17. int len = codeStr.length();
    18. return patch[len-1]+codeStr;
    19. }
    20. @Cacheable(value = "smsCode" , key = "#tele") //key在这里就是电话号码,类似将电话号码作为key
    21. public String get(String tele){
    22. // 如果缓存中有对应数据,那我们就利用key获取到了
    23. // 如果缓存中没有对应的数据,那我们就返回null,也非常的合理
    24. return null;
    25. }
    26. }

    postman获取验证码:

    postman对验证码进行验证 

     

    4.Ehcache缓存工具

       maven坐标

    1. <dependency>
    2. <groupId>net.sf.ehcache</groupId>
    3. <artifactId>ehcache</artifactId>
    4. </dependency>

    配置文件的配置

    1. #第二种方法:Druid专用配置 推荐
    2. spring:
    3. datasource:
    4. druid:
    5. driver-class-name: com.mysql.cj.jdbc.Driver
    6. url: jdbc:mysql://localhost:3306/user_db?serverTimezone=GMT
    7. username: root
    8. password: admin
    9. cache:
    10. type: ehcache
    11. #开启MP运行日志
    12. mybatis-plus:
    13. configuration:
    14. # 标准输出 打印到控制台上 以后我们就不用sout输出了, 这个东西会帮我们输出
    15. log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

    下面的这个配置要和上面的左边进行配对,如果有这个配置,但是没有坐标,一样会出现错误 

     以及还有下面的ehcache.xml配置文件

    上面的这组配置,是配置的默认的缓存的地方,但是从我们的代码来看,我们显然不是存放在默认的地方,而是“smsCode”缓存空间中,则我们还需要添加一组配置(不同的数据,缓存不一样,所以可以设置多个缓存策略)

    其中,下面的 “name”就是我们指定缓存空间

     

     

  • 相关阅读:
    每天一个数据分析题(一百六十四)
    使用拦截器来检测用户的登录状态
    [Kettle] 单变量统计
    nginx(CVE-2022-41741和41742) 漏洞修复
    【微信小程序开发】——奶茶点餐小程序的制作(二)
    论文精读:Focal Loss for Dense Object Detection
    Gradle学习笔记之Groovy简单使用
    archlinux fcitx5-rime五笔输入法
    [网络安全] PKI
    UI 设计的未来发展
  • 原文地址:https://blog.csdn.net/weixin_51351637/article/details/124767932