1.Proxy动态代理
我们先来看一下普通的工厂方法下的实现：
public interface UserService {
public void save();
public void delete();
public void update();
public void query();
}
public class UserServiceImpl implements UserService{
public void save() {
System.out.println("save");
}
public void delete() {
System.out.println("delete");
}
public void update() {
System.out.println("update");
}
public void query() {
System.out.println("query");
}
}
public class UserServiceProxyFactory {
public UserServiceProxyFactory() {
}
public UserService getUserService(){
return new UserServiceImpl();
}
}
UserServiceProxyFactory factory = new UserServiceProxyFactory();
UserService userService = factory.getUserService();
userService.save();
userService.query();
打印了：
save
query
假如此时我们需要在UserService的四个方法都加上事务判断，那么需要在每个方法里面加上一段代码，显然是不好的，这时我们使用动态代理来看一下怎么做.
我们让工厂以动态代理的方式来实现:
public class UserServiceProxyFactory implements InvocationHandler{
private UserService userService;
public UserServiceProxyFactory(UserService userService) {
this.userService = userService;
}
public UserService getUserServiceProxy(){
//生成动态代理
return (UserService) Proxy.newProxyInstance(UserServiceProxyFactory.class.getClassLoader(),
UserServiceImpl.class.getInterfaces(),this);
}
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
System.out.println("打开事务");
Object invoke = method.invoke(userService,args);
System.out.println("关闭事务");
return invoke;
}
}
UserService us = new UserServiceImpl();
UserServiceProxyFactory factory = new UserServiceProxyFactory(us);
UserService userService = factory.getUserServiceProxy();
userService.save();
userService.query();
打开事务
save
关闭事务
打开事务
query
关闭事务
可以看到使用了动态代理后每个方法前后都加入了事务管理，我们再来看一下UserService userService = factory.getUserServiceProxy();返回的是什么
System.out.println(userService instanceof UserServiceImpl);
System.out.println(userService.getClass());
false
class com.sun.proxy.$Proxy0
可以看出来这个并不是我们的UserServiceImpl对象，而是一个代理类，它同样实现了UserService接口，如果我们要代理的类没有实现某个接口的话不能使用这种方法，要用cglib动态代理
2.cglib动态代理
public class UserServiceProxyFactory2 implements MethodInterceptor{
public UserServiceImpl getUserServiceProxy(){
Enhancer en = new Enhancer();//生成代理对象
en.setSuperclass(UserServiceImpl.class);//对谁代理
en.setCallback(this);
UserServiceImpl userService = (UserServiceImpl) en.create();
return userService;
}
/**
* @param obj 代理对象
* @param method 调用的方法,基于jdk reflect,此方法不能直接在当前对象中使用,只能使用在其他实例上,否则将无限循环触发"拦截器"
* @param proxy 经过封装的代理类的方法
*/
public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
System.out.println("打开事务");
Object value = proxy.invokeSuper(obj, args);//这里要特别注意使用的是invokeSuper方法
System.out.println("关闭事务");
//如下两个方法,不能在当前代理对象中使用.
//method.invoke(other, args);
//proxy.invoke(other, args);
return value;
}
}
UserServiceProxyFactory2 factory2 = new UserServiceProxyFactory2();
UserServiceImpl userService = factory2.getUserServiceProxy();
userService.save();
userService.query();
打开事务
save
关闭事务
打开事务
query
关闭事务
System.out.println(userService instanceof UserServiceImpl);
System.out.println(userService.getClass());
true
class com.test.service.UserServiceImpl$$EnhancerByCGLIB$$e0e91299
可以看出使用这种方式拿到的代理是继承了UserServiceImpl
