首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Java Web ConnectionPool (连接池技术)

Java Web ConnectionPool (连接池技术)

作者头像
Hongten
发布2018-09-13 17:29:49
1K0
发布2018-09-13 17:29:49
举报
文章被收录于专栏:HongtenHongten

根目录下:

dbpool.properties

代码:

driverClassName=oracle.jdbc.driver.OracleDriver
username=scott
password=tiger
url=jdbc:oracle:thin:@192.168.1.20:1521:ora9
poolSize=10

ConnectionPool.java

代码:

package webbook.util;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import java.util.Vector;

public class ConnectionPool {

	private Vector<Connection> pool;

	private String url;

	private String username;

	private String password;

	private String driverClassName;

	/**
	 * 连接池的大小,也就是连接池中有多少个数据库连接。
	 */
	private int poolSize = 1;

	private static ConnectionPool instance = null;

	/**
	 * 私有的构造方法,禁止外部创建本类的对象,要想获得本类的对象,通过<code>getIstance</code>方法。
	 * 使用了设计模式中的单子模式。
	 */
	private ConnectionPool() {
		init();
	}

	/**
	 * 连接池初始化方法,读取属性文件的内容 建立连接池中的初始连接
	 */
	private void init() {
		pool = new Vector<Connection>(poolSize);
		readConfig();
		addConnection();
	}

	/**
	 * 返回连接到连接池中
	 */
	public synchronized void release(Connection conn) {
		pool.add(conn);

	}

	/**
	 * 关闭连接池中的所有数据库连接
	 */
	public synchronized void closePool() {
		for (int i = 0; i < pool.size(); i++) {
			try {
				((Connection) pool.get(i)).close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pool.remove(i);
		}
	}

	/**
	 * 返回当前连接池的一个对象
	 */
	public static ConnectionPool getInstance() {
		if (instance == null) {
			instance = new ConnectionPool();
		}
		return instance;
	}

	/**
	 * 返回连接池中的一个数据库连接
	 */
	public synchronized Connection getConnection() { 
		if (pool.size() > 0) {
			Connection conn = pool.get(0);
			pool.remove(conn);
			return conn;
		} else {
			return null;
		}
	}

	/**
	 * 在连接池中创建初始设置的的数据库连接
	 */
	private void addConnection() {
		Connection conn = null;
		for (int i = 0; i < poolSize; i++) {

			try {
				Class.forName(driverClassName);
				conn = java.sql.DriverManager.getConnection(url, username, password);
				pool.add(conn);

			} catch (ClassNotFoundException e) {
				e.printStackTrace();
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}
	}

	/**
	 * 读取设置连接池的属性文件
	 */
	private void readConfig() {
		try {
			String path = System.getProperty("user.dir") + "\\dbpool.properties";
			FileInputStream is = new FileInputStream(path);
			Properties props = new Properties();
			props.load(is);
			this.driverClassName = props.getProperty("driverClassName");
			this.username = props.getProperty("username");
			this.password = props.getProperty("password");
			this.url = props.getProperty("url");
			this.poolSize = Integer.parseInt(props.getProperty("poolSize"));
		} catch (Exception e) {
			e.printStackTrace();
			System.err.println("读取属性文件出错. ");		
		}
	}
}

ConnectionPoolTest.java

代码:

package webbook.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class ConnectionPoolTest {

	public static void main(String[] args) throws Exception {
		String sql = "select id,name,phone from guestbook";
		long start = System.currentTimeMillis();
		ConnectionPool pool = null;

		for (int i = 0; i < 100; i++) {
			pool = ConnectionPool.getInstance();
			Connection conn = pool.getConnection();
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
			}
			rs.close();
			stmt.close();
			pool.release(conn);
		}
		pool.closePool();
		System.out.println("经过100次的循环调用,使用连接池花费的时间:" + (System.currentTimeMillis() - start) + "ms\n");

		String hostName = "192.168.1.20";
		String driverClass = "oracle.jdbc.driver.OracleDriver";
		String url = "jdbc:oracle:thin:@" + hostName + ":1521:ora9";
		String user = "scott";
		String password = "tiger";
		start = System.currentTimeMillis();
		
		for (int i = 0; i < 100; i++) {
			Class.forName(driverClass);
			Connection conn = DriverManager.getConnection(url, user, password);
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
			}
			rs.close();
			stmt.close();
			conn.close();
		}
		System.out.println("经过100次的循环调用,不使用连接池花费的时间:" + (System.currentTimeMillis() - start) + "ms");
	}
}
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2011-07-22 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档