AI专业者开发社区 1 号成员
  •  0 回帖  •  1 浏览  •  4 个月前
   

Java 数据库连接池介绍(4)--Tomcat 连接池介绍

Tomcat 连接池是从 Tomcat 7 开始重新编写的高并发连接池，用以取代以前 Tomcat 中使用的 DBCP 1 连接池，它可以配置在 Tomcat 中使用，也可以单独使用。本文主要介绍 Tomcat 连接池的基本使用，文中使用到的软件版本：Java 1.8.0_191、Tomcat 8.5.72、Spring Boot 2.3.12.RELEASE。

1、配置参数

1.1、基础配置

参数 默认值 描述
factory   必须，需要是 org.apache.tomcat.jdbc.pool.DataSourceFactory
type   应该是 javax.sql.DataSource 或 javax.sql.XADataSource

1.2、系统属性

参数 默认值 描述
org.apache.tomcat.jdbc.pool.onlyAttemptCurrentClassLoader false 是否只使用当前的类加载器 (加载该连接池的类加载器) 来加载动态类

1.3、一般参数

这些参数和 DBCP 一致，但有些默认值不一样。

参数 默认值 描述
defaultAutoCommit 驱动的默认值 是否自动提交
defaultReadOnly 驱动的默认值 是否只读
defaultTransactionIsolation 驱动的默认值

默认的事务隔离级别
NONE、READ_COMMITTED、READ_UNCOMMITTED、
REPEATABLE_READ、SERIALIZABLE
defaultCatalog  

默认的 catalog。( 目录，类似于模式名，但比模式名更加抽象；
Oracle，MySQL 不支持，MS SQL Server = 数据库名 )
driverClassName   驱动名称
url   连接 url
username   用户名
password   密码
maxActive 100 最大活动连接数
maxIdle 100 最大空闲连接数
minIdle 10 最小空闲连接数
initialSize 10 初始连接数
maxWait 3000 从连接池获取连接，最大等待时间 (秒)
testOnBorrow false 从连接池获取连接时，是否验证有效性；如果验证失败，则丢弃该连接。
testOnConnect true 连接创建时，是否验证有效性
testOnReturn false 连接返回连接池时，是否验证有效性
testWhileIdle false 连接空闲时，是否验证有效性
validationQuery null

连接校验的查询 sql
如果指定，该 SQL 不需要返回结果，只要不抛 SQLException；如果没有指定，则通过调用 isValid() 方法进行校验。
validationQueryTimeout -1 校验查询的超时时间 (秒)；非正数表示不启用该特性。
validatorClassName null 校验的类名，需实现 org.apache.tomcat.jdbc.pool.Validator 接口并包含一个无参构造函数。
timeBetweenEvictionRunsMillis 5000 校验空闲连接的时间周期 (毫秒)，不能设为小于 1 秒，非正表示不验证
minEvictableIdleTimeMillis 60000 空闲连接至少多长时间 (毫秒) 后，才会被校验
removeAbandoned false 是否删除泄露的连接
removeAbandonedTimeout 60 连接泄露的超时时间 (秒)
 logAbandoned false  连接删除时是否打印堆栈信息
 connectionProperties  null

连接属性，格式为： [propertyName=property;]*
"user" and "password" 将被除外，所以在此不需要包含这两个属性。

1.4、增强参数

参数 默认值 描述
initSQL null 连接创建时，执行的初始化 SQL
jdbcInterceptors null

jdbc 拦截器，需要继承 org.apache.tomcat.jdbc.pool.JdbcInterceptor；已存在的拦截器：
org.apache.tomcat.jdbc.pool.interceptor.ConnectionState 自动提交、只读、目录和事务隔离级别的跟踪
org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer statement 的跟踪，在连接返回连接池时关闭它们
validationInterval 3000 连接校验的最短间隔 (毫秒)
jmxEnabled true 是否注册连接池到 JMX
fairQueue true  是否使用公平队列，如果为 true，获取连接时将按照 "先进先出" 的原则
abandonWhenPercentageFull  0  泄露连接达到 abandonWhenPercentageFull 比例才关闭这些连接，0 表示有泄露连接立马关闭
maxAge  0 连接最大存活时间；在从连接池获取连接和连接返回连接池时进行该项检测，如果 now - time-when-connected > maxAge，则关闭该连接；0 表示不进行该项检测。
useEquals true   是否使用 String.equals 来判断 ProxyConnection 是否相等
suspectTimeout 0  和 removeAbandonedTimeout 类似，但该设置只是打印日志并不删除连接；大于 0 才生效。
rollbackOnReturn false 连接在返回连接池时是否自动回滚事务。
commitOnReturn false 连接在返回连接池时是否自动提交事务；如果 rollbackOnReturn==true 则忽略该参数。
alternateUsernameAllowed false 从连接池获取连接时是否允许设置新的凭证。默认情况下，连接池会忽略 DataSource.getConnection(username,password) 的调用，直接返回一个已创建的连接；如果要使用不同的凭证来获取连接，即 DataSource.getConnection(username,password) 生效，可把该参数设为 true。
dataSource null  设置数据源，连接池将从该数据源获取连接
dataSourceJNDI null  数据源的 jndi
useDisposableConnectionFacade true 是否使用连接外观；设置为 true 可以防止连接关闭后的重复使用。
logValidationErrors false 是否记录校验的错误
propagateInterruptState false 是否传播线程中断状态
ignoreExceptionOnPreLoad false 是否忽略创建连接时的错误
useStatementFacade true 如果希望使用包装 statement，以便在设置了 statement 代理时，在已关闭的 statement 上调用 equals()and hashCode() 方法，需将此设置为 true。

详细的说明可以参考官网文档：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.49.196.11:3306/mydb?useUnicode=true&amp;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 </span>= <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">;
    </span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)"> {
        connection </span>=<span style="color: rgba(0, 0, 0, 1)"> datasource.getConnection();
        Statement st </span>=<span style="color: rgba(0, 0, 0, 1)"> connection.createStatement();
        ResultSet rs </span>= st.executeQuery("select version()"<span style="color: rgba(0, 0, 0, 1)">);
        </span><span style="color: rgba(0, 0, 255, 1)">if</span><span style="color: rgba(0, 0, 0, 1)"> (rs.next()) {
            System.out.println(rs.getString(</span>1<span style="color: rgba(0, 0, 0, 1)">));
        }
    } </span><span style="color: rgba(0, 0, 255, 1)">catch</span><span style="color: rgba(0, 0, 0, 1)"> (SQLException e) {
        e.printStackTrace();
    } </span><span style="color: rgba(0, 0, 255, 1)">finally</span><span style="color: rgba(0, 0, 0, 1)"> {
        close(connection);
    }

    </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">实际使用中一般是在应用启动时初始化数据源，应用从数据源中获取连接；并不会关闭数据源。</span>



        datasource.close();
}


</span><span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span> <span style="color: rgba(0, 0, 255, 1)">void</span><span style="color: rgba(0, 0, 0, 1)"> close(Connection connection) {
    </span><span style="color: rgba(0, 0, 255, 1)">if</span> (connection != <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">) {
        </span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)"> {
            connection.close();
        } </span><span style="color: rgba(0, 0, 255, 1)">catch</span><span style="color: rgba(0, 0, 0, 1)"> (SQLException e) {
            e.printStackTrace();
        }
    }
}



}

2.2、作为资源配置在 Tomcat 中

先把对应数据库的驱动包拷贝到 Tomcat 或应用的 lib 目录下，然后在 content.xml 中配置资源，content.xml 可以在如下位置：

conf/context.xml：针对所有的应用
conf/Catalina/localhost：针对单个应用，适合在 Tomcat 外部部署应用
{应用}/META-INFcontext.xml：针对单个应用

配置资源的例子如下：

<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.49.196.11:3306/mydb?useUnicode=true&amp;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 查找数据源并获取数据库的版本信息 </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>


<span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">dependency</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
    <span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">groupId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>org.springframework<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">groupId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
    <span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">artifactId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>spring-jdbc<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">artifactId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">dependency</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>

<span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">dependency</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
    <span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">groupId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>org.apache.tomcat<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">groupId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
    <span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">artifactId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>tomcat-jdbc<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">artifactId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
    <span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">version</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>8.5.72<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">version</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">dependency</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>

<span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">dependency</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
    <span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">groupId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>mysql<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">groupId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
    <span style="color: rgba(0, 0, 255, 1)">&lt;</span><span style="color: rgba(128, 0, 0, 1)">artifactId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>mysql-connector-java<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">artifactId</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>
<span style="color: rgba(0, 0, 255, 1)">&lt;/</span><span style="color: rgba(128, 0, 0, 1)">dependency</span><span style="color: rgba(0, 0, 255, 1)">&gt;</span>



</dependencies>

3.1.2、单数据源

application.yml 配置：

spring:
  datasource:
    tomcat-pool:
      name: Tomcat 连接池
      url: jdbc:mysql://10.49.196.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

数据源配置类：

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、多数据源

application.yml 配置：

spring:
  datasource:
    tomcat-pool:
      db1:
        name: Tomcat 连接池
        url: jdbc:mysql://10.49.196.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

数据源配置类：

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(</span>"dataSource1"<span style="color: rgba(0, 0, 0, 1)">)
@ConfigurationProperties(prefix </span>= "spring.datasource.tomcat-pool.db1"<span style="color: rgba(0, 0, 0, 1)">)
</span><span style="color: rgba(0, 0, 255, 1)">public</span><span style="color: rgba(0, 0, 0, 1)"> DataSource dataSource1() {
    </span><span style="color: rgba(0, 0, 255, 1)">return</span> DataSourceBuilder.create().type(org.apache.tomcat.jdbc.pool.DataSource.<span style="color: rgba(0, 0, 255, 1)">class</span><span style="color: rgba(0, 0, 0, 1)">).build();
}

@Bean(</span>"dataSource2"<span style="color: rgba(0, 0, 0, 1)">)
@ConfigurationProperties(prefix </span>= "spring.datasource.tomcat-pool.db2"<span style="color: rgba(0, 0, 0, 1)">)
</span><span style="color: rgba(0, 0, 255, 1)">public</span><span style="color: rgba(0, 0, 0, 1)"> DataSource dataSource2() {
    </span><span style="color: rgba(0, 0, 255, 1)">return</span> DataSourceBuilder.create().type(org.apache.tomcat.jdbc.pool.DataSource.<span style="color: rgba(0, 0, 255, 1)">class</span><span style="color: rgba(0, 0, 0, 1)">).build();
}



}

使用：

@Autowired
@Qualifier("dataSource1")
private DataSource dataSource1;

@Autowired
@Qualifier("dataSource2")
private DataSource dataSource2;