• Springboot 之整合(Druid数据库连接池、PageHelper实现分页、Redis缓存)

    目录

    1. springboot 整合Druid数据库连接池

     1.1 导依赖

     1.2  修改application.properties添加druid相关配置

     1.3 启动主类 访问Druid 数据库连接池

    2. springboot 整合pagehelper实现分页

     2.1 导依赖

     2.2 修改application.properties添加druid相关配置

     2.3 aop模块

     2.4 utils模块

     2.5 service模块

     2.6 serviceimpl模块

     2.7  controller模块

    3. springboot 整合Redis缓存

      3.1 导依赖

      3.2 修改application.properties添加druid相关配置

      3.3 config模块

      3.4 实现类模块

    1. springboot 整合Druid数据库连接池

      1.1 导依赖

    1.         
    2.         <dependency>
    3.             <groupId>com.alibabagroupId>
    4.             <artifactId>druid-spring-boot-starterartifactId>
    5.             <version>1.1.10version>
    6.         dependency>

      1.2  修改application.properties添加druid相关配置

    1. spring:
    2.   datasource:
    3.     type: com.alibaba.druid.pool.DruidDataSource
    4.     #配置druid 数据库连接池
    5.     druid:
    6.       #2.连接池配置
    7.       #初始化连接池的连接数量 大小，最小，最大
    8.       initial-size: 5
    9.       min-idle: 5
    10.       max-active: 20
    11.       #配置获取连接等待超时的时间
    12.       max-wait: 60000
    13.       #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
    14.       time-between-eviction-runs-millis: 60000
    15.       # 配置一个连接在池中最小生存的时间，单位是毫秒
    16.       min-evictable-idle-time-millis: 30000
    17.       validation-query: SELECT 1 FROM DUAL
    18.       test-while-idle: true
    19.       test-on-borrow: true
    20.       test-on-return: false
    21.       # 是否缓存preparedStatement，也就是PSCache  官方建议MySQL下建议关闭   个人建议如果想用SQL防火墙 建议打开
    22.       pool-prepared-statements: true
    23.       max-pool-prepared-statement-per-connection-size: 20
    24.       # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
    25.       filter:
    26.         stat:
    27.           merge-sql: true
    28.           slow-sql-millis: 5000
    29.       #3.基础监控配置
    30.       web-stat-filter:
    31.         enabled: true
    32.         url-pattern: /*
    33.         #设置不统计哪些URL
    34.         exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
    35.         session-stat-enable: true
    36.         session-stat-max-count: 100
    37.       stat-view-servlet:
    38.         enabled: true
    39.         url-pattern: /druid/*
    40.         reset-enable: true
    41.         #设置监控页面的登录名和密码
    42.         login-username: admin
    43.         login-password: admin
    44.         allow: 127.0.0.1
    45.         #deny: 192.168.1.100

      1.3 启动主类 访问Druid 数据库连接池

         http://localhost:8080/druid/index.html

     

    2. springboot 整合pagehelper实现分页

      2.1 导依赖

    1.         
    2.         <dependency>
    3.             <groupId>com.github.pagehelpergroupId>
    4.             <artifactId>pagehelper-spring-boot-starterartifactId>
    5.             <version>1.2.3version>
    6.         dependency>
    7.         
    8.         <dependency>
    9.             <groupId>org.springframework.bootgroupId>
    10.             <artifactId>spring-boot-starter-aopartifactId>
    11.         dependency>

      2.2 修改application.properties添加druid相关配置

    1.  
    2. spring:
    3.   #spring 循环依赖处理
    4.   main:
    5.     allow-circular-references: true
    6.  
    7. #配置分页插件
    8. pagehelper:
    9.   reasonable: true
    10.   supportMethodsArguments: true
    11.   page-size-zero: true
    12.   helper-dialect: mysql
    13.  
    14.

      2.3 aop模块

       PageAspect

    1. package com.jmh.springboot03.aop;
    2.  
    3. import com.github.pagehelper.PageHelper;
    4. import com.github.pagehelper.PageInfo;
    5. import com.jmh.springboot03.utils.PageBean;
    6. import lombok.extern.slf4j.Slf4j;
    7. import org.aspectj.lang.ProceedingJoinPoint;
    8. import org.aspectj.lang.annotation.Around;
    9. import org.aspectj.lang.annotation.Aspect;
    10. import org.springframework.stereotype.Component;
    11.  
    12. import java.util.List;
    13.  
    14. @Component
    15. @Aspect
    16. public class PageAspect {
    17.  
    18.     /**
    19.      *  *：返回值不限
    20.      *  *..：包名不限
    21.      *  *Service：以Service结尾的接口或者是类
    22.      *  list*：以list开头的方法
    23.      *  (..)：参数及参数类型不限
    24.      */
    25.     @Around(value="execution(* *..*Service.list*(..))")
    26.     public Object invoke(ProceedingJoinPoint joinPoint) throws Throwable {
    27.         //获取目标方法的执行参数数组
    28.         Object[] args = joinPoint.getArgs();
    29.         //定义PageBean对象
    30.         PageBean pageBean=null;
    31.         //循环目标方法的参数数组
    32.         for (Object arg : args) {
    33.             //判断参数是否与PageBean一致
    34.             if(arg instanceof PageBean){
    35.                 pageBean= (PageBean) arg;
    36.                 break;
    37.             }
    38.         }
    39.  
    40.         //判断是否是分页，并设置PageHelper的分页参数
    41.         if (null != pageBean && pageBean.isPagination())
    42.             PageHelper.startPage(pageBean.getPage(), pageBean.getRows());
    43.  
    44.         Object returnValue = joinPoint.proceed(args);
    45.  
    46.         if (null != pageBean && pageBean.isPagination()){
    47.            /* //原始List分页配置
    48.             List list= (List) returnValue;
    49.             PageInfo pageInfo=new PageInfo<>(list);
    50.             pageBean.setTotal(pageInfo.getTotal()+"");
    52.              //响应分装类分页配置
    53.             JsonResponseBody jsonResponseBody= (JsonResponseBody) returnValue;
    54.             PageInfo pageInfo=new PageInfo((List) jsonResponseBody.getData());
    55.             jsonResponseBody.setTotal((int) pageInfo.getTotal());*/
    56.         }
    57.  
    58.         return returnValue;
    59.     }
    60. }

      2.4 utils模块

       PageBean

    1. package com.jmh.springboot03.utils;
    2.  
    3. import java.io.Serializable;
    4. import java.util.Map;
    5.  
    6. import javax.servlet.http.HttpServletRequest;
    7.  
    8. public class PageBean implements Serializable {
    9.  
    10. 	private static final long serialVersionUID = 2422581023658455731L;
    11.  
    12. 	//页码
    13. 	private int page=1;
    14. 	//每页显示记录数
    15. 	private int rows=10;
    16. 	//总记录数
    17. 	private int total=0;
    18. 	//是否分页
    19. 	private boolean isPagination=true;
    20. 	//上一次的请求路径
    21. 	private String url;
    22. 	//获取所有的请求参数
    23. 	private Map map;
    24. 	
    25. 	public PageBean() {
    26. 		super();
    27. 	}
    28. 	
    29. 	//设置请求参数
    30. 	public void setRequest(HttpServletRequest req) {
    31. 		String page=req.getParameter("page");
    32. 		String rows=req.getParameter("rows");
    33. 		String pagination=req.getParameter("pagination");
    34. 		this.setPage(page);
    35. 		this.setRows(rows);
    36. 		this.setPagination(pagination);
    37. 		this.url=req.getContextPath()+req.getServletPath();
    38. 		this.map=req.getParameterMap();
    39. 	}
    40. 	public String getUrl() {
    41. 		return url;
    42. 	}
    43.  
    44. 	public void setUrl(String url) {
    45. 		this.url = url;
    46. 	}
    47.  
    48. 	public Map getMap() {
    49. 		return map;
    50. 	}
    51.  
    52. 	public void setMap(Map map) {
    53. 		this.map = map;
    54. 	}
    55.  
    56. 	public int getPage() {
    57. 		return page;
    58. 	}
    59.  
    60. 	public void setPage(int page) {
    61. 		this.page = page;
    62. 	}
    63. 	
    64. 	public void setPage(String page) {
    65. 		if(null!=page&&!"".equals(page.trim()))
    66. 			this.page = Integer.parseInt(page);
    67. 	}
    68.  
    69. 	public int getRows() {
    70. 		return rows;
    71. 	}
    72.  
    73. 	public void setRows(int rows) {
    74. 		this.rows = rows;
    75. 	}
    76. 	
    77. 	public void setRows(String rows) {
    78. 		if(null!=rows&&!"".equals(rows.trim()))
    79. 			this.rows = Integer.parseInt(rows);
    80. 	}
    81.  
    82. 	public int getTotal() {
    83. 		return total;
    84. 	}
    85.  
    86. 	public void setTotal(int total) {
    87. 		this.total = total;
    88. 	}
    89. 	
    90. 	public void setTotal(String total) {
    91. 		this.total = Integer.parseInt(total);
    92. 	}
    93.  
    94. 	public boolean isPagination() {
    95. 		return isPagination;
    96. 	}
    97. 	
    98. 	public void setPagination(boolean isPagination) {
    99. 		this.isPagination = isPagination;
    100. 	}
    101. 	
    102. 	public void setPagination(String isPagination) {
    103. 		if(null!=isPagination&&!"".equals(isPagination.trim()))
    104. 			this.isPagination = Boolean.parseBoolean(isPagination);
    105. 	}
    106. 	
    107. 	/**
    108. 	 * 获取分页起始标记位置
    109. 	 * @return
    110. 	 */
    111. 	public int getStartIndex() {
    112. 		//(当前页码-1)*显示记录数
    113. 		return (this.getPage()-1)*this.rows;
    114. 	}
    115. 	
    116. 	/**
    117. 	 * 末页
    118. 	 * @return
    119. 	 */
    120. 	public int getMaxPage() {
    121. 		int totalpage=this.total/this.rows;
    122. 		if(this.total%this.rows!=0)
    123. 			totalpage++;
    124. 		return totalpage;
    125. 	}
    126. 	
    127. 	/**
    128. 	 * 下一页
    129. 	 * @return
    130. 	 */
    131. 	public int getNextPage() {
    132. 		int nextPage=this.page+1;
    133. 		if(this.page>=this.getMaxPage())
    134. 			nextPage=this.getMaxPage();
    135. 		return nextPage;
    136. 	}
    137. 	
    138. 	/**
    139. 	 * 上一页
    140. 	 * @return
    141. 	 */
    142. 	public int getPreivousPage() {
    143. 		int previousPage=this.page-1;
    144. 		if(previousPage<1)
    145. 			previousPage=1;
    146. 		return previousPage;
    147. 	}
    148.  
    149. 	@Override
    150. 	public String toString() {
    151. 		return "PageBean [page=" + page + ", rows=" + rows + ", total=" + total + ", isPagination=" + isPagination
    152. 				+ "]";
    153. 	}
    154. }

      2.5 service模块

        PageBean 加到接口方法要实现分页的参数里即可

    List listBook(Book book, PageBean pageBean);

      2.6 serviceimpl模块

        PageBean 加到实现类接口方法要实现分页的参数里即可

    1.     @Override
    2.     public List listBook(Book book, PageBean pageBean) {
    3.         List books = bookMapper.listBook(book);
    4.         return books;
    5.     }

     2.7  controller模块

    1.     @RequestMapping("/listBook")
    2.     public JsonResponseBody> listBook(HttpServletRequest request,Book book){
    3.         //实例化PageBaen
    4.         PageBean pageBean=new PageBean();
    5.         //设置打开分页
    6.         pageBean.setRequest(request);
    7.         List books = bookService.listBook(book,pageBean);
    8.         return new JsonResponseBody<>(books,pageBean.getTotal());
    9.     }

    3. springboot 整合Redis缓存

      3.1 导依赖

    1.         <dependency>
    2.             <groupId>org.springframework.bootgroupId>
    3.             <artifactId>spring-boot-starter-data-redisartifactId>
    4.         dependency>

      3.2 修改application.properties添加druid相关配置

    1. spring:
    2.   #配置redis
    3.   redis:
    4.     host: 127.0.0.1 //ip地址
    5.     database: 0     //redis 一共有16个数据库 参数代码数据库下标
    6.     password: 1234  //密码 没有密码忽略
    7.     port: 6379      //端口号

      3.3 config模块

        RedisConfig

    1. package com.jmh.springboot03.config;
    2.  
    3. import org.springframework.beans.factory.annotation.Autowired;
    4. import org.springframework.beans.factory.annotation.Configurable;
    5. import org.springframework.context.annotation.Bean;
    6. import org.springframework.context.annotation.Configuration;
    7. import org.springframework.data.redis.connection.RedisConnectionFactory;
    8. import org.springframework.data.redis.core.RedisTemplate;
    9. import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
    10. import org.springframework.data.redis.serializer.StringRedisSerializer;
    11.  
    12. import javax.annotation.Resource;
    13.  
    14. /**
    15.  * @author 蒋明辉
    16.  * @data 2022/10/1 17:08
    17.  */
    18. @Configuration
    19. public class RedisConfig {
    20.  
    21.     @Bean
    22.     public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){
    23.         //实例化一个redis模板
    24.         RedisTemplate redisTemplate=new RedisTemplate<>();
    25.         //设置连接工厂
    26.         redisTemplate.setConnectionFactory(redisConnectionFactory);
    27.         //针对string类型的key和value进行序列化
    28.         redisTemplate.setKeySerializer(new StringRedisSerializer());
    29.         redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    30.         //针对has类型的key和value进行序列化
    31.         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
    32.         redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
    33.         //将上诉代码启用
    34.         redisTemplate.afterPropertiesSet();
    35.         return redisTemplate;
    36.  
    37.     }
    38. }
    39.  
    40.

      3.4 实现类模块

    1. package com.jmh.springboot03.service.impl;
    2.  
    3. import com.jmh.springboot03.exception.BusinessException;
    4. import com.jmh.springboot03.mapper.BookMapper;
    5. import com.jmh.springboot03.model.Book;
    6. import com.jmh.springboot03.service.IBookService;
    7. import com.jmh.springboot03.utils.JsonResponseStatus;
    8. import com.jmh.springboot03.utils.PageBean;
    9. import org.springframework.data.redis.core.RedisTemplate;
    10. import org.springframework.stereotype.Service;
    11.  
    12. import javax.annotation.Resource;
    13. import java.util.List;
    14.  
    15. /**
    16.  * @author 蒋明辉
    17.  * @data 2022/10/1 15:07
    18.  */
    19. @Service
    20. public class BookServiceImpl implements IBookService {
    21.  
    22.     /**
    23.      * 注入书本Mapper接口
    24.      */
    25.     @Resource
    26.     private BookMapper bookMapper;
    27.  
    28.     /**
    29.      * 注入redis模板
    30.      */
    31.     @Resource
    32.     private RedisTemplate redisTemplate;
    33.  
    34.     @Override
    35.     public Book selectByPrimaryKey(Integer id) {
    36.         Book book = bookMapper.selectByPrimaryKey(id);
    37.         //将获取到的数据保存到redis数据库里面
    38.         redisTemplate.opsForValue().set("book:"+book.getId(),book);
    39.         return book;
    40.     }
    41.  
    42.  
    43. }

  • 相关阅读:
    Rust逆向学习 (2)
    数据结构：KMP算法的原理图解和代码解析
    React-Router link方式跳转
    One-YOLOv5 v1.2.0发布：支持分类、检测、实例分割
    Android 逆向入门保姆级教程
    likeadmin和fastapi的bug
    move_base代码解析（一）MoveBase::executeCb
    聊一聊损失函数
    一分钟带你了解音视频开发进阶（先收藏了）
    flask旅游景点推荐
  • 原文地址：https://blog.csdn.net/m0_63300795/article/details/127135897