当前位置: 主页 > 数据库

java数据库连接池-java线程池异常处理

发布时间:2023-02-14 11:11   浏览次数:次   作者:佚名

JAVA的JDBC数据库连接池总结,数据库连接池满了怎么办

JDBC 数据库连接池

一、JDBC数据库连接池的必要性

1、在使用和开发基于数据库的web程序时,传统模式基本上遵循以下步骤:

(1)在主程序(如servlet、beans)中建立数据库连接
(2)进行sql操作
(3)断开数据库连接

2.本模型开发中存在的问题:

(1)普通的JDBC数据库连接使用 DriverManager 来获取,每次向数据库建立连接的时候都要将 Connection加载到内存中,再验证用户名和密码(得花费0.05s~1s的时间)。需要数据库连接的时候,就向数据库要求一个,执行完成后再断开连接。这样的方式将会消耗大量的资源和时间。数据库的连接资源并没有得到很好的重复利用。若同时有几百人甚至几千人在线,频繁的进行数据库连接操作将占用很多的系统资源,严重的甚至会造成服务器的崩溃。
(2)对于每一次数据库连接,使用完后都得断开。否则,如果程序出现异常而未能关闭,将会导致数据库系统中的内存泄漏,最终将导致重启数据库。(回忆:何为Java的内存泄漏?)
(3)这种开发不能控制被创建的连接对象数,系统资源会被毫无顾及的分配出去,如连接过多,也可能导致内存泄漏,服务器崩溃。LIK1

2、数据库连接池技术

为了解决传统开发中的数据库连接问题,可以使用数据库连接池技术。

1、数据库连接池的基本思想:

就是为数据库连接建立一个“缓冲池”。 预先在缓冲池中放入一定数量的连接。 当需要建立数据库连接时,只需从“缓冲池”中取出一个,用完再放回去即可。

数据库连接池负责分配、管理和释放数据库连接java数据库连接池java数据库连接池,它允许应用程序重用现有的数据库连接,而不是重新建立连接。

数据库连接池初始化时,会创建一定数量的数据库连接,放入连接池中。 这些数据库连接数由最小数据库连接数设置。 不管这些数据库连接是否被使用,连接池总是会保证至少有这么多连接。 连接池中的最大数据库连接数限制了连接池可以占用的最大连接数。 当应用程序从连接池中请求的连接数超过最大连接数时,这些请求将被加入到等待队列中。

在这里插入图片描述

2、数据库连接池的工作原理:

在这里插入图片描述

3、数据库连接池技术的优点:

(1) 资源再利用

由于数据库连接可以复用,避免了频繁创建和释放连接带来的大量性能开销。 在降低系统消耗的基础上,另一方面也增加了系统运行环境的稳定性。

(2) 更快的系统响应速度

在数据库连接池的初始化过程中,往往会创建若干个数据库连接,放在连接池中备用。 至此,连接的初始化已经完成。对于业务请求处理,直接使用已有的可用连接,避免数据库连接初始化和释放过程的时间开销,从而减少系统响应时间

(3) 新的资源配置方式

java线程池异常处理_c 内存池开源库_java数据库连接池

对于多个应用共享同一个数据库的系统,可以在应用层通过配置数据库连接池来限制一个应用的最大可用数据库连接数,防止一个应用独占所有的数据库资源。

(4)统一连接管理,避免数据库连接泄露

在一个比较完善的数据库连接池的实现中,可以根据预先占用的超时设置强制回收被占用的连接,从而避免了传统数据库连接操作中可能出现的资源泄漏。 LIK2

3.多种开源数据库连接池

1、JDBC的数据库连接池用javax.sql.DataSource表示。 DataSource只是一个接口,通常由服务器(Weblogic、WebSphere、Tomcat)实现,一些开源组织也提供了实现:

(1)DBCP 是Apache提供的数据库连接池。tomcat服务器自带dbcp数据库连接池。速度相对c3p0较快,但因自身存在BUG,Hibernate3已不再提供支持。

(2)C3P0 是一个开源组织提供的一个数据库连接池,速度相对较慢,稳定性还可以,hibernate官方推荐使用。

(3)Proxool 是sourceforge下的一个开源项目数据库连接池,有监控连接池状态的功能,稳定性较c3p0差一点.

(4)BoneCP 是一个开源组织提供的数据库连接池,速度快。

(5)Druid 是阿里提供的数据库连接池,据说是集DBCP 、C3P0 、Proxool优点于一身的数据库连接池,但是速度不确定是否有BoneCP快。

2、DataSource 通常称为数据源,它包括连接池和连接池管理两部分。 习惯上称DataSource为连接池

3、使用DataSource代替DriverManager获取Connection,获取速度快,同时可以大大提高数据库访问速度。

注意:

(1)数据源和数据库连接不同,数据源无需创建多个,它是产生数据库连接的工厂,因此整个应用只需要一个数据源即可。
(2)当数据库访问结束后,程序还是像以前一样关闭数据库连接:conn.close();
但conn.close()并没有关闭数据库的物理连接,它仅仅把数据库连接释放,归还给了数据库连接池。LIK3

3.1 C3P0数据库连接池

(1)方式一获取连接:

//使用C3P0数据库连接池的方式,获取数据库的连接:不推荐
public static Connection getConnection1() throws Exception{
	ComboPooledDataSource cpds = new ComboPooledDataSource();
	cpds.setDriverClass("com.mysql.jdbc.Driver"); 
	cpds.setJdbcUrl("jdbc:mysql://localhost:3306/test");
	cpds.setUser("root");
	cpds.setPassword("abc123");
		

java数据库连接池_c 内存池开源库_java线程池异常处理

// cpds.setMaxPoolSize(100); Connection conn = cpds.getConnection(); return conn; }

(2)第二种方式获取连接:

//使用C3P0数据库连接池的配置文件方式,获取数据库的连接:推荐
private static DataSource cpds = new ComboPooledDataSource("helloc3p0");
public static Connection getConnection2() throws SQLException{
	Connection conn = cpds.getConnection();
	return conn;
}

其中src下的配置文件为:(c3p0-config.xml)

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
	<named-config name="helloc3p0">
		<!-- 获取连接的4个基本信息 -->
		<property name="user">root</property>
		<property name="password">abc123</property>
		<property name="jdbcUrl">jdbc:mysql:///test
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		
		<!-- 涉及到数据库连接池的管理的相关属性的设置 -->
		<!-- 若数据库中连接数不足时, 一次向数据库服务器申请多少个连接 -->
		<property name="acquireIncrement">5</property>
		<!-- 初始化数据库连接池时连接的数量 -->
		<property name="initialPoolSize">5</property>
		<!-- 数据库连接池中的最小的数据库连接数 -->
		<property name="minPoolSize">5</property>
		<!-- 数据库连接池中的最大的数据库连接数 -->
		<property name="maxPoolSize">10</property>

java线程池异常处理_c 内存池开源库_java数据库连接池

<!-- C3P0 数据库连接池可以维护的 Statement 的个数 --> <property name="maxStatements">20</property> <!-- 每个连接同时可以使用的 Statement 对象的个数 --> <property name="maxStatementsPerConnection">5</property> </named-config> </c3p0-config>
LIK4

3.2 DBCP数据库连接池

1、DBCP是Apache软件基金会下的开源连接池实现。 连接池依赖于组织下的另一个开源系统:Common-pool。 要使用此连接池实现,应将以下两个 jar 文件添加到系统中:

Commons-dbcp.jar:连接池的实现
Commons-pool.jar:连接池实现的依赖库

2、Tomcat的连接池就是使用这个连接池实现的。 数据库连接池可以与应用服务器集成,也可以独立于应用程序使用。

3、数据源与数据库连接不同。 无需创建多个数据源。 它是一个产生数据库连接的工厂,所以整个应用只需要一个数据源。

4、当数据库访问结束后,程序仍然像之前一样关闭数据库连接:conn.close(); 但是上面的代码并没有关闭与数据库的物理连接,只是释放了数据库连接,并返回到数据库连接池中。

配置属性说明:

在这里插入图片描述

(1)获取连接方式一:

public static Connection getConnection3() throws Exception {
	BasicDataSource source = new BasicDataSource();
		
	source.setDriverClassName("com.mysql.jdbc.Driver");
	source.setUrl("jdbc:mysql:///test");
	source.setUsername("root");
	source.setPassword("abc123");
		
	//
	source.setInitialSize(10);
		

java数据库连接池_java线程池异常处理_c 内存池开源库

Connection conn = source.getConnection(); return conn; }

(2)获取连接方式二:

//使用dbcp数据库连接池的配置文件方式,获取数据库的连接:推荐
private static DataSource source = null;
static{
	try {
		Properties pros = new Properties();
		
		InputStream is = DBCPTest.class.getClassLoader().getResourceAsStream("dbcp.properties");
			
		pros.load(is);
		//根据提供的BasicDataSourceFactory创建对应的DataSource对象
		source = BasicDataSourceFactory.createDataSource(pros);
	} catch (Exception e) {
		e.printStackTrace();
	}
		
}
public static Connection getConnection4() throws Exception {
		
	Connection conn = source.getConnection();
	
	return conn;
}

其中,src下的配置文件为:(dbcp.properties)

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true&useServerPrepStmts=false
username=root
password=abc123

c 内存池开源库_java线程池异常处理_java数据库连接池

initialSize=10 #...
LIK5

3.3 德鲁伊(Druid)数据库连接池

Druid是阿里巴巴开源平台上一个数据库连接池的实现。 它结合了C3P0、DBCP、Proxool等DB pool的优点,同时增加了日志监控,可以很好的监控DB pool连接和SQL的执行情况。 可以说用于监控的DB连接池可以说是目前最好的连接池之一。

import java.sql.Connection;
import java.util.Properties;
import javax.sql.DataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
public class TestDruid {
	public static void main(String[] args) throws Exception {
		Properties pro = new Properties();		 pro.load(TestDruid.class.getClassLoader().getResourceAsStream("druid.properties"));
		DataSource ds = DruidDataSourceFactory.createDataSource(pro);
		Connection conn = ds.getConnection();
		System.out.println(conn);
	}
}

其中src下的配置文件为:(druid.properties)

url=jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true
username=root
password=123456
driverClassName=com.mysql.jdbc.Driver
initialSize=10
maxActive=20
maxWait=1000
filters=wall

详细参数配置:

在这里插入图片描述

在这里插入图片描述

相关文章