A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

数据库连接池原理-传统方式
当有多个线程,每个线程都需要连接数据库执行SQL语句的话,那么每个线程都会创建一个连接,并且在使用完毕后,关闭连接。
创建连接和关闭连接的过程也是比较消耗时间的,当多线程并发的时候,系统就会变得很卡顿。
同时,一个数据库同时支持的连接总数也是有限的,如果多线程并发量很大,那么数据库连接的总数就会被消耗光,后续线程发起的数据库连接就会失败。


数据库连接池原理-使用池
与传统方式不同,连接池在使用之前,就会创建好一定数量的连接。
如果有任何线程需要使用连接,那么就从连接池里面借用,而不是自己重新创建.
使用完毕后,又把这个连接归还给连接池供下一次或者其他线程使用。
倘若发生多线程并发情况,连接池里的连接被借用光了,那么其他线程就会临时等待,直到有连接被归还回来,再继续使用。
整个过程,这些连接都不会被关闭,而是不断的被循环使用,从而节约了启动和关闭连接的时间。



ConnectionPool构造方法和初始化

1. ConnectionPool() 构造方法约定了这个连接池一共有多少连接。
2. 在init() 初始化方法中,创建了size条连接。 注意,这里不能使用try-with-resource这种自动关闭连接的方式。
因为连接恰恰需要保持不关闭状态,供后续循环使用。
3. getConnection, 判断是否为空,如果是空的就wait等待,否则就借用一条连接出去。
4. returnConnection, 在使用完毕后,归还这个连接到连接池,并且在归还完毕后,调用notifyAll,通知那些等待的线程,有新的连接可以借用了。

注:连接池设计用到了多线程的wait和notifyAll
[url=][/url]
public class ConnectionPool {    List<Connection> cs = new ArrayList<Connection>();    int size;    //定义连接池里的最大连接数    public ConnectionPool(int size){        this.size = size;        init();    }    public void init(){        //这里恰恰不能使用try-with-resource的方式,        // 因为这些连接都需要是活的,不要被自动关闭        try{            Class.forName("com.mysql.jdbc.Driver");            for (int i = 0;i<size;i++){                Connection c = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/how2java?characterEncoding=UTF-8",                        "root", "123456");                cs.add(c);            }        }catch (ClassNotFoundException e){            e.printStackTrace();        }catch (SQLException e){            e.printStackTrace();        }    }    //需要连接时,将连接分配出去的方法    public synchronized Connection getConnection(){        while(cs.isEmpty()){            try{                this.wait();//this表示引用该函数所属类的当前对象            }catch (InterruptedException e) {                e.printStackTrace();            }        }        Connection c = cs.remove(0);        return c;    }    //用完连接后,将连接还给连接池的方法    public synchronized void returnConnection(Connection c){        cs.add(c);        this.notifyAll();    }}[url=][/url]

测试类首先初始化一个有3条连接的数据库连接池然后创建100个线程,每个线程都会从连接池中借用连接,并且在借用之后,归还连接。 拿到连接之后,执行一个耗时1秒的SQL语句。

[url=][/url]
public class TestConnectionPool {    public static void main(String[] args) {        ConnectionPool cp = new ConnectionPool(3);        for (int i = 0;i<100;i++){            new WorkingThread("working thread"+i,cp).start();        }    }}class WorkingThread extends Thread{    private ConnectionPool cp;    public WorkingThread(String name,ConnectionPool cp){        super(name);//给当前thread命名        this.cp = cp;    }    public void run(){        Connection c = cp.getConnection();        System.out.println(this.getName()+":\t 获取了一根连接,并开始工作");        try(Statement st = c.createStatement()){            //模拟时耗1秒的数据库SQL语句            Thread.sleep(1000);            st.execute("select * from hero");        }catch (SQLException | InterruptedException e){            e.printStackTrace();        }        cp.returnConnection(c);    }}[url=][/url]








2 个回复

倒序浏览
有任何问题欢迎在评论区留言
回复 使用道具 举报
或者添加学姐微信
DKA-2018
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马