`

几种Java数据库连接池实现(一)

 
阅读更多
几种Java数据库连接池实现(一)
(一)
package shop;

import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;

/*
java数据库连接池实现(转载)

作用:
在数据库存取中,数据库连接池是不可缺少的,它可以提高连接利用率
减少连接等待,对于提高数据存储性能会有不小的作用.
原理:
连接池相当于连接的集合,在连接池初始化时先实例化一定数量的空闲连接
等待用户使用,用户使用完连接再将其返回连接池,这样就免去了最耗时的
创建连接的开销在没有空闲连接的情况下,连接池将自动生成连接再分配给
用户请求.
实例:
*/
/*
* 我的数据库连接池
*
* **********模块说明**************
*
* getInstance()返回POOL唯一实例,第一次调用时将执行构造函数
* 构造函数Pool()调用驱动装载loadDrivers()函数;连接池创建createPool()函数 loadDrivers()装载驱动
* createPool()建连接池 getConnection()返回一个连接实例 getConnection(long time)添加时间限制
* freeConnection(Connection con)将con连接实例返回到连接池 getnum()返回空闲连接数
* getnumActive()返回当前使用的连接数
*
*/
public class Pool {
    private static Pool instance = null; // 定义唯一实例

    private int maxConnect = 100;// 最大连接数

    private int normalConnect = 10;// 保持连接数

    private String password = "";// 密码

    private String url = "jdbc:mysql://localhost/shop";// 连接URL

    private String user = "root";// 用户名

    private String driverName = "com.mysql.jdbc.Driver";// 驱动类

    Driver driver = null;// 驱动变量

    DBConnectionPool pool = null;// 连接池实例变量

    // 将构造函数私有,不允许外界访问
    private Pool() {
        loadDrivers(driverName);
        createPool();
    }

    // 装载和注册所有JDBC驱动程序
    private void loadDrivers(String dri) {
        String driverClassName = dri;
        try {
            driver = (Driver) Class.forName(driverClassName).newInstance();
            DriverManager.registerDriver(driver);
            System.out.println("成功注册JDBC驱动程序" + driverClassName);
        } catch (Exception e) {
            System.out.println("无法注册JDBC驱动程序:" + driverClassName + ",错误:" + e);
        }
    }

    // 创建连接池
    private void createPool() {
        pool = new DBConnectionPool(password, url, user, normalConnect,
                maxConnect);
        if (pool != null) {
            System.out.println("创建连接池成功");
        } else {
            System.out.println("创建连接池失败");
        }
    }

    // 返回唯一实例
    public static synchronized Pool getInstance() {
        if (instance == null) {
            instance = new Pool();
        }
        return instance;
    }

    // 获得一个可用的连接,如果没有则创建一个连接,且小于最大连接限制
    public Connection getConnection() {
        if (pool != null) {
            return pool.getConnection();
        }
        return null;
    }

    // 获得一个连接,有时间限制
    public Connection getConnection(long time) {
        if (pool != null) {
            return pool.getConnection(time);
        }
        return null;
    }

    // 将连接对象返回给连接池
    public void freeConnection(Connection con) {
        if (pool != null) {
            pool.freeConnection(con);
        }
    }

    // 返回当前空闲连接数
    public int getnum() {
        return pool.getnum();
    }

    // 返回当前连接数
    public int getnumActive() {
        return pool.getnumActive();
    }

    // 关闭所有连接,撤销驱动注册
    public synchronized void release() {
        // /关闭连接
        pool.release();
        // /撤销驱动
        try {
            DriverManager.deregisterDriver(driver);
            System.out.println("撤销JDBC驱动程序 " + driver.getClass().getName());
        } catch (SQLException e) {
            System.out
                    .println("无法撤销JDBC驱动程序的注册:" + driver.getClass().getName());
        }
    }
}

package shop;

//数据池文件
import java.sql.*;
import java.util.*;
import java.util.Date;

public class DBConnectionPool {
    private int checkedOut;

    private Vector<Connection> freeConnections = new Vector<Connection>();

    private int maxConn;

    // private int normalConn;

    private String password;

    private String url;

    private String user;

    private static int num = 0;// 空闲的连接数

    private static int numActive = 0;// 当前的连接数

    public DBConnectionPool(String password, String url, String user,
            int normalConn, int maxConn) {
        this.password = password;
        this.url = url;
        this.user = user;
        this.maxConn = maxConn;
        // this.normalConn = normalConn;
        for (int i = 0; i < normalConn; i++) { // 初始normalConn个连接
            Connection c = newConnection();
            if (c != null) {
                freeConnections.addElement(c);
                num++;
            }
        }
    }

    // 释放不用的连接到连接池
    public synchronized void freeConnection(Connection con) {
        freeConnections.addElement(con);
        num++;
        checkedOut--;
        numActive--;
        notifyAll();
    }

    // 创建一个新连接
    private Connection newConnection() {
        Connection con = null;
        try {
            if (user == null) { // 用户,密码都为空
                con = DriverManager.getConnection(url);
            } else {
                con = DriverManager.getConnection(url, user, password);
            }
            System.out.println("连接池创建一个新的连接");
        } catch (SQLException e) {
            System.out.println("无法创建这个URL的连接" + url);
            return null;
        }
        return con;
    }

    // 返回当前空闲连接数
    public int getnum() {
        return num;
    }

    // 返回当前连接数
    public int getnumActive() {
        return numActive;
    }

    // 获取一个可用连接
    public synchronized Connection getConnection() {
        Connection con = null;
        if (freeConnections.size() > 0) { // 还有空闲的连接
            num--;
            con = (Connection) freeConnections.firstElement();
            freeConnections.removeElementAt(0);
            try {
                if (con.isClosed()) {
                    System.out.println("从连接池删除一个无效连接");
                    con = getConnection();
                }
            } catch (SQLException e) {
                System.out.println("从连接池删除一个无效连接");
                con = getConnection();
            }
        } else if (maxConn == 0 || checkedOut < maxConn) { // 没有空闲连接且当前连接小于最大允许值,最大值为0则不限制
            con = newConnection();
        }
        if (con != null) { // 当前连接数加1
            checkedOut++;
        }
        numActive++;
        return con;
    }

    // 获取一个连接,并加上等待时间限制,时间为毫秒
    public synchronized Connection getConnection(long timeout) {
        long startTime = new Date().getTime();
        Connection con;
        while ((con = getConnection()) == null) {
            try {
                wait(timeout);
            } catch (InterruptedException e) {
            }
            if ((new Date().getTime() - startTime) >= timeout) {
                return null; // 超时返回
            }
        }
        return con;
    }

    // 关闭所有连接
    public synchronized void release() {
        Enumeration allConnections = freeConnections.elements();
        while (allConnections.hasMoreElements()) {
            Connection con = (Connection) allConnections.nextElement();
            try {
                con.close();
                num--;
            } catch (SQLException e) {
                System.out.println("无法关闭连接池中的连接");
            }
        }
        freeConnections.removeAllElements();
        numActive = 0;
    }
}
分享到:
评论

相关推荐

    Java jdbc数据库连接池总结

    Java JDBC 数据库连接池总结 Java 语言中,JDBC(Java DataBase Connection)是应用程序与数据库沟通的桥梁。在 Web 应用开发的早期,主要使用的技术是 CGIASPPHP 等。之后,Sun 公司推出了基于 Java 语言的 ...

    java数据库连接池

    Java数据库连接池(JDBC Connection Pool)是一种管理数据库连接的技术,它允许应用程序重复使用已经存在的数据库连接,而不是每次需要时都创建新的连接。这大大提高了应用程序的性能和效率,因为创建和销毁数据库...

    JAVA数据库连接池类

    本篇文章将深入解析一个自定义的JAVA数据库连接池类,帮助开发者更好地理解和运用这一关键技术。 首先,连接池的基本思想是预先创建一定数量的数据库连接,并存储在一个集合(如Vector)中,供应用程序按需获取和...

    Java数据库连接池的原理与应用.pdf

    Java数据库连接池的原理与应用 在Java开发领域,数据库连接池(Database Connection Pool,简称DBCP)是一种提高数据库访问性能、降低资源消耗的重要技术。它通过预先建立一定数量的数据库连接,存储在一个“池”中...

    java数据库连接池源码及使用示例

    总结来说,本资源提供了学习和实践Java数据库连接池的一个起点。通过分析源码并运行示例,你可以深入理解数据库连接池的实现细节,这将对提升Java应用的数据库性能有很大帮助。同时,这也是一次了解和比较不同连接池...

    Java各数据库连接池配置介绍

    Java数据库连接池是管理数据库连接的一种机制,它可以有效地复用数据库连接,避免每次数据库操作时创建和销毁连接的开销,从而提高了应用的性能。在Java中,有多种数据库连接池实现,包括C3P0、DBCP和Proxool等。 *...

    java数据库连接池的资料

    Java数据库连接池是一种高效管理数据库连接的技术,它在Java应用程序中扮演着至关重要的角色。连接池的基本思想是预先创建一定数量的数据库连接,存储在内存中,当应用程序需要时,从池中获取一个已存在的连接,用完...

    java 数据库连接池

    Java数据库连接池是一种重要的技术,它在Java应用程序与数据库交互时起到了关键的作用。数据库连接池在多线程、高并发的环境下尤其重要,因为它能够有效地管理和重用数据库连接,从而提高系统性能,减少资源消耗。 ...

    JAVA数据库连接池

    总的来说,Java数据库连接池是提高JSP网站性能的关键技术之一,它通过优化数据库连接的创建和管理,降低了系统资源的消耗,提升了网站的响应速度。正确理解和使用数据库连接池,是每个Java开发者必备的技能。

    java项目开发实践经验之二:几种常见数据库连接池的使用比较(转)

    本篇文章将探讨几种常见的数据库连接池的使用比较,包括Proxool、DBCP、C3P0,并通过配置文件(如`proxool.xml`、`dbcp.xml`和`c3p0.xml`)来展示它们的配置细节。 首先,我们来看Proxool,它是一个轻量级的数据库...

    数据库连接池代码

    数据库连接池是管理数据库连接的一种机制,它在应用程序启动时预创建一定数量的数据库连接,并将这些连接存储在一个池中。当应用程序需要访问数据库时,可以从池中获取一个已建立的连接,用完后再归还,而不是每次都...

    基于Java的数据库连接池组件

    实现Java数据库连接池组件: Java中实现数据库连接池组件通常涉及以下几个关键的步骤: 1. 初始化连接池:创建多个数据库连接,并存储在某个数据结构中,例如线程安全的列表或队列。 2. 连接池管理器:创建一个管理...

    数据库连接池 jar包

    MySQL数据库连接池是针对MySQL数据库的一种优化方式,通过预先创建并维护一定数量的数据库连接,避免了每次需要连接数据库时的创建和销毁过程,从而提高了应用的性能和资源利用率。 首先,我们需要了解什么是数据库...

    数据库连接池驱动包_数据库连接池驱动包_

    Druid 是阿里巴巴开源的一个强大、全面且高性能的Java数据库连接池。它不仅提供了基础的连接池功能,还集成了监控、SQL解析、拦截器等功能,可以帮助开发者进行性能分析和问题定位。Druid 还支持多种数据库,包括 ...

    数据库连接池c3p0jar包

    数据库连接池是Java开发中非常重要的一个组件,它在处理多线程环境下对数据库资源的高效利用和管理中起着关键作用。C3P0是一个开源的Java连接池实现,它提供了一种灵活且功能强大的数据库连接管理方式。在本文中,...

    Java的JDBC数据库连接池实现方法.doc

    Java 中的数据库连接池可以分为两类:一种是基于应用服务器的连接池,另一种是独立的连接池。在 J2EE 程序中,应用服务器通常提供了数据库连接池的功能,但是对于一般的 Java 应用程序、Applet 或者 JSP、velocity ...

Global site tag (gtag.js) - Google Analytics