Java 數(shù)據(jù)庫(kù)連接池 Tomcat介紹
前言:
Tomcat 連接池是從 Tomcat 7 開始重新編寫的高并發(fā)連接池,用以取代以前 Tomcat 中使用的 DBCP 1 連接池,它可以配置在 Tomcat 中使用,也可以單獨(dú)使用。本文主要介紹 Tomcat 連接池的基本使用,文中使用到的軟件版本:Java 1.8.0_191、Tomcat 8.5.72、Spring Boot 2.3.12.RELEASE。
1、配置參數(shù)
1.1、基礎(chǔ)配置
| 參數(shù) | 默認(rèn)值 | 描述 |
| factory | ? | 必須,需要是 org.apache.tomcat.jdbc.pool.DataSourceFactory |
| type | ? | 應(yīng)該是?javax.sql.DataSource 或 javax.sql.XADataSource |
1.2、系統(tǒng)屬性
| 參數(shù) | 默認(rèn)值 | 描述 |
| org.apache.tomcat.jdbc.pool.onlyAttemptCurrentClassLoader | false | 是否只使用當(dāng)前的類加載器(加載該連接池的類加載器)來加載動(dòng)態(tài)類 |
1.3、一般參數(shù)
這些參數(shù)和 DBCP 一致,但有些默認(rèn)值不一樣。
| 參數(shù) | 默認(rèn)值 | 描述 |
| defaultAutoCommit | 驅(qū)動(dòng)的默認(rèn)值 | 是否自動(dòng)提交 |
| defaultReadOnly | 驅(qū)動(dòng)的默認(rèn)值 | 是否只讀 |
| defaultTransactionIsolation | 驅(qū)動(dòng)的默認(rèn)值 |
默認(rèn)的事務(wù)隔離級(jí)別 |
| defaultCatalog | ? |
默認(rèn)的 catalog。(目錄,類似于模式名,但比模式名更加抽象; |
| driverClassName | ? | 驅(qū)動(dòng)名稱 |
| url | ? | 連接 url |
| username | ? | 用戶名 |
| password | ? | 密碼 |
| maxActive | 100 | 最大活動(dòng)連接數(shù) |
| maxIdle | 100 | 最大空閑連接數(shù) |
| minIdle | 10 | 最小空閑連接數(shù) |
| initialSize | 10 | 初始連接數(shù) |
| maxWait | 3000 | 從連接池獲取連接,最大等待時(shí)間(秒) |
| testOnBorrow | false | 從連接池獲取連接時(shí),是否驗(yàn)證有效性;如果驗(yàn)證失敗,則丟棄該連接。 |
| testOnConnect | true | 連接創(chuàng)建時(shí),是否驗(yàn)證有效性 |
| testOnReturn | false | 連接返回連接池時(shí),是否驗(yàn)證有效性 |
| testWhileIdle | false | 連接空閑時(shí),是否驗(yàn)證有效性 |
| validationQuery | null |
連接校驗(yàn)的查詢sql |
| validationQueryTimeout | -1 | 校驗(yàn)查詢的超時(shí)時(shí)間(秒);非正數(shù)表示不啟用該特性。 |
| validatorClassName | null | 校驗(yàn)的類名,需實(shí)現(xiàn)?org.apache.tomcat.jdbc.pool.Validator 接口并包含一個(gè)無參構(gòu)造函數(shù)。 |
| timeBetweenEvictionRunsMillis | 5000 | 校驗(yàn)空閑連接的時(shí)間周期(毫秒),不能設(shè)為小于 1 秒,非正表示不驗(yàn)證 |
| minEvictableIdleTimeMillis | 60000 | 空閑連接至少多長(zhǎng)時(shí)間(毫秒)后,才會(huì)被校驗(yàn) |
| removeAbandoned | false | 是否刪除泄露的連接 |
| removeAbandonedTimeout | 60 | 連接泄露的超時(shí)時(shí)間(秒) |
| ?logAbandoned | false | ?連接刪除時(shí)是否打印堆棧信息 |
| ?connectionProperties | ?null |
連接屬性,格式為: [propertyName=property;]* |
1.4、增強(qiáng)參數(shù)
| 參數(shù) | 默認(rèn)值 | 描述 |
| initSQL | null | 連接創(chuàng)建時(shí),執(zhí)行的初始化 SQL |
| jdbcInterceptors | null |
jdbc 攔截器,需要繼承 org.apache.tomcat.jdbc.pool.JdbcInterceptor;已存在的攔截器: |
| validationInterval | 3000 | 連接校驗(yàn)的最短間隔(毫秒) |
| jmxEnabled | true | 是否注冊(cè)連接池到 JMX |
| fairQueue | true | ?是否使用公平隊(duì)列,如果為 true,獲取連接時(shí)將按照 "先進(jìn)先出" 的原則 |
| abandonWhenPercentageFull | ?0 | ?泄露連接達(dá)到?abandonWhenPercentageFull 比例才關(guān)閉這些連接,0 表示有泄露連接立馬關(guān)閉 |
| maxAge | ?0 | 連接最大存活時(shí)間;在從連接池獲取連接和連接返回連接池時(shí)進(jìn)行該項(xiàng)檢測(cè),如果?now - time-when-connected > maxAge,則關(guān)閉該連接;0 表示不進(jìn)行該項(xiàng)檢測(cè)。 |
| useEquals | true? | ?是否使用?String.equals 來判斷?ProxyConnection 是否相等 |
| suspectTimeout | 0 | ?和?removeAbandonedTimeout 類似,但該設(shè)置只是打印日志并不刪除連接;大于 0 才生效。 |
| rollbackOnReturn | false | 連接在返回連接池時(shí)是否自動(dòng)回滾事務(wù)。 |
| commitOnReturn | false | 連接在返回連接池時(shí)是否自動(dòng)提交事務(wù);如果?rollbackOnReturn==true 則忽略該參數(shù)。 |
| alternateUsernameAllowed | false | 從連接池獲取連接時(shí)是否允許設(shè)置新的憑證。默認(rèn)情況下,連接池會(huì)忽略 DataSource.getConnection(username,password) 的調(diào)用,直接返回一個(gè)已創(chuàng)建的連接;如果要使用不同的憑證來獲取連接,即 DataSource.getConnection(username,password) 生效,可把該參數(shù)設(shè)為 true。 |
| dataSource | null | ?設(shè)置數(shù)據(jù)源,連接池將從該數(shù)據(jù)源獲取連接 |
| dataSourceJNDI | null | ?數(shù)據(jù)源的 jndi |
| useDisposableConnectionFacade | true | 是否使用連接外觀;設(shè)置為 true 可以防止連接關(guān)閉后的重復(fù)使用。 |
| logValidationErrors | false | 是否記錄校驗(yàn)的錯(cuò)誤 |
| propagateInterruptState | false | 是否傳播線程中斷狀態(tài) |
| ignoreExceptionOnPreLoad | false | 是否忽略創(chuàng)建連接時(shí)的錯(cuò)誤 |
| useStatementFacade | true | 如果希望使用包裝 statement,以便在設(shè)置了 statement 代理時(shí),在已關(guān)閉的 statement 上調(diào)用 equals() and hashCode() 方法,需將此設(shè)置為 true。 |
詳細(xì)的說明可以參考官網(wǎng)文檔:https://tomcat.apache.org/tomcat-8.5-doc/jdbc-pool.html
2、使用
2.1、直接使用
2.1.1、引入依賴
<dependency>
<groupId>org.apache.tomcat</groupId>
<artifactId>tomcat-jdbc</artifactId>
<version>8.5.72</version>
</dependency>
2.1.2、使用例子
package com.abc.demo.general.dbpool;
import org.apache.tomcat.jdbc.pool.DataSource;
import org.apache.tomcat.jdbc.pool.PoolProperties;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TomcatPoolCase {
public static void main(String[] args) {
PoolProperties poolProperties = new PoolProperties();
poolProperties.setName("Tomcat連接池");
poolProperties.setUrl("jdbc:mysql://10.40.9.11:3306/mydb?useUnicode=true&characterEncoding=UTF-8");
poolProperties.setDriverClassName("com.mysql.cj.jdbc.Driver");
poolProperties.setUsername("root");
poolProperties.setPassword("123456");
poolProperties.setJmxEnabled(true);
poolProperties.setTestWhileIdle(false);
poolProperties.setTestOnBorrow(true);
poolProperties.setValidationQuery("SELECT 1");
poolProperties.setTestOnReturn(false);
poolProperties.setValidationInterval(30000);
poolProperties.setTimeBetweenEvictionRunsMillis(30000);
poolProperties.setMaxActive(100);
poolProperties.setInitialSize(10);
poolProperties.setMaxWait(10000);
poolProperties.setRemoveAbandonedTimeout(60);
poolProperties.setMinEvictableIdleTimeMillis(30000);
poolProperties.setMinIdle(10);
poolProperties.setLogAbandoned(true);
poolProperties.setRemoveAbandoned(true);
poolProperties.setJdbcInterceptors(
"org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;" +
"org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer");
DataSource datasource = new DataSource();
datasource.setPoolProperties(poolProperties);
Connection connection = null;
try {
connection = datasource.getConnection();
Statement st = connection.createStatement();
ResultSet rs = st.executeQuery("select version()");
if (rs.next()) {
System.out.println(rs.getString(1));
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
close(connection);
}
//實(shí)際使用中一般是在應(yīng)用啟動(dòng)時(shí)初始化數(shù)據(jù)源,應(yīng)用從數(shù)據(jù)源中獲取連接;并不會(huì)關(guān)閉數(shù)據(jù)源。
datasource.close();
}
private static void close(Connection connection) {
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
2.2、作為資源配置在 Tomcat 中
先把對(duì)應(yīng)數(shù)據(jù)庫(kù)的驅(qū)動(dòng)包拷貝到 Tomcat 或應(yīng)用的 lib 目錄下,然后在 content.xml 中配置資源,
content.xml 可以在如下位置:
conf/context.xml:針對(duì)所有的應(yīng)用conf/Catalina/localhost:針對(duì)單個(gè)應(yīng)用,適合在Tomcat外部部署應(yīng)用{應(yīng)用}/META-INFcontext.xml:針對(duì)單個(gè)應(yīng)用
配置資源的例子如下:
<Resource name="jdbc/testDb"
auth="Container"
type="javax.sql.DataSource"
factory="org.apache.tomcat.jdbc.pool.DataSourceFactory"
testWhileIdle="true"
testOnBorrow="true"
testOnReturn="false"
validationQuery="SELECT 1"
validationInterval="30000"
timeBetweenEvictionRunsMillis="30000"
maxActive="20"
maxIdle="20"
minIdle="5"
maxWait="10000"
initialSize="5"
removeAbandonedTimeout="60"
removeAbandoned="true"
logAbandoned="true"
minEvictableIdleTimeMillis="30000"
jmxEnabled="true"
jdbcInterceptors="org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;
org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer"
username="root"
password="123456"
driverClassName="com.mysql.cj.jdbc.Driver"
url="jdbc:mysql://10.40.9.11:3306/mydb?useUnicode=true&characterEncoding=UTF-8" />
可以通過 jndi 來查找該資源,這里通過 jsp 來演示查找方法:
<%@ page language="java" contentType="text/html; charset=utf-8" pageEncoding="UTF-8"%>
<%@ page import="javax.naming.Context,
javax.naming.InitialContext,
javax.sql.DataSource,
java.sql.*"%>
<%
Connection connection = null;
try {
InitialContext initialContext = new InitialContext();
Context context = (Context) initialContext.lookup("java:comp/env");
DataSource dataSource = (DataSource)context.lookup("jdbc/testDb");
connection = dataSource.getConnection();
Statement st = connection.createStatement();
ResultSet rs = st.executeQuery("select version()");
if (rs.next()) {
System.out.println(rs.getString(1));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
%>
<html>
<body>
<h3>通過 jndi 查找數(shù)據(jù)源并獲取數(shù)據(jù)庫(kù)的版本信息</h3>
</body>
</html>
3.2、在 SpringBoot 中使用
3.1.1、引入依賴
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.12.RELEASE</version>
<relativePath />
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.apache.tomcat</groupId>
<artifactId>tomcat-jdbc</artifactId>
<version>8.5.72</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
</dependencies>
3.1.2、單數(shù)據(jù)源
application.yml 配置:
spring:
datasource:
tomcat-pool:
name: Tomcat連接池
url: jdbc:mysql://10.40.9.11:3306/mydb?useUnicode=true&characterEncoding=UTF-8
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: 123456
test-while-idle: true
test-on-borrow: true
validation-query: select 1
test-on-return: false
validation-interval: 30000
time-between-eviction-runs-millis: 30000
max-active: 100
initial-size: 10
max-wait: 10000
remove-abandoned-timeout: 60
min-evictable-idle-time-millis: 30000
min-idle: 10
log-abandoned: true
remove-abandoned: true
jdbc-interceptors: org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer
數(shù)據(jù)源配置類:
package com.abc.demo.config;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
@Bean("dataSource")
@ConfigurationProperties(prefix = "spring.datasource.tomcat-pool")
public DataSource dataSource() {
return DataSourceBuilder.create().type(org.apache.tomcat.jdbc.pool.DataSource.class).build();
}
}
使用:
@Autowired private DataSource dataSource;
3.1.3、多數(shù)據(jù)源
application.yml 配置:
spring:
datasource:
tomcat-pool:
db1:
name: Tomcat連接池
url: jdbc:mysql://10.40.9.11:3306/mydb?useUnicode=true&characterEncoding=UTF-8
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: 123456
test-while-idle: true
test-on-borrow: true
validation-query: select 1
test-on-return: false
validation-interval: 30000
time-between-eviction-runs-millis: 30000
max-active: 100
initial-size: 10
max-wait: 10000
remove-abandoned-timeout: 60
min-evictable-idle-time-millis: 30000
min-idle: 10
log-abandoned: true
remove-abandoned: true
jdbc-interceptors: org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer
db2:
name: Tomcat連接池
url: jdbc:mysql://10.110.74.187:3306/egmp?useUnicode=true&characterEncoding=UTF-8
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: InsYR0ot187!
test-while-idle: true
test-on-borrow: true
validation-query: select 1
test-on-return: false
validation-interval: 30000
time-between-eviction-runs-millis: 30000
max-active: 100
initial-size: 10
max-wait: 10000
remove-abandoned-timeout: 60
min-evictable-idle-time-millis: 30000
min-idle: 10
log-abandoned: true
remove-abandoned: true
jdbc-interceptors: org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer
數(shù)據(jù)源配置類:
package com.abc.demo.config;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
@Bean("dataSource1")
@ConfigurationProperties(prefix = "spring.datasource.tomcat-pool.db1")
public DataSource dataSource1() {
return DataSourceBuilder.create().type(org.apache.tomcat.jdbc.pool.DataSource.class).build();
}
@Bean("dataSource2")
@ConfigurationProperties(prefix = "spring.datasource.tomcat-pool.db2")
public DataSource dataSource2() {
return DataSourceBuilder.create().type(org.apache.tomcat.jdbc.pool.DataSource.class).build();
}
}
使用:
@Autowired
@Qualifier("dataSource1")
private DataSource dataSource1;
@Autowired
@Qualifier("dataSource2")
private DataSource dataSource2;
到此這篇關(guān)于 Java 數(shù)據(jù)庫(kù)連接池 Tomcat介紹的文章就介紹到這了,更多相關(guān) Java連接池 Tomcat內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Mybatis實(shí)現(xiàn)SQL存儲(chǔ)流程詳解
MyBatis作為一款優(yōu)秀的持久層框架,它支持自定義SQL、存儲(chǔ)過程以及高級(jí)映射。它免除了幾乎所有的JDBC代碼以及設(shè)置參數(shù)和獲取結(jié)果集的工作2023-03-03
Java 大小寫最快轉(zhuǎn)換方式實(shí)例代碼
這篇文章主要介紹了Java 大小寫最快轉(zhuǎn)換方式實(shí)例代碼的相關(guān)資料,需要的朋友可以參考下2017-07-07
SpringBoot修改子模塊Module的jdk版本的方法 附修改原因
這篇文章主要介紹了SpringBoot修改子模塊Module的jdk版本的方法 附修改原因,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-04-04
基于Java的電梯系統(tǒng)實(shí)現(xiàn)過程
這篇文章主要介紹了基于Java的電梯系統(tǒng)實(shí)現(xiàn)過程,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-10-10
教你如何精準(zhǔn)統(tǒng)計(jì)出你的接口"QPS"
今天小編就為大家分享一篇關(guān)于QPS的精準(zhǔn)計(jì)算方法,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧2021-08-08

