javamysqlproxy_JAVA动态代理（实现自定义数据库连接池）

JAVA 动态代理(实现自定义数据库连接池)

环境&＃xff1a;JDK1.8

MAVEN

IDEA 2018.2

jar包&＃xff1a;mysql-connector-java-5.1.38

实现思路&＃xff1a;

首先通过资源文件读取数据库连接必要信息(driver&＃xff0c;url&＃xff0c;user&＃xff0c;password)&＃xff0c;获取数据库连接&＃xff0c;然后通过动态代理模式阻止连接真正被关闭而是放回集(连接池)合中。

Maven导包

mysql

mysql-connector-java

5.1.38

项目结构

dbconfig.properties

#数据库驱动配置文件

DRIVER&＃61;com.mysql.jdbc.Driver

URL&＃61;jdbc:mysql:///abc

USER&＃61;root

PASSWORD&＃61;abcJDBCUtil.java

package cn.omist.util;

import java.sql.*;

import java.util.ResourceBundle;

/**

* 数据库相关操作

* &＃64;author Mr_Fan

*/

public class JDBCUtil {

//使用ResourceBundle读取资源文件

private static ResourceBundle bundle &＃61; ResourceBundle.getBundle("dbconfig");

private static String driver;

private static String url;

private static String user;

private static String password;

//使用静态代码块进行赋值

static {

driver &＃61; bundle.getString("DRIVER");

url &＃61; bundle.getString("URL");

user &＃61; bundle.getString("USER");

password &＃61; bundle.getString("PASSWORD");

}

/**

* 获取连接

* &＃64;return

*/

public static Connection getConnection() {

Connection conn &＃61; null;

try {

Class.forName(driver);

conn &＃61; DriverManager.getConnection(url, user, password);

return conn;

} catch (Exception e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

/**

* 释放连接

* &＃64;param rs

* &＃64;param st

* &＃64;param conn

*/

public static void release(ResultSet rs, Statement st, Connection conn) {

if (rs !&＃61; null) {

try {

rs.close();

} catch (Exception e) {

e.printStackTrace();

}

}

if (st !&＃61; null) {

try {

st.cancel();

} catch (Exception e) {

e.printStackTrace();

}

}

if (conn !&＃61; null) {

try {

conn.commit();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

}MyDataSource.java

package cn.omist.dataSource;

import cn.omist.util.JDBCUtil;

import java.lang.reflect.InvocationHandler;

import java.lang.reflect.Method;

import java.lang.reflect.Proxy;

import java.sql.Connection;

import java.util.ArrayList;

import java.util.Collections;

import java.util.List;

/**

* 自定义连接池

*

* &＃64;author Mr_Fan

*/

public class MyDataSource {

//定义一个池&＃xff0c;用于存放连接

// private static List pool &＃61; new ArrayList(); //线程不安全所以不使用

//Collections.synchronixzedList 方法使集合变得线程安全

private static List pool &＃61; Collections.synchronizedList(new ArrayList());

//使用静态代码快递给池中加入连接

static {

for (int i &＃61; 0; i <10; i&＃43;&＃43;) {

Connection conn &＃61; JDBCUtil.getConnection();

pool.add(conn);

}

}

/**

* 获取一个连接 采用动态代理模式

*

* &＃64;return

*/

public static Connection getConnection() {

final Connection conn &＃61; pool.remove(0);

//创建代理对象

Connection proxyConn &＃61; (Connection) Proxy.newProxyInstance(conn.getClass().getClassLoader(),

conn.getClass().getInterfaces(),

new InvocationHandler() {

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

Object rtValue &＃61; null;

//1.判断当前方法是不是close方法

if ("close".equals(method.getName())) {

//不能直接关闭

pool.add(conn);//返回池中

} else {

rtValue &＃61; method.invoke(conn, args);

}

return rtValue;

}

});

return proxyConn;

}

/**

* 获取池中的连接数

*

* &＃64;return

*/

public static int getPoolSize() {

return pool.size();

}

}DataSourceTest.java

package cn.omist.test;

import cn.omist.dataSource.MyDataSource;

import java.sql.Connection;

import java.sql.SQLException;

public class DataSourceTest {

public static void main(String[] args) throws SQLException {

int size &＃61; MyDataSource.getPoolSize();

System.out.println("使用之前连接数量:"&＃43;size);

for (int i &＃61; 0; i <10; i&＃43;&＃43;) {

Connection conn &＃61; MyDataSource.getConnection();

System.out.println(conn);

conn.close();

}

int size1 &＃61; MyDataSource.getPoolSize();

System.out.println("使用之后连接数量:"&＃43;size);

}

}运行结果

使用之前连接数量:10

com.mysql.jdbc.JDBC4Connection&＃64;3d82c5f3

com.mysql.jdbc.JDBC4Connection&＃64;2b05039f

com.mysql.jdbc.JDBC4Connection&＃64;61e717c2

com.mysql.jdbc.JDBC4Connection&＃64;66cd51c3

com.mysql.jdbc.JDBC4Connection&＃64;4dcbadb4

com.mysql.jdbc.JDBC4Connection&＃64;4e515669

com.mysql.jdbc.JDBC4Connection&＃64;17d10166

com.mysql.jdbc.JDBC4Connection&＃64;1b9e1916

com.mysql.jdbc.JDBC4Connection&＃64;ba8a1dc

com.mysql.jdbc.JDBC4Connection&＃64;4f8e5cde

使用之后连接数量:10

支付宝扫一扫

微信扫一扫

企鹅扫一扫