資訊專欄INFORMATION COLUMN
摘要：看過(guò)的一些書(shū)上也是多數(shù)介紹了這兩種數(shù)據(jù)庫(kù)連接池，自己做的也是使用。參考資料文檔首頁(yè)文檔問(wèn)題阿里學(xué)習(xí)，號(hào)稱最好的數(shù)據(jù)庫(kù)連接池常用數(shù)據(jù)庫(kù)連接池配置說(shuō)明學(xué)習(xí)整合，使用連接池使用和監(jiān)控配置數(shù)據(jù)源配置如果文章有錯(cuò)的地方歡迎指正，大家互相交流。
前言
本章節(jié)主要講解Druid數(shù)據(jù)庫(kù)連接池，為什么要學(xué)Druid數(shù)據(jù)庫(kù)連接池呢？？
我的知識(shí)儲(chǔ)備數(shù)據(jù)庫(kù)連接池有兩種->C3P0，DBCP，可是現(xiàn)在看起來(lái)并不夠用阿~當(dāng)時(shí)學(xué)習(xí)C3P0的時(shí)候，覺(jué)得這個(gè)數(shù)據(jù)庫(kù)連接池是挺強(qiáng)大的。看過(guò)的一些書(shū)上也是多數(shù)介紹了這兩種數(shù)據(jù)庫(kù)連接池，自己做的Demo也是使用C3P0?？墒乾F(xiàn)在看起來(lái)這兩種都不夠了~業(yè)界發(fā)展得真快呀
上面的我就沒(méi)有打碼了，都是一些熱心的開(kāi)發(fā)者評(píng)論，正因?yàn)樗麄兊脑u(píng)論才促使我會(huì)去學(xué)更好的東西，也希望大家多多指點(diǎn)~
于是乎，我就花一點(diǎn)時(shí)間去學(xué)習(xí)Druid數(shù)據(jù)庫(kù)連接池了...如果有錯(cuò)的地方往指正~~
Druid數(shù)據(jù)庫(kù)連接池是阿里的，因此文檔是有中文版本的，英語(yǔ)不好學(xué)起來(lái)也不用那么頭疼.
一、Druid介紹Druid一般的用處有兩個(gè)：
替代C3P0、DBCP數(shù)據(jù)庫(kù)連接池(因?yàn)樗男阅芨?
自帶監(jiān)控頁(yè)面，實(shí)時(shí)監(jiān)控應(yīng)用的連接池情況
所以本文主要是使用Druid作為數(shù)據(jù)庫(kù)連接池并且使用一下實(shí)時(shí)監(jiān)控應(yīng)用，做個(gè)入門(mén)學(xué)習(xí)~
二、搭建Druid環(huán)境由于簡(jiǎn)化配置，我就直接實(shí)用SpringBoot和SpringData JPA的方式來(lái)搭建一個(gè)Druid的Demo了~~~
2.1引入pom2.2Druid默認(rèn)的配置org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-test test mysql mysql-connector-java com.alibaba druid 1.1.5 org.springframework.boot spring-boot-starter-data-jpa ch.qos.logback logback-classic 1.2.3 test
配置數(shù)據(jù)源的信息(Druid),和JPA相關(guān)配置～
# 數(shù)據(jù)庫(kù)訪問(wèn)配置 # 主數(shù)據(jù)源，默認(rèn)的 spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://localhost:3306/druid spring.datasource.username=root spring.datasource.password=root # 下面為連接池的補(bǔ)充設(shè)置，應(yīng)用到上面所有數(shù)據(jù)源中 # 初始化大小，最小，最大 spring.datasource.initialSize=5 spring.datasource.minIdle=5 spring.datasource.maxActive=20 # 配置獲取連接等待超時(shí)的時(shí)間 spring.datasource.maxWait=60000 # 配置間隔多久才進(jìn)行一次檢測(cè)，檢測(cè)需要關(guān)閉的空閑連接，單位是毫秒 spring.datasource.timeBetweenEvictionRunsMillis=60000 # 配置一個(gè)連接在池中最小生存的時(shí)間，單位是毫秒 spring.datasource.minEvictableIdleTimeMillis=300000 spring.datasource.validationQuery=SELECT 1 FROM DUAL spring.datasource.testWhileIdle=true spring.datasource.testOnBorrow=false spring.datasource.testOnReturn=false # 打開(kāi)PSCache，并且指定每個(gè)連接上PSCache的大小 spring.datasource.poolPreparedStatements=true spring.datasource.maxPoolPreparedStatementPerConnectionSize=20 # 配置監(jiān)控統(tǒng)計(jì)攔截的filters，去掉后監(jiān)控界面sql無(wú)法統(tǒng)計(jì)，"wall"用于防火墻 spring.datasource.filters=stat,wall,log4j # 通過(guò)connectProperties屬性來(lái)打開(kāi)mergeSql功能；慢SQL記錄 spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000 # 合并多個(gè)DruidDataSource的監(jiān)控?cái)?shù)據(jù) #spring.datasource.useGlobalDataSourceStat=true #JPA配置 spring.jpa.hibernate.ddl-auto=update spring.jpa.show-sql=true spring.jackson.serialization.indent_output=true
更多的配置要去看官方文檔了～不過(guò)這里一般就夠用了。
2.3配置監(jiān)控頁(yè)面Druid的監(jiān)控統(tǒng)計(jì)功能是通過(guò)filter-chain擴(kuò)展實(shí)現(xiàn)，如果你要打開(kāi)監(jiān)控統(tǒng)計(jì)功能，配置StatFilter
配置druid數(shù)據(jù)源狀態(tài)監(jiān)控，配置一個(gè)攔截器和一個(gè)Servlet即可～
package com.example.demo; /** * Created by ozc on 2018/3/26. * * @author ozc * @version 1.0 */ import com.alibaba.druid.support.http.StatViewServlet; import com.alibaba.druid.support.http.WebStatFilter; import org.springframework.boot.web.servlet.FilterRegistrationBean; import org.springframework.boot.web.servlet.ServletRegistrationBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * druid 配置. *2.4JPA測(cè)試* 這樣的方式不需要添加注解：@ServletComponentScan * * @author Administrator */ @Configuration public class DruidConfiguration { /** * 注冊(cè)一個(gè)StatViewServlet * * @return */ @Bean public ServletRegistrationBean DruidStatViewServle2() { //org.springframework.boot.context.embedded.ServletRegistrationBean提供類的進(jìn)行注冊(cè). ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*"); //添加初始化參數(shù)：initParams //白名單： servletRegistrationBean.addInitParameter("allow", "127.0.0.1"); //IP黑名單 (存在共同時(shí)，deny優(yōu)先于allow) : 如果滿足deny的話提示:Sorry, you are not permitted to view this page. servletRegistrationBean.addInitParameter("deny", "192.168.1.73"); //登錄查看信息的賬號(hào)密碼. servletRegistrationBean.addInitParameter("loginUsername", "admin2"); servletRegistrationBean.addInitParameter("loginPassword", "123456"); //是否能夠重置數(shù)據(jù). servletRegistrationBean.addInitParameter("resetEnable", "false"); return servletRegistrationBean; } /** * 注冊(cè)一個(gè)：filterRegistrationBean * * @return */ @Bean public FilterRegistrationBean druidStatFilter2() { FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter()); //添加過(guò)濾規(guī)則. filterRegistrationBean.addUrlPatterns("/*"); //添加不需要忽略的格式信息. filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"); return filterRegistrationBean; } }
POJO:
@Entity
public class User implements Serializable {
/**
* serialVersionUID.
*/
private static final long serialVersionUID = 1L;
/**
* 主鍵.
*/
@Id
@GeneratedValue
private String id;
/**
* 用戶名.
*/
private String userName = "";
/**
* 手機(jī)號(hào)碼.
*/
private String mobileNo = "";
/**
* 郵箱.
*/
private String email = "";
/**
* 密碼.
*/
private String password = "";
/**
* 用戶類型.
*/
private Integer userType = 0;
/**
* 注冊(cè)時(shí)間.
*/
private Date registerTime = new Date();
/**
* 所在區(qū)域.
*/
private String region = "";
/**
* 是否有效 0 有效 1 無(wú)效.
*/
private Integer validity = 0;
/**
* 頭像.
*/
private String headPortrait = "";
}
Controller:
@RestController
public class UserController {
@Autowired
private UserRepos userRepos;
@RequestMapping(value="saveUser")
public User saveUser(){
return userRepos.save(new User());
}
@RequestMapping(value="/findByUserName")
public List findByUserName(String userName){
return userRepos.findByUserName(userName);
}
@RequestMapping(value="findByUserNameLike")
public List findByUserNameLkie(String userName){
return userRepos.findByUserNameLike(userName);
}
@RequestMapping(value="findByPage")
public Page findByPage(Integer userType){
return userRepos.findByUserType(userType, new PageRequest(1, 5));
}
}
Repository:
