详解JDBC连接池

用Java代码操作数据库，需要数据库连接对象，一个用户至少要用到一个连接。现在假设有成千上百万个用户，就要创建十分巨大数量的连接对象，这会使数据库承受极大的压力，为了解决这种现象，一种技术出现了，这就是JDBC连接池。

一、JDBC连接池原理

传统方式创建和销毁与数据库的连接都需要消耗系统资源和时间，为了复用连接，代替传统的频繁占用系统资源和耗费时间的方式，便于管理连接，可以规定最大的连接数（控制应用服务器对数据库的并发访问），JDBC连接池就是用来解决这些问题的。

在要使用连接对象之前先创建好规定数量（根据服务器的负载能力制定）的连接对象存放到连接池（实现池子的方式一般是用链表结构的集合来实现）中。

当应用服务器需要连接对象的时候就从连接池中获取，用完该连接对象时归还连接对象到连接池中。当应用服务器需要连接对象而当前连接池中没有连接对象可取时，就让其先等待，如果等待超时还没有获取到连接对象，就新建一个连接对象给服务器让其使用，用完后销毁该创建的对象。

二、JDBC连接池的简单实现

import java.io.IOException;

import java.io.InputStream;

import java.lang.reflect.InvocationHandler;

import java.lang.reflect.Method;

import java.lang.reflect.Proxy;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.util.LinkedList;

import java.util.Properties;

public class MyPool {

private int initCount = 3; // 初始连接数

private int maxCount = 6; // 最大连接数

private int currentCount = 0; // 当前连接数

// 用于保存连接的链表集合

private LinkedList<Connection> pools = new LinkedList<Connection>();

// 参数

private static String driverClass;

private static String url;

private static String user;

private static String password;



// 初始化参数

static {

InputStream input = MyPool.class.getResourceAsStream("/jdbcConf.properties");

Properties prop = new Properties();

try {

prop.load(input);

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

input.close();

} catch (IOException e) {

e.printStackTrace();

}

}

url = prop.getProperty("url");

user = prop.getProperty("user");

password = prop.getProperty("password");

driverClass = prop.getProperty("driverClass");

try {

Class.forName(driverClass);

} catch (ClassNotFoundException e) {

e.printStackTrace();

}

}



public MyPool() {

// 初始化连接

for(int i = 0; i < initCount; i++) {

pools.addFirst(createConn());

}

}



// 创建连接

private Connection createConn() {

Connection proxyConn = null;

try {

Connection conn = DriverManager.getConnection(url, user, password);

// 对conn进行动态代理

proxyConn = (Connection) Proxy.newProxyInstance(

conn.getClass().getClassLoader(),

conn.getClass().getInterfaces(),

new InvocationHandler() {

@Override

public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

// 如果当前连接数小于初始连接数，则关闭连接时将连接放回连接池

String methodName = method.getName();

if ("close".equals(methodName)) {

if (pools.size() < initCount) {

pools.addLast(conn);

return null;

}

currentCount--;

}

return method.invoke(conn, args);

}

}

);

currentCount++;

} catch (SQLException e) {

e.printStackTrace();

}

return proxyConn;

}



// 获取连接

public Connection getConn() {

// 如果连接池中还有连接，那就直接获取

if(pools.size() > 0) {

return pools.removeFirst();

}



// 如果连接池中没有连接，就判断是否达到最大连接数，如果没有就新建连接

if(currentCount < maxCount) {

return createConn();

}



// 达到最大连接数，就抛出异常

throw new RuntimeException("达到最大连接数了！！！");

}

}

三、开源的JDBC连接池技术

Sun公司约定：如果是连接池技术，需要实现一个接口javax.sql.DataSource

DBCP和C3P0是两个开源的连接池技术。下面我们做一下简单的介绍：

1、DBCP

DBCP是Apache软件基金组织下的开源连接池实现，Tomcat的连接池正是采用DBCP来实现的。

DBCP既可以与应用服务器整合使用，也可由应用程序独立使用。

2、c3p0概述

Spring框架默认支持C3P0连接池技术。

C3P0连接池的核心类：ComboPooledDataSource

JDBC连接池的出现归根结底还是为了解决应用服务器对数据库的并发访问和代替传统的频繁占用系统资源和耗费时间的方式。这门技术涉及到的东西远比本文写出来的要复杂的多，想要彻底弄明白其中的弯弯绕绕，建议观看本站的JDBC教程，打好基础，慢慢掌握JDBC的各种知识。