}
public class ClassesDaoInterceptor implements InvocationHandler{
private Object target;
private MyTransaction myTransaction;
public ClassesDaoInterceptor(Object target,MyTransaction myTransaction){
this.target = target;
this.myTransaction = myTransaction;
}
@Override
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
System.out.println(proxy.getClass().getName());
if(method.getName().equals("saveClasses")||
method.getName().equals("updateClasses")){
this.myTransaction.beginTransaction();//??
method.invoke(this.target, args);//?????
this.myTransaction.commit();
}else{
method.invoke(this.target, args);
}
return null;
}
}
public class ClassesDaoTest {
public static void testSaveClasses(){
Object target = new ClassesDaoImpl();
MyTransaction myTransaction = new MyTransaction();
ClassesDaoInterceptor interceptor = new ClassesDaoInterceptor(target, myTransaction);
ClassesDao proxyDao = (ClassesDao) Proxy.newProxyInstance(target.getClass().getClassLoader(), target.getClass().getInterfaces(), interceptor);
Classes classes = new Classes();
classes.setCname("aaaa");
proxyDao.saveClasses(classes);
}
public static void main(String[] args) {
testSaveClasses();
}
}
spring的事務(wù)也是動(dòng)態(tài)代理實(shí)現(xiàn)的,當(dāng)一個(gè)服務(wù)類里的一個(gè)實(shí)現(xiàn)了服務(wù)接口的方法中調(diào)用另一個(gè)服務(wù)方法,第二個(gè)服務(wù)方法不會(huì)加入到事務(wù)中,因?yàn)檫@種調(diào)用方式不是被代理對(duì)象調(diào)用,而是實(shí)際目標(biāo)對(duì)象調(diào)用,不會(huì)產(chǎn)生代理對(duì)象,所以第二個(gè)服務(wù)方法不會(huì)加入到事務(wù)中,如果想實(shí)現(xiàn)這種操作,需要先得到aop的代理對(duì)象,AopContext.currentProxy();,得到服務(wù)接口,進(jìn)行調(diào)用服務(wù)方法。spring的事務(wù)代理是cglib實(shí)現(xiàn)的,只能代理訪問接口中的方法。