静态代理和动态代理的例子

1.静态代理
静态代理 时序图：
[img]

[/img]
静态的代理
存在的问题：
1.需要建立大量的代理类
2.重复的代码会出现各个角落里。
接口

package com.test.dao;

public interface UserDao {

	public void addUser(String userId,String userName);
	
	public String findById(String id);
	
	public void modifyUser(String userId,String userName);
}

实现类：

package com.test.dao;


public class userDaoImpl implements UserDao {

	public void addUser(String userId, String userName) {
		
		System.out.println("userDaoImpl----->addUser()"+userName);

	}

	public String findById(String id) {
		// TODO Auto-generated method stub
		return null;
	}

	public void modifyUser(String userId, String userName) {
		// TODO Auto-generated method stub

	}

}

静态代理类:

package com.test.dao;


public class userDaoImpl implements UserDao {

	public void addUser(String userId, String userName) {
		
		System.out.println("userDaoImpl----->addUser()"+userName);

	}

	public String findById(String id) {
		// TODO Auto-generated method stub
		return null;
	}

	public void modifyUser(String userId, String userName) {
		// TODO Auto-generated method stub

	}

}

调用的客户端：

package com.test.dao;

public class Client {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		UserDao userDao= new UserProxyImpl(new userDaoImpl());
		
		userDao.addUser("a001", "郭靖");

	}

}

2.动态代理：
动态代理 时序图：
[img]

[/img]
接口

package com.test.dao;

public interface UserDao {

	public void addUser(String userId,String userName);
	
	public String findById(String id);
	
	public void modifyUser(String userId,String userName);
}

实现类：

package com.test.dao;


public class userDaoImpl implements UserDao {

	public void addUser(String userId, String userName) {
		
		System.out.println("userDaoImpl----->addUser()"+userName);

	}

	public String findById(String id) {
		// TODO Auto-generated method stub
		return null;
	}

	public void modifyUser(String userId, String userName) {
		// TODO Auto-generated method stub

	}

}

代理类:

package com.test.dao;

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

public class LogHendler implements InvocationHandler {

	//声明目标对象 所有类用继承之Object
	private Object targetObject;
	 //根据转入的对象创建代理类
	public Object newProxyObject(Object targetObject){
		this.targetObject=targetObject;
		//返回一个指定接口的代理类实例，该接口可以将方法调用指派到指定的调用处理程序
		return Proxy.newProxyInstance(targetObject.getClass().getClassLoader()
									, targetObject.getClass().getInterfaces()
									, this);
	}
	/**
	 * proxy - 在其上调用方法的代理实例
	 * method - 对应于在代理实例上调用的接口方法的 Method 实例
	 * args - 包含传入代理实例上方法调用的参数值的对象数组
	 */
	public Object invoke(Object proxy, Method method, Object[] args)
			throws Throwable {
		 System.out.println("代理start()------>"+method.getName());
		 //取方法参数个数
		 for(int i=0;i<args.length;i++){
			System.out.println(args[i]);
		 }
		 //用作返回
		 Object ret=null;
		 try{
		 //调用对象方法,如果有返回则存入ret中返回结果
			 ret=method.invoke(this.targetObject, args);
		 System.out.println("代理success------>"+method.getName());
		 }catch(Exception e){
			 e.printStackTrace();
			 System.out.println("调用代理------>失败！");
		 }
		return ret;
	}

}

调用的客户端：

package com.test.dao;

public class Client {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
//		UserDao userDao= new UserProxyImpl(new UserDaoImpl());
//		
//		userDao.addUser("a001", "郭靖");
		
		LogHendler hendler =new LogHendler();
		//根据真实的类生成代理对象
		UserDao userDao=(UserDao)hendler.newProxyObject(new UserDaoImpl());
		userDao.addUser("aoo1", "郭靖");
	}

}

3.项目应用动态代理做事务处理

public class TransactionHandler implements InvocationHandler {
	//取得目标对象
	private Object targetObject;
	public Object newProxyObject(Object targetObject){
		this.targetObject=targetObject;
		//根据传入的对象产生目标对象
		return Proxy.newProxyInstance(targetObject.getClass().getClassLoader()
									, targetObject.getClass().getInterfaces()
									, this);
	}
	
	public Object invoke(Object proxy, Method method, Object[] args)
			throws Throwable {
		Object ret=null;
		Connection conn=null;
		try{
			conn=ConnectionManager.getConnection();
			//只对add,modify,del开头的方法，开启事务，对find开头方法不开启事务
			if(method.getName().startsWith("add")||
				method.getName().startsWith("modify")||
				method.getName().startsWith("del")){
			//开启事务
				ConnectionManager.setAutoCommit(conn, false);
			}
			//调用目标方法，返回结果
			ret=method.invoke(targetObject, args);
			//如果是自动提交，则不要再重复提交
			if(!conn.getAutoCommit()){
			//提交事务
			ConnectionManager.commit(conn);
			}
		}catch(AppException e ){
		//事务回滚
			ConnectionManager.rollback(conn);
			throw e;
		}finally{
			ConnectionManager.closeConnection();
		}
		return ret;
	}

}