Spring boot 集成 分页,druid,redis
2021/9/27 19:11:25
本文主要是介绍Spring boot 集成 分页,druid,redis,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
分页
1. pom.xml配置
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId> </dependency> <dependency> <groupId>com.github.pagehelper</groupId> <artifactId>pagehelper-spring-boot-starter</artifactId> <version>1.2.12</version> </dependency>
2.application.properties
# -------------------- pagehelper B --------------------------- pagehelper.helper-dialect= mysql #pagehelper.reasonable=true #pagehelper.support-methods-arguments=true #pagehelper.params=count=countSql # -------------------- pagehelper E ---------------------------
3.PageBean.java, PagingInterceptor.java,拷入项目中
3.1、PageBean.java
package com.example.sbdemo03.util; import org.springframework.util.StringUtils; import javax.servlet.http.HttpServletRequest; import java.util.Map; public class PageBean { /** * 页码 */ private int page = 1; /** * 每页显示的记录数 */ private int rows = 10; /** * 总记录数 */ private int total = 0; /** * 是否分页 */ private boolean pagination = true; /** * 分页查询url */ private String url; /** * 存放请求参数,用于生成隐藏域中的元素 */ private Map<String,String[]> parameterMap; public Map<String, String[]> getParameterMap() { return parameterMap; } public void setParameterMap(Map<String, String[]> parameterMap) { this.parameterMap = parameterMap; } public String getUrl() { return url; } public void setUrl(String url) { this.url = url; } /** * 设置分页公共参数 * @return */ public void setRequest(HttpServletRequest request) { if(!StringUtils.isEmpty(request.getParameter("page"))) { this.setPage(Integer.valueOf(request.getParameter("page"))); } if(!StringUtils.isEmpty(request.getParameter("rows"))) { this.setRows(Integer.valueOf(request.getParameter("rows"))); } if(!StringUtils.isEmpty(request.getParameter("pagination"))) { this.setPagination(Boolean.valueOf(request.getParameter("pagination"))); } this.url = request.getRequestURI(); Map<String,String[]> mm = request.getParameterMap(); this.parameterMap = request.getParameterMap(); } public int getPage() { return page; } public void setPage(int page) { this.page = page; } public int getRows() { return rows; } public void setRows(int rows) { this.rows = rows; } public int getTotal() { return total; } public void setTotal(int total) { this.total = total; } //计算页数据下标 public int getStartIndex() { return (this.page - 1) * this.rows; } public boolean isPagination() { return pagination; } public void setPagination(boolean pagination) { this.pagination = pagination; } //获取总页数 public int getTotalPageNum() { if(this.getTotal() % this.rows == 0) { return this.getTotal() / this.rows; } else { return this.getTotal() / this.rows + 1; } } //获取上一页 public int getPreviousPageNum() { return this.page - 1 > 0 ? this.page - 1 : this.page; } //获取下一页 public int getNextPageNum() { return this.page + 1 < this.getTotalPageNum() ? this.page + 1 : this.getTotalPageNum(); } @Override public String toString() { return "PageBean [page=" + page + ", rows=" + rows + ", total=" + total + ", pagination=" + pagination + "]"; } }
3.2、PagingInterceptor.java
package com.example.sbdemo03.util; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; import org.springframework.stereotype.Component; import java.util.List; /** * 环绕通知处理分页 * * @author Administrator * @create 2019-11-0915:11 */ @Component @Aspect public class PagingInterceptor { //@Around(value = "execution(* *..*Service.*Page(..))") @Around(value = "@annotation(com.example.sbdemo03.annotation.Paging))") public Object paging(ProceedingJoinPoint proceedingJoinPoint) throws Throwable { Object[] args = proceedingJoinPoint.getArgs(); PageBean pageBean = getPageBean(args); if (pageBean != null && pageBean.isPagination()) { PageHelper.startPage(pageBean.getPage(), pageBean.getRows()); } Object rv = proceedingJoinPoint.proceed(); if(pageBean != null && pageBean.isPagination() && rv != null) { PageInfo pageInfo = new PageInfo((List)rv); pageBean.setTotal(Long.valueOf(pageInfo.getTotal()).intValue()); } return rv; } //获取pagebean对象 private PageBean getPageBean(Object[] args) { PageBean pageBean = null; for (Object arg : args) { if (arg instanceof PageBean) { pageBean = (PageBean) arg; } } return pageBean; } }
3.4 自定义注解
package com.zking.sbdemo03.annotation; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) public @interface Paging { }
druid数据库连接池
阿里开源的数据库连接池,使用java开发,提供强大的监控和扩展功能,可以替换DBCP和C3P0连接池,性能要比其他的连接池要好。
1、pom.xml
<dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.21</version> </dependency>
2、application.properties
#--------------------- druid config B ------------------------ #config druid spring.datasource.type=com.alibaba.druid.pool.DruidDataSource #初始化时建立物理连接的个数 spring.datasource.druid.initial-size=5 #最小连接池数量 spring.datasource.druid.min-idle=5 #最大连接池数量 maxIdle已经不再使用 spring.datasource.druid.max-active=20 #获取连接时最大等待时间,单位毫秒 spring.datasource.druid.max-wait=60000 #申请连接的时候检测,如果空闲时间大于timeBetweenEvictionRunsMillis,执行validationQuery检测连接是否有效。 spring.datasource.druid.test-while-idle=true #既作为检测的间隔时间又作为testWhileIdel执行的依据 spring.datasource.druid.time-between-eviction-runs-millis=60000 #销毁线程时检测当前连接的最后活动时间和当前时间差大于该值时,关闭当前连接 spring.datasource.druid.min-evictable-idle-time-millis=30000 #用来检测连接是否有效的sql 必须是一个查询语句 #mysql中为 select 1 #oracle中为 select 1 from dual spring.datasource.druid.validation-query=select 1 #申请连接时会执行validationQuery检测连接是否有效,开启会降低性能,默认为true spring.datasource.druid.test-on-borrow=false #归还连接时会执行validationQuery检测连接是否有效,开启会降低性能,默认为true spring.datasource.druid.test-on-return=false #当数据库抛出不可恢复的异常时,抛弃该连接 #spring.datasource.druid.exception-sorter=true #是否缓存preparedStatement,mysql5.5+建议开启 spring.datasource.druid.pool-prepared-statements=true #当值大于0时poolPreparedStatements会自动修改为true spring.datasource.druid.max-pool-prepared-statement-per-connection-size=20 #配置扩展插件 spring.datasource.druid.filters=stat,wall #通过connectProperties属性来打开mergeSql功能;慢SQL记录 spring.datasource.druid.connection-properties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500 #合并多个DruidDataSource的监控数据 spring.datasource.druid.use-global-data-source-stat=true # WebStatFilter配置,说明请参考Druid Wiki,配置_配置WebStatFilter #是否启用StatFilter默认值true spring.datasource.druid.web-stat-filter.enabled=true spring.datasource.druid.web-stat-filter.url-pattern=/* #经常需要排除一些不必要的url,比如*.js,/jslib/*等等 spring.datasource.druid.web-stat-filter.exclusions=*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/* #Druid内置提供了一个StatViewServlet用于展示Druid的统计信息 #设置访问druid监控页的账号和密码,默认没有 spring.datasource.druid.stat-view-servlet.enabled=true spring.datasource.druid.stat-view-servlet.reset-enable=false spring.datasource.druid.stat-view-servlet.login-username=admin spring.datasource.druid.stat-view-servlet.login-password=admin #DruidStatView的servlet-mapping spring.datasource.druid.stat-view-servlet.url-pattern=/druid/* #允许列表,只有配置在此处的ip才允许访问durid监控平台 spring.datasource.druid.stat-view-servlet.allow=127.0.0.1 #拒绝列表,配置下此处的ip将被拒绝访问druid监控平台 spring.datasource.druid.stat-view-servlet.deny= #--------------------- druid config E ------------------------
redis
1、pom.xml
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
2、application.properties
# -------------------- redis config B ------------------------- # Redis数据库索引(默认为0) spring.redis.database=0 # Redis服务器地址 spring.redis.host=192.168.0.24 # Redis服务器连接端口 spring.redis.port=6379 # Redis服务器连接密码(默认为空) spring.redis.password= # 连接池最大连接数(使用负值表示没有限制) spring.redis.jedis.pool.max-active=100 # 连接池最大阻塞等待时间(使用负值表示没有限制) spring.redis.jedis.pool.max-wait=-1ms # 连接池中的最大空闲连接 spring.redis.jedis.pool.max-idle=10 # 连接池中的最小空闲连接 spring.redis.jedis.pool.min-idle=0 # 连接超时时间(毫秒) spring.redis.jedis.timeout=1000 # -------------------- redis config E -------------------------
3、redis缓存的一些注意事项
只应将热数据放到缓存中 所有缓存信息都应设置过期时间 缓存过期时间应当分散以避免集中过期(防止雪崩) 缓存key应具备可读性 应避免不同业务出现同名缓存key 可对key进行适当的缩写以节省内存空间 选择合适的数据结构 确保写入缓存中的数据是完整且正确的 避免使用耗时较长的操作命令,如:keys * Redis默认配置中操作耗时超过10ms即视为慢查询 一个key对应的数据不应过大 对于string类型,一个key对应的value大小应控制在10K以内,1K左右更优hash类型,不应超过5000行 避免缓存穿透 数据库中未查询到的数据,可在Redis中设置特殊标识,以避免因缓存中无数据而导致每次请求均达到数据库 缓存层不应抛出异常 缓存应有降级处理方案,缓存出了问题要能回源到数据库进行处理 可以进行适当的缓存预热 对于上线后可能会有大量读请求的应用,在上线之前可预先将数据写入缓存中 读的顺序是先缓存,后数据库;写的顺序是先数据库,后缓存 数据一致性问题 数据源发生变更时可能导致缓存中数据与数据源中数据不一致,应根据实际业务需求来选择适当的缓存更新策略: 主动更新:在数据源发生变更时同步更新缓存数据或将缓存数据过期。一致性高,维护成本较高。 被动删除:根据缓存设置的过期时间有Redis负责数据的过期删除。一致性较低,维护成本较低。
这篇关于Spring boot 集成 分页,druid,redis的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-06-26结对编程到底难不难?答案在这里
- 2024-06-19《2023版Java工程师》课程升级公告
- 2024-06-15matplotlib作图不显示3D图,怎么办?
- 2024-06-1503-Loki 日志监控
- 2024-06-1504-让LLM理解知识 -Prompt
- 2024-06-05做软件测试需要懂代码吗?
- 2024-06-0514-ShardingSphere的分布式主键实现
- 2024-06-03为什么以及如何要进行架构设计权衡?
- 2024-05-31全网首发第二弹!软考2024年5月《软件设计师》真题+解析+答案!(11-20题)
- 2024-05-31全网首发!软考2024年5月《软件设计师》真题+解析+答案!(21-30题)