DRUID鏈接池的實用 配置詳解

• DRUID介紹

    DRUID是阿里巴巴開源平臺上一個數據庫鏈接池實現，它結合了C3P0、DBCP、PROXOOL等DB池的優勢，同時加入了日誌監控，能夠很好的監控DB池鏈接和SQL的執行狀況，能夠說是針對監控而生的DB鏈接池(聽說是目前最好的鏈接池,不知道速度有沒有BoneCP快)。

 

• 配置參數

和其它鏈接池同樣DRUID的DataSource類爲：com.alibaba.druid.pool.DruidDataSource，基本配置參數以下：

 

配置	缺省值	說明
name		配置這個屬性的意義在於，若是存在多個數據源，監控的時候能夠經過名字來區分開來。  若是沒有配置，將會生成一個名字，格式是："DataSource-" + System.identityHashCode(this)
jdbcUrl		鏈接數據庫的url，不一樣數據庫不同。例如：  mysql : jdbc:mysql://10.20.153.104:3306/druid2  oracle : jdbc:oracle:thin:@10.20.149.85:1521:ocnauto
username		鏈接數據庫的用戶名
password		鏈接數據庫的密碼。若是你不但願密碼直接寫在配置文件中，可使用ConfigFilter。詳細看這裏：https://github.com/alibaba/druid/wiki/%E4%BD%BF%E7%94%A8ConfigFilter
driverClassName	根據url自動識別	這一項可配可不配，若是不配置druid會根據url自動識別dbType，而後選擇相應的driverClassName(建議配置下)
initialSize	0	初始化時創建物理鏈接的個數。初始化發生在顯示調用init方法，或者第一次getConnection時
maxActive	8	最大鏈接池數量
maxIdle	8	已經再也不使用，配置了也沒效果
minIdle		最小鏈接池數量
maxWait		獲取鏈接時最大等待時間，單位毫秒。配置了maxWait以後，缺省啓用公平鎖，併發效率會有所降低，若是須要能夠經過配置useUnfairLock屬性爲true使用非公平鎖。
poolPreparedStatements	false	是否緩存preparedStatement，也就是PSCache。PSCache對支持遊標的數據庫性能提高巨大，好比說oracle。在mysql下建議關閉。
maxOpenPreparedStatements	-1	要啓用PSCache，必須配置大於0，當大於0時，poolPreparedStatements自動觸發修改成true。在Druid中，不會存在Oracle下PSCache佔用內存過多的問題，能夠把這個數值配置大一些，好比說100
validationQuery		用來檢測鏈接是否有效的sql，要求是一個查詢語句。若是validationQuery爲null，testOnBorrow、testOnReturn、testWhileIdle都不會其做用。
testOnBorrow	true	申請鏈接時執行validationQuery檢測鏈接是否有效，作了這個配置會下降性能。
testOnReturn	false	歸還鏈接時執行validationQuery檢測鏈接是否有效，作了這個配置會下降性能
testWhileIdle	false	建議配置爲true，不影響性能，而且保證安全性。申請鏈接的時候檢測，若是空閒時間大於timeBetweenEvictionRunsMillis，執行validationQuery檢測鏈接是否有效。
timeBetweenEvictionRunsMillis		有兩個含義：  1) Destroy線程會檢測鏈接的間隔時間2) testWhileIdle的判斷依據，詳細看testWhileIdle屬性的說明
numTestsPerEvictionRun		再也不使用，一個DruidDataSource只支持一個EvictionRun
minEvictableIdleTimeMillis
connectionInitSqls		物理鏈接初始化的時候執行的sql
exceptionSorter	根據dbType自動識別	當數據庫拋出一些不可恢復的異常時，拋棄鏈接
filters		屬性類型是字符串，經過別名的方式配置擴展插件，經常使用的插件有：  監控統計用的filter:stat日誌用的filter:log4j防護sql注入的filter:wall
proxyFilters		類型是List<com.alibaba.druid.filter.Filter>，若是同時配置了filters和proxyFilters，是組合關係，並不是替換關係

 

• 使用方法

DB數據源的使用方法也就是2種，一種是在代碼中寫死經過NEW操做符建立DataSSource，而後set一些鏈接屬性，這裏不在累述;另一種是基於SPRING的配置方法，而後讓SPRING的Context自動加載配置（如下配置文件默認都在項目根目錄下conf文件夾中）

一、屬性文件:application.properties(DataSource鏈接參數)

 

jdbc.driverClassName=com.mysql.jdbc.Driver 
jdbc.url=jdbc:mysql://127.0.0.1:3306/test 
jdbc.username=root 
jdbc.password=1qaz!QAZ

 

二、SPRING配置文件：spring-base.xml

 

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns=" http://www.springframework.org/schema/beans" 
 xmlns:xsi=" http://www.w3.org/2001/XMLSchema-instance" xmlns:batch=" http://www.springframework.org/schema/batch" 
 xsi:schemaLocation=" http://www.springframework.org/schema/beans 
           http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">

 

 <bean id="propertyConfigure" 
  class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> 
  <property name="locations"> 
   <list> 
    <value>./conf/application.properties</value> 
   </list> 
  </property> 
 </bean>

 

 <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" 
  init-method="init" destroy-method="close"> 
  <property name="driverClassName" value="${jdbc.driverClassName}" /> 
  <property name="url" value="${jdbc.url}" /> 
  <property name="username" value="${jdbc.username}" /> 
  <property name="password" value="${jdbc.password}" /> 
  <!-- 配置初始化大小、最小、最大 --> 
  <property name="initialSize" value="1" /> 
  <property name="minIdle" value="1" /> 
  <property name="maxActive" value="10" />

  <!-- 配置獲取鏈接等待超時的時間 --> 
  <property name="maxWait" value="10000" />

  <!-- 配置間隔多久才進行一次檢測，檢測須要關閉的空閒鏈接，單位是毫秒 --> 
  <property name="timeBetweenEvictionRunsMillis" value="60000" />

  <!-- 配置一個鏈接在池中最小生存的時間，單位是毫秒 --> 
  <property name="minEvictableIdleTimeMillis" value="300000" />

  <property name="testWhileIdle" value="true" />

  <!-- 這裏建議配置爲TRUE，防止取到的鏈接不可用 --> 
  <property name="testOnBorrow" value="true" /> 
  <property name="testOnReturn" value="false" />

  <!-- 打開PSCache，而且指定每一個鏈接上PSCache的大小 --> 
  <property name="poolPreparedStatements" value="true" /> 
  <property name="maxPoolPreparedStatementPerConnectionSize" 
   value="20" />

  <!-- 這裏配置提交方式，默認就是TRUE，能夠不用配置 -->

  <property name="defaultAutoCommit" value="true" />

  <!-- 驗證鏈接有效與否的SQL，不一樣的數據配置不一樣 --> 
  <property name="validationQuery" value="select 1 " /> 
  <property name="filters" value="stat" /> 
  <property name="proxyFilters"> 
   <list> 
    <ref bean="logFilter" /> 
   </list> 
  </property> 
 </bean>

 

 <bean id="logFilter" class="com.alibaba.druid.filter.logging.Slf4jLogFilter"> 
  <property name="statementExecutableSqlLogEnable" value="false" /> 
 </bean>

</beans>

上面紅色標註部分爲監控DB池鏈接執行監控，後面在作詳細說明.

 

• 監控方式

一、WEB方式監控配置

<servlet> 
     <servlet-name>DruidStatView</servlet-name> 
     <servlet-class>com.alibaba.druid.support.http.StatViewServlet</servlet-class> 
 </servlet> 
 <servlet-mapping> 
     <servlet-name>DruidStatView</servlet-name> 
     <url-pattern>/druid/*</url-pattern> 
 </servlet-mapping> 
 <filter> 
  <filter-name>druidWebStatFilter</filter-name> 
  <filter-class>com.alibaba.druid.support.http.WebStatFilter</filter-class> 
  <init-param> 
   <param-name>exclusions</param-name> 
   <param-value>/public/*,*.js,*.css,/druid*,*.jsp,*.swf</param-value> 
  </init-param> 
  <init-param> 
   <param-name>principalSessionName</param-name> 
   <param-value>sessionInfo</param-value> 
  </init-param> 
  <init-param> 
   <param-name>profileEnable</param-name> 
   <param-value>true</param-value> 
  </init-param> 
 </filter> 
 <filter-mapping> 
  <filter-name>druidWebStatFilter</filter-name> 
  <url-pattern>/*</url-pattern> 
 </filter-mapping>

 

把上面servlet配置添加到項目web.xml便可。而後運行Tomcat，瀏覽器輸入 http://IP:PROT/druid

就能夠打開Druid的監控頁面了.

二、日誌文件監控

Druid提供了多種日誌文件監控 commons-logging、log4j等，這裏咱們主要使用slf4j和logback來進行日誌監控配置。

首先要引入slf4j和logback相關的jar文件（從Maven公共倉庫下載 http://search.maven.org/）

<slf4j.version>1.7.7</slf4j.version> 
<logback.version>1.1.2</logback.version>

 

<dependency> 
    <groupId>org.slf4j</groupId> 
    <artifactId>slf4j-api</artifactId> 
    <version>${slf4j.version}</version> 
 </dependency> 
<dependency> 
    <groupId>ch.qos.logback</groupId> 
    <artifactId>logback-access</artifactId> 
    <version>${logback.version}</version> 
</dependency> 
<dependency> 
    <groupId>ch.qos.logback</groupId> 
    <artifactId>logback-core</artifactId> 
    <version>${logback.version}</version> 
</dependency> 
<dependency> 
    <groupId>ch.qos.logback</groupId> 
    <artifactId>logback-classic</artifactId> 
    <version>${logback.version}</version> 
</dependency> 

 

接下配置logback的配置文件(./conf/logback.xml)

 

<configuration>

 <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> 
  <layout class="ch.qos.logback.classic.PatternLayout"> 
   <Pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n 
   </Pattern> 
  </layout> 
 </appender>

 <appender name="FILE" class="ch.qos.logback.core.FileAppender"> 
  <file>./logs/druid_info.log</file> 
  <layout class="ch.qos.logback.classic.PatternLayout"> 
   <Pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</Pattern> 
  </layout> 
  <filter class="ch.qos.logback.classic.filter.ThresholdFilter"> 
   <level>debug</level> 
  </filter> 
 </appender>

 <root level="DEBUG"> 
  <appender-ref ref="FILE" /> 
 </root> 
</configuration>

 

最後就是寫一個測試類進行測試

public class TestMain {

 public static void loadLoggerContext() { 
  System.getProperties().put("logback.configurationFile", "./conf/logback.xml"); 
  LoggerContext lc = (LoggerContext) LoggerFactory.getILoggerFactory(); 
  StatusPrinter.setPrintStream(System.err); 
  StatusPrinter.print(lc); 
 }

 public static void main(String[] args) {   try {    loadLoggerContext();    FileSystemXmlApplicationContext context = new FileSystemXmlApplicationContext("./conf/spring-base.xml");   } catch (Exception e) {    System.out.println(e);   }  } }