当前位置： 首页 > news >正文

手写数据库连接池

news 2025/8/4 19:12:48

数据库连接是个耗时操作.对数据库连接的高效管理影响应用程序的性能指标.

数据库连接池正是针对这个问题提出来的.

数据库连接池负责分配,管理和释放数据库连接.它允许应用程序重复使用一个现有的数据路连接,而不需要每次重新建立一个新的连接,利用数据库连接池将明显提升对数据库操作的性能.

数据库连接池技术方案:

1.C3P0

2.DBCP

3.Proxool

4.Tomcat jdbc Oppl

5.BoneCP

6.Druid

7.HikariCP

数据库连接池属于一种池化技术:

常见的有:http访问(httpclient),redis访问(redisPool),线程(线程池)等

新建个空项目

可能是版本原因idea创建空项目总要重启一下

设置下maven和encoding

新建模块

DataSource是JDK里的规范,用来专门放连接的.是一个连接工厂

自定义一个接口

里面需要实现的两个方法是:  其他的父接口的其他方式可以暂时不管

这样基础结构就有了

package com.pool;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;/*** @author hrui* @date 2023/9/10 3:06*/
public class MyAbstractDataSource implements MyDataSourceInterface{private String url;private String driver;private String username;private String password;//最大的连接数量private int poolMaxActiveConnection=10;//最大空闲连接数private int poolMaxIdIeConnection=5;//当连接都在使用时候,最大检出时间(等待时间),毫秒private int poolTimeToWait=20000;public int getPoolMaxActiveConnection() {return poolMaxActiveConnection;}public void setPoolMaxActiveConnection(int poolMaxActiveConnection) {this.poolMaxActiveConnection = poolMaxActiveConnection;}public int getPoolMaxIdIeConnection() {return poolMaxIdIeConnection;}public void setPoolMaxIdIeConnection(int poolMaxIdIeConnection) {this.poolMaxIdIeConnection = poolMaxIdIeConnection;}public int getPoolTimeToWait() {return poolTimeToWait;}public void setPoolTimeToWait(int poolTimeToWait) {this.poolTimeToWait = poolTimeToWait;}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}public String getDriver() {return driver;}public void setDriver(String driver) {this.driver = driver;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}@Overridepublic Connection getConnection() throws SQLException {return getConnection(username,password);}@Overridepublic Connection getConnection(String username, String password) throws SQLException {return doGetConnection(username,password);}private Connection doGetConnection(String username, String password) throws SQLException {Connection connection = DriverManager.getConnection(url, username, password);return connection;}
}

上面三个方法,都是获得连接

下面用动态代理方式实现对数据库连接的代理

package com.pool;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;/*** 采用动态代理实现对数据库连接的代理* @author hrui* @date 2023/9/10 3:45*/
public  class ConnectionProxy implements InvocationHandler {//真正连接private Connection realConnection;//代理连接private Connection proxyConnection;//数据源对象private MyDataSource myDataSource;public ConnectionProxy(Connection realConnection, MyDataSource myDataSource) {//初始化真实连接和数据源this.realConnection = realConnection;this.myDataSource = myDataSource;//初始化代理连接...需要一个代理对象  JDK动态代理this.proxyConnection= (Connection)Proxy.newProxyInstance(Connection.class.getClassLoader(),new Class<?>[]{Connection.class},this);}public Connection getRealConnection() {return realConnection;}public void setRealConnection(Connection realConnection) {this.realConnection = realConnection;}public Connection getProxyConnection() {return proxyConnection;}public void setProxyConnection(Connection proxyConnection) {this.proxyConnection = proxyConnection;}public MyDataSource getMyDataSource() {return myDataSource;}public void setMyDataSource(MyDataSource myDataSource) {this.myDataSource = myDataSource;}/*** 当调用Connection对象里面的任何方法时,该方法会进行拦截* 主要目的为了拦截Connection的close方法,当关闭时进行拦截,将Connection对象放入连接池中* 其他方法无需拦截* @param proxy* @param method* @param args* @return* @throws Throwable*/@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {//获取当前调用了Connection对象的什么方法String methodName=method.getName();if(methodName.equals("close")){//TODO 把连接放入连接池return null;}else{//其他方法return method.invoke(realConnection, args);}}
}}

下面写个类继承MyAbstractDataSource  在里面放入连接池

package com.pool;import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;/*** 数据源连接池* @author hrui* @date 2023/9/10 4:15*/
public class MyDataSource extends MyAbstractDataSource{//空闲连接private final List<ConnectionProxy> idleConnections=new ArrayList<>();//激活的连接池private final List<ConnectionProxy> activeConnections=new ArrayList<>();//下面三个可以抽取放到父类抽象类中,由用户配置 //最大的连接数量//private int poolMaxActiveConnection=10;//最大空闲连接数//private int poolMaxIdIeConnection=5;//当连接都在使用时候,最大检出时间(等待时间),毫秒//private int poolTimeToWait=20000;//用于同步监视器对象private final Object monitor=new Object();//用于同步监视器对象(关闭)//private final Object watch=new Object();/*** 重写:用于获取代理连接* @return* @throws SQLException*/@Overridepublic Connection getConnection() throws SQLException {ConnectionProxy connectionProxy=getConnectionProxy(super.getUsername(),super.getPassword());//返回代理连接return super.getConnection();}/*** 获取代理连接* @param username* @param password* @return*/private ConnectionProxy getConnectionProxy(String username,String password) throws SQLException {//TODO//是否需要等待boolean wait=false;ConnectionProxy connectionProxy=null;//刚开始没有连接while(connectionProxy==null){synchronized (monitor){//看连接池有没有空闲连接,如果不为空,直接获取连接if(!idleConnections.isEmpty()){connectionProxy=idleConnections.remove(0);//如果是空的}else{//没有空闲连接,那么需要获取新的连接(创建连接)//这里先判断最大连接数是不是小于配置数量  10if(activeConnections.size()<supper.getPoolMaxActiveConnection()){//创建新连接  需要传入真实连接connectionProxy=new ConnectionProxy(super.getConnection(),this);}//否则需要等待20秒   上面定义了poolTimeToWait=20000}}if(!wait){wait=true;}if(connectionProxy==null){try {monitor.wait(supper.getPoolTimeToWait());} catch (InterruptedException e) {e.printStackTrace();//万一等待被线程打断,退出一下break;}}}if(connectionProxy!=null){//连接对象不是空,说明已经拿到连接了,放入容器activeConnections.add(connectionProxy);}return connectionProxy;}//用于关连接//不是把连接关系,而是还给连接池public void closeConnection(ConnectionProxy connectionProxy){synchronized (monitor){//最大连接(激活连接)里删除activeConnections.remove(connectionProxy);//如果空闲连接<定义的数量则放入空闲连接if(idleConnections.size()<supper.getPoolMaxIdIeConnection()){idleConnections.add(connectionProxy);}//通知一下,唤醒上面哪个等待获取连接的线程monitor.notify();}}
}

那么代理对象中把连接还给连接池的方法也有了

就是当所有连接用完了,等待20秒的逻辑没写

下面测试自己写的连接池

新建模块  引入依赖

不想玩了

http://www.lryc.cn/news/161301.html

相关文章：

  • 在CentOS7上增加swap空间
  • @Autowired和@Resource
  • QTableView通过setColumnWidth设置了列宽无效的问题
  • 【用unity实现100个游戏之10】复刻经典俄罗斯方块游戏
  • Docker容器内数据备份到系统本地
  • 学信息系统项目管理师第4版系列06_项目管理概论
  • Java发送（QQ）邮箱、验证码发送
  • PostgresSQL----基于Kubernetes部署PostgresSQL
  • 7 个适合初学者的项目，可帮助您开始使用 ChatGPT
  • JDBC操作SQLite的工具类
  • SEO百度优化基础知识全解析（了解百度SEO标签作用）
  • 用python实现基本数据结构【03/4】
  • 软件测试面试题汇总
  • AP5101C 高压线性恒流IC 宽电压6-100V LED汽车大灯照明 台灯LED矿灯 指示灯电源驱动
  • 【大数问题】字符串相减（大数相减）＜模拟＞
  • easycode生成代码模板配置
  • 【数据结构】堆排序和Top-k问题
  • 经典的生产者和消费者模型问题
  • Java基础：代理
  • 每日一学——防火墙2
  • Web学习笔记-React（组合Components）
  • 【strstr函数的介绍和模拟实现——超详细版】
  • 【Terraform】Terraform自动创建云服务器脚本
  • TCP机制之确认应答及超时重传
  • Openharmony3.2 源码编译(ubuntu 22.04) 过程记录
  • PostgreSQL 数据库使用 psql 导入 SQL
  • 容器编排学习（三）端口映射与Harber镜像仓库介绍
  • Day_13 ＞ 指针进阶（2）
  • 对Transformer中的Attention(注意力机制)的一点点探索
  • 车内信息安全技术-安全技术栈-软件安全