Java數(shù)據(jù)庫(kù)連接池Tomcat怎么使用

這篇文章主要介紹“Java數(shù)據(jù)庫(kù)連接池Tomcat怎么使用”，在日常操作中，相信很多人在Java數(shù)據(jù)庫(kù)連接池Tomcat怎么使用問(wèn)題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”Java數(shù)據(jù)庫(kù)連接池Tomcat怎么使用”的疑惑有所幫助！接下來(lái)，請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧！

前言：

Tomcat 連接池是從 Tomcat 7 開(kāi)始重新編寫的高并發(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ǔ)配置

1.2、系統(tǒng)屬性

1.3、一般參數(shù)

這些參數(shù)和 DBCP 一致，但有些默認(rèn)值不一樣。

1.4、增強(qiáng)參數(shù)

詳細(xì)的說(shuō)明可以參考官網(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&amp;characterEncoding=UTF-8" />

可以通過(guò) jndi 來(lái)查找該資源，這里通過(guò) jsp 來(lái)演示查找方法：

<%@ 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>

        <h4>通過(guò) jndi 查找數(shù)據(jù)源并獲取數(shù)據(jù)庫(kù)的版本信息</h4>

    </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怎么使用”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！