DRUID——為監控而生的DB池
1.? DRUID介紹
DRUID是阿里巴巴開源平臺上一個數據庫連接池實現，它結合了C3P0、DBCP、PROXOOL等DB池的優點，同時加入了日志監控，可以很好的監控DB池連接和SQL的執行情況，可以說是針對監控而生的DB連接池(據說是目前最好的連接池,不知道速度有沒有BoneCP快)。
2. 配置參數
和其它連接池一樣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，是組合關系，并非替換關系 |
3. 使用方法
DB數據源的使用方法也就是2種，一種是在代碼中寫死通過NEW操作符創建DataSSource，然后set一些連接屬性，這里不在累述;另外一種是基于SPRING的配置方法，然后讓SPRING的Context自動加載配置（以下配置文件默認都在項目根目錄下conf文件夾中）
1、屬性文件: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
2、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>
4.? 監控方式
1、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的監控頁面了。
2、日志文件監控
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); } } }
?
