浅谈在Spring中如何使用数据源(DBCP、C3P0、JNDI)

2023-09-06 09:53:06 58

在Spring中，有以下三种方式来创建数据源：

通过JNDI获取应用服务器中的数据源；
在Spring容器中配置数据源；
通过代码来创建数据源，这种方式适用于无容器依赖的单元测试。

1配置数据源

Spring在第三方依赖包中包含了2种数据源的实现包一个是Apache的DBCP；另一个是C3P0。我们可以在Spring配置文件中直接配置这些数据源。

1.1DBCP

DBCP（DatabaseConnectionPool）是一个依赖Jakartacommons-pool对象池机制的数据库连接池，所以在类路径下还必须包括commons-pool.jar。下面是使用DBCP配置MySql数据源的配置片段：

BasicDataSource提供了close()方法用于关闭数据源，所以必须设定destroy-method=”close”，以便Spring容器关闭时，能够正常关闭数据源。

除以上必须的数据源属性外，还有一些常用的属性。

事务属性：

属性默认值说明 defaultAutoCommit true 连接默认为auto-commit状态。 defaultReadOnly 驱动默认值连接默认的read-only状态。如果没有设置则setReadOnly方法将不会被调用。(某些驱动不支持只读模式,比如：Informix) defaultTransactionIsolation 驱动默认值连接默认的TransactionIsolation状态。有这些值：NONE、READ_COMMITTED、READ_UNCOMMITTED、REPEATABLE_READ、SERIALIZABLE。

连接数相关属性：

属性默认值说明 initialSize 0 初始化连接数：连接池启动时创建的初始化连接数量。 maxActive 8 最大活动连接:连接池在同一时间内能够分配的最大活动连接的数量。如果设置为非正数，则表示不限制。 maxIdle 8 最大空闲连接:连接池中容许保持空闲状态的最大连接数量,超过的空闲连接将被释放,如果设置为负数，则表示不限制。 minIdle 0 最小空闲连接:连接池中容许保持空闲状态的最小连接数量,低于这个数量将创建新的连接,如果设置为0，则表示不创建。 maxWait 无限最大等待时间:当没有可用连接时,连接池等待连接被归还的最大时间(单位为毫秒),超出时间将抛出异常,如果设置为-1，则表示无限等待。

连接监测与维护相关属性：

属性默认值说明 validationQuery 无配置SQL查询语句,用于验证从连接池取出的连接是否可用。如果指定,则查询必须是一个SQLSELECT，并且必须返回至少一行记录。MySQL中是“select1”；在Oracle中是"select1fromdual"。 testOnBorrow true 指明是否从连接池中取出连接之前进行检测,如果检测失败,则从池中去除连接并尝试取出另一个新的连接。注意:设置为true后如果要生效，则validationQuery参数必须正确被设置。 testOnReturn false 指明是否在归还到池中前进行检测。注意:与testOnBorrow一样，设置为true后如果要生效，则validationQuery参数必须正确被设置。 testWhileIdle false 指明连接是否会被空闲连接回收器(如果有)所检测。如果检测失败,则连接将从池中被移除。注意:设置为true后如果要生效，则validationQuery参数必须正确被设置。 timeBetweenEvictionRunsMillis -1 空闲连接回收器线程运行的周期,以毫秒为单位。如果设置为非正数,则不运行空闲连接回收器线程。注意:启用该参数时，则validationQuery参数必须正确被设置。 numTestsPerEvictionRun 3 在每次空闲连接回收器线程(如果有)运行时需要检测的连接数量。 minEvictableIdleTimeMillis 1000*60*30 连接在池中保持空闲而不被空闲连接回收器线程回收的最小时间值，以毫秒为单位。

缓存相关属性：

属性默认值说明 poolPreparedStatements false 开启连接池的preparedstatement功能设置为true后，所有的CallableStatement和PreparedStatement都会被缓存起来。 maxOpenPreparedStatements 不限制能够同时分配打开的statements的最大数量。0表示不限制。

连接泄露回收相关属性：

属性默认值说明 removeAbandoned false 是否删除泄露的连接。如果设置为true,那么那些可能存在泄露的连接会被删除。假设maxActive为10个，活动连接为8个，空闲连接为1个，10-8-1=1，那么就会把删除这个连接（会先检测该活动连接未被使用的时间是否超过removeAbandonedTimeout）。如果需要一个长连接操作，那么removeAbandoned需要设置的长一些，否则正常使用的连接可能会被误删除。 removeAbandonedTimeout 300 泄露的连接可以被删除的时间段，单位为秒。 logAbandoned false 当Statement或连接被泄露时是否打印堆栈日志。

假设数据库用的是MySQL，那么如果数据源配置不当，将可能会发生经典的“8小时问题”。原因是MySQL在默认情况下如果发现一个连接的空闲时间超过8小时，那么会在数据库端自动关闭这个连接。而数据源并不知道这个连接已经被关闭了，所以当它将这个无用的连接返回给某个DAO时，DAO就会抛出无法获取connection的异常。

DBCP的testOnBorrow默认设置为true，所以从连接池中取出连接之前会先进行检测，因为不会发生“8小时问题”。但如果每次取连接时都进行检测，那么在高并发应用下就会产生性能问题。

因此建议在高并发下，将testOnBorrow设置为false；然后将testWhileIdle设置为true，打开空闲连接回收器；最后把timeBetweenEvictionRunsMillis的值设定为小于8小时，这样那些被MySQL所关闭的空闲连接，就会被清除出去。这样不仅解决了“8小时问题”，而且还保证了高性能O(∩_∩)O哈哈~

注意：因为MySQL本身的interactive-timeout（单位为s）参数，可以设定空闲连接的过期时间，所以我们要想获取到这个参数值，然后再设定DBCP的timeBetweenEvictionRunsMillis属性值。

1.2C3P0

C3P0是一个开放源代码的JDBC数据源实现项目，它实现了JDBC3和JDBC2扩展规范说明的Connection和Statement池。

下面是使用C3P0配置MySql数据源的配置片段：

C3P0也提供了一个用于关闭数据源的close()方法，这样我们就可以保证Spring容器被关闭时，能够成功关闭数据源。

属性默认值

acquireIncrement

acquireRetryAttempts 30

acquireRetryDelay 1000

autoCommitOnClose false

automaticTestTable null

breakAfterAcquireFailure false

checkoutTimeout 0

connectionTesterClassName com.mchange.v2.C3P0.impl.DefaultConnectionTester

idleConnectionTestPeriod 0

initialPoolSize 3

maxIdleTime 0

maxPoolSize 15

maxStatements 0

maxStatementsPerConnection 0

numHelperThreads 3

preferredTestQuery null

propertyCycle 300

testConnectionOnCheckout false

testConnectionOnCheckin false

说明
当连接池中无空闲连接时，一次性创建新连接的数量。
在从数据库获取新连接失败后，重复尝试的次数。
尝试获取连接之间的间隔时间，单位为毫秒。
连接关闭时，将所有未提交的操作回滚。
会创建一张名为Test的空表，并使用其自带的查询语句进行测试。如果定义了这个参数，那么preferredTestQuery属性将被忽略。我们不能在这张Test表上进行任何操作，它仅为C3P0测试所用。
获取连接失败时，将会引起所有等待获取连接的线程抛出异常。但是数据源仍有效保留，并在下次调用getConnection()时继续尝试获取连接。在尝试获取连接失败后，该数据源将申明已断开并永久关闭。
当连接池中的连接用完时，客户端调用getConnection()后等待获取新连接的时间，单位：毫秒。超时后将抛出SQLException。设为0表示无限期等待。
通过实现ConnectionTester或QueryConnectionTester的类来测试连接，类名需设置为全限定名。
隔多少秒，检查连接池中的所有空闲连接。0表示不检查。
初始化时创建的连接数，应在minPoolSize与maxPoolSize之间取值。
最大空闲时间，超过空闲时间的连接将会被丢弃。为0或负数则表示永不丢弃。
连接池中保留的最大连接数。
JDBC标准参数，用以控制数据源内加载的PreparedStatement数量。但由于预缓存的Statement属于单个Connection而不是整个连接池。所以设置这个参数需要多方面的考虑，如果maxStatements与maxStatementsPerConnection均为0，则缓存被关闭。
连接池内单个连接所拥有的最大缓存Statement数。
C3P0是异步操作的，缓慢的JDBC操作通过HelperThreads完成。通过多线程实现多个操作同时被执行，这样可以有效地提升性能。
定义所有连接测试都执行的测试语句。在使用连接测试的情况下，这个参数能够显著地提高测试速度。测试的表必须在初始数据源时就存在。
修改系统配置参数生效时长，单位为s。
因性能消耗大，所以请只在需要时开启。如果设为true那么在每个connection提交的时候都将校验其有效性。建议使用idleConnectionTestPeriod或automaticTestTable等方法来提升连接测试的性能。
如果设为true，那么在取得连接的同时将校验其连接的有效性。

2JNDI数据源

如果应用配置在高性能的应用服务器（如WebLogic或Websphere等）上，我们可能更希望使用应用服务器所提供的数据源。应用服务器的数据源使用JNDI方式来供调用者使用，Spring为此专门提供了引用JNDI资源的JndiObjectFactoryBean类。下面是一个简单的配置：

Spring2.0+为获取J2EE资源提供了一个jee命名空间，通过jee命名空间，可以有效地简化J2EE资源的引用：

3Spring数据源实现类

Spring本身也提供了一个简单的数据源实现类DriverManagerDataSource，它位于org.springframework.jdbc.datasource包中。这个类实现了javax.sql.DataSource接口，但它并没有提供池化连接机制，每次调用getConnection()方法获取新连接时，只是简单地创建一个新的连接。它不需要额外的依赖类，所以，这个数据源类比较适合在单元测试中使用。

Spring数据源实现类既可以通过配置直接使用，也可以在代码中实例化调用：

DriverManagerDataSourcedataSource=newDriverManagerDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/spring4");
dataSource.setUsername("root");
dataSource.setPassword("");

try{
Connectionconnection=dataSource.getConnection();
if(connection.isClosed()){
System.out.println("连接已关闭");
}else{
System.out.println("连接已开启");
}
}catch(SQLExceptione){
e.printStackTrace();
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

浅谈在Spring中如何使用数据源(DBCP、C3P0、JNDI)

热门推荐

随机推荐