MySQL資料庫第七天—-Connection連接池、包裝模式(裝飾模式)與動態代理模式

在上次寫的連接模板中,Connection是單例,隻適用於單線程也就是一個用戶操作,一旦多線程同時運行,就會掛掉,這裡將探討原因和解決辦法。

單例工廠類的漏洞:

這裡寫瞭一個類,專門對此做瞭測試:

TxDemo.java

package cn.hncu.tx;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

import cn.hncu.pubs.ConnFactory;

//使用的是單例連接工廠ConnFactory
public class TxDemo {
	/*
	 * 我這裡開瞭四個線程,加上mian線程,共五個線程,每次拿Connection都是拿的同一個對象,
	 * 則這些線程之間會串數據,如:
	 * 我讓main線程執行插入,然後在提交之前睡眠,讓第三個線程執行插入時出錯,
	 * 然後回滾,就會把main線程剛才所執行的全部回滾,main線程之前的動作全部無效,
	 * 若其他線程比三線程提前執行完,則把main線程的動作也一起提交瞭,若main線程下面出錯,則無法回滾
	 * 這樣不安全
	 */
	public static void main(String[] args) {
		Connection con = ConnFactory.getConn();
		try {
			Statement st = con.createStatement();
			con.setAutoCommit(false);// 開啟一個事務
			st.executeUpdate("insert into person2 values('P07','趙子龍','1')");

			MyThread th1 = new MyThread(1);
			MyThread th2 = new MyThread(2);
			MyThread th3 = new MyThread(3);
			MyThread th4 = new MyThread(4);
			th1.start();
			th2.start();
			th3.start();
			th4.start();
			Thread.sleep(1000);

			con.commit();
			System.out.println("main線程提交一個事務");
		} catch (Exception e) {
			try {
				con.rollback();
				System.out.println("main線程回滾一個事務");
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		} finally {
			try {
//				con.setAutoCommit(true);
//				con.close();
			} catch (Exception e) {
				e.printStackTrace();
			}

		}
	}
}

class MyThread extends Thread {
	private int num;

	public MyThread(int num) {
		this.num = num;
	}

	@Override
	public void run() {
		Connection con = ConnFactory.getConn();
		try {
			Statement st = con.createStatement();
			con.setAutoCommit(false);// 開啟一個事務
			String sql = "insert into person2 values('P07" + num + "','趙子龍"
					+ num + "','1')";
			if(num==3){
				sql = "insert into person2 values('P07" + num + ",'趙子龍"
						+ num + "','1')";
			}else{
				Thread.sleep(100);
			}
			//System.out.println("sql-----" + sql);
			st.executeUpdate(sql);
			con.commit();
			System.out.println(num + "線程提交一個事務");

		} catch (Exception e) {
			try {
				con.rollback();
				System.out.println(num + "線程回滾一個事務");
			} catch (SQLException e1) {
				e1.printStackTrace();
			} finally {
				try {
//					con.setAutoCommit(true);
//					con.close();
				} catch (Exception e1) {
					e1.printStackTrace();
				}
			}
		}

	}

}

串數據:雖然main線程提交瞭事務,但是被3線程給回滾瞭,所以main線程做的插入動作也被回滾瞭,再提交也沒用

解決:要開一個連接池,池中放連接,對池做維護

ConnUtils.java工具類

package cn.hncu.pool;

import java.sql.Connection;
import java.sql.DriverManager;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

//new出多個連接,放進池中,連接不再是單例,用池當單例
public class ConnUtils {
	private static List pool=new ArrayList();
	private final static int NUM=3;
	private ConnUtils(){
	}
	static{
		Properties p=new Properties();
		try {
			p.load(ClassLoader.getSystemResourceAsStream("jdbc.properties"));//可從本類ConnUtils.Class.getClassLoader().getResourceAsStream("jdbc.properties")拿
			String dirver=p.getProperty("driver");
			String url=p.getProperty("url");
			String user=p.getProperty("username");
			String password=p.getProperty("password");
			
			Class.forName(dirver);
			for(int i=0;i

TxDemo2.java測試類

package cn.hncu.tx;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

import cn.hncu.pool.ConnUtils;
import cn.hncu.pubs.ConnFactory;

//使用的是多例連接工具ConnUtils
public class TxDemo2 {
	
	public static void main(String[] args) {
		Connection con = ConnUtils.getConn();
		try {
			Statement st = con.createStatement();
			con.setAutoCommit(false);// 開啟一個事務
			st.executeUpdate("insert into person2 values('P07','趙子龍','1')");

			MyThread2 th1 = new MyThread2(1);
			MyThread2 th2 = new MyThread2(2);
			MyThread2 th3 = new MyThread2(3);
			MyThread2 th4 = new MyThread2(4);
			th1.start();
			th2.start();
			th3.start();
			th4.start();
			Thread.sleep(1000);

			con.commit();
			System.out.println("main線程提交一個事務");
		} catch (Exception e) {
			try {
				con.rollback();
				System.out.println("main線程回滾一個事務");
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		} finally {
			try {
				con.setAutoCommit(true);
//				con.close();
				ConnUtils.back(con);//這裡是回收Connection連接,應做成con.close(),池在背後回收資源,調用back方法
			} catch (Exception e) {
				e.printStackTrace();
			}

		}
	}
}

class MyThread2 extends Thread {
	private int num;

	public MyThread2(int num) {
		this.num = num;
	}

	@Override
	public void run() {
		Connection con = ConnUtils.getConn();
		try {
			Statement st = con.createStatement();
			con.setAutoCommit(false);// 開啟一個事務
			String sql = "insert into person2 values('P07" + num + "','趙子龍"
					+ num + "','1')";
			if(num==2){
				sql = "insert into person2 values('P07" + num + ",'趙子龍"
						+ num + "','1')";
			}else{
				Thread.sleep(100);
			}
			//System.out.println("sql-----" + sql);
			st.executeUpdate(sql);
			con.commit();
			System.out.println(num + "線程提交一個事務");

		} catch (Exception e) {
			try {
				con.rollback();
				System.out.println(num + "線程回滾一個事務");
			} catch (SQLException e1) {
				e1.printStackTrace();
			} finally {
				try {
					con.setAutoCommit(true);
//					con.close();
					ConnUtils.back(con);
				} catch (Exception e1) {
					e1.printStackTrace();
				}
			}
		}

	}

}

每個線程都獨立開瞭,各不影響:

 

裝修模式:

對Connection功能進行增強

ConnUtils2.java

由於本代碼實現瞭Connection接口,代碼較多,但大部分都是 不重要的,這裡我隻對改動的代碼貼出來:

在靜態塊for循環中

for(int i=0;i

這裡用到瞭MyConnection內部類

//采用包裝模式(裝修模式)對Connection con功能進行增強
	//因為是靜態塊中new  MyConnection 同時還要訪問靜態變量pool,所以要聲明成靜態,不然new 的時候會出現錯誤
	 static class MyConnection implements Connection {
		private Connection con;
		public MyConnection(Connection con){
			this.con=con;
		}
		

下面都是實現Connection抽象方法,我們隻對close方法進行更改,其餘還是用原來的

//功能增強就是這個地方,把close方法,改成放回池中
		@Override
		public void close() throws SQLException {
			System.out.println("往池中還回一個連接------"+this);
			pool.add(this);//註意這裡要放this
		}

TxDemo3.java中也隻是把原先的ConnUtils.back(con)方法,改成con.close()方法,其餘與TxDemo2.java相同,這裡不再重敘。

 

結果也是正確的:

 

代理模式:

代理模式的作用是:為其他對象提供一種代理以控制對這個對象的訪問。

 

代理模式的初期引入:

房東與租客:

Renter.java

package cn.hncu.proxy.rent;

public class Renter implements IRenter {
	@Override
	public void rent(){
		System.out.println("房東:租出房子,收取房租");
	}

	@Override
	public String toString() {
		return "好好保護我的房子....";
	}
	
	
}

IRenter.java

package cn.hncu.proxy.rent;

public interface IRenter {
	public abstract void rent();
}

Client.java

package cn.hncu.proxy.rent;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

public class Client {

	public static void main(String[] args) {
		final Renter r=new Renter();//被代理對象-----原型對象
		
		Object newObj=Proxy.newProxyInstance(
				//ClassLoader loader, Class[] interfaces, InvocationHandler h
				Client.class.getClassLoader(),
				new Class[]{IRenter.class}, 
				new InvocationHandler() {
					
					@Override//參數:proxy是代理後的對象(和外面的newObj一樣的),method是當前被調用的method對象,args是當前method對象的參數
					public Object invoke(Object proxy, Method method, Object[] args)
							throws Throwable {
						if(method.getName().equals("rent")){
							System.out.println("給中介交點費用...");
							return method.invoke(r, args);
						}
						
						return method.invoke(r, args);//這裡是放行,不做任何攔截,隻是從這裡過瞭一下
					}
				});
		
		/*
		 * 代理後的對象newObj和原型對象r 是不同類型的對象。二者屬於兄弟關系,都是IRenter接口的實現類(子類)
		 * 因此newObj是無法強轉成Renter類型
		 */
		
		//代理後的newObj通常都是強轉換成接口類型來使用
		IRenter ir=(IRenter)newObj;
		ir.rent();
		
		String str=ir.toString();
		System.out.println(str);
	}

}

 

運行結果圖:

 

連接池用代理模式:

ConnnUtils3.java

package cn.hncu.pool;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

//new出多個連接,放進池中,連接不再是單例,用池當單例
public class ConnUtils3 {
	private static List pool=new ArrayList();
	private final static int NUM=3;
	private ConnUtils3(){
	}
	static{
		Properties p=new Properties();
		try {
			p.load(ClassLoader.getSystemResourceAsStream("jdbc.properties"));//可從本類ConnUtils.Class.getClassLoader().getResourceAsStream("jdbc.properties")拿
			String dirver=p.getProperty("driver");
			String url=p.getProperty("url");
			String user=p.getProperty("username");
			String password=p.getProperty("password");
			
			Class.forName(dirver);
			for(int i=0;i

測試類與測試結果和上次的一樣,這裡不再貼出。

通用模板:

ProxyUtils.java

package cn.hncu.proxy.util;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

public class ProxyUtils implements InvocationHandler {
	private Object obj;
	private ProxyUtils(Object obj){
		this.obj=obj;
	}
	public static Object getProxy(Object obj){
		Object newObj=Proxy.newProxyInstance(
				ProxyUtils.class.getClassLoader(), 
				obj.getClass().getInterfaces(), 
				new ProxyUtils(obj));//構造傳參
		return newObj;
	}
	@Override
	public Object invoke(Object proxy, Method method, Object[] args)
			throws Throwable {
		
		System.out.println("前面攔攔:......");
		Object resObj=method.invoke(obj, args);
		System.out.println("後面攔攔:......");
		
		
		return resObj;
	}
}

 

測試模板:

人和狗

dog.java

package cn.hncu.proxy.util;

public class Dog implements IDog {
	private String name;
	public Dog(){
		this.name="小黑";
	}
	/* (non-Javadoc)
	 * @see cn.hncu.proxy.util.IDog#bark()
	 */
	@Override
	public void bark(){
		System.out.println(name+": 汪``汪``汪``");
	}
}

IDog.java

package cn.hncu.proxy.util;

public interface IDog {

	public abstract void bark();

}

Person.java

package cn.hncu.proxy.util;

public class Person implements IPerson {
	private String name;
	public Person(String name){
		this.name=name;
	}
	
	/* (non-Javadoc)
	 * @see cn.hncu.proxy.util.IPerson#sayHi()
	 */
	@Override
	public void sayHi(){
		System.out.println("Hello,I am "+name);
	}
	
}

IPerson.java

package cn.hncu.proxy.util;

public interface IPerson {

	public abstract void sayHi();

}

Client.java

package cn.hncu.proxy.util;

public class Client {

	public static void main(String[] args) {
		Dog dog=new Dog();
		IDog dog2=(IDog) ProxyUtils.getProxy(dog);
		
		Person p=new Person("二牛");
		IPerson p2=(IPerson) ProxyUtils.getProxy(p);
		
		p2.sayHi();
		System.out.println("------------------------");
		dog2.bark();
	}

}

運行結果:


 

You May Also Like