代理模式实现 - ToB企服应用市场:ToB评测及商务社交产业平台

/**
* Subject
*/
public interface IUserMapperInterface {
void save(String userName, String userNumber);
}

复制代码

/**
* RealSubject
*/
public class UserMapperInterfaceImpl implements IUserMapperInterface {
@Override
public void save(String userName, String userNumber) {
System.out.println("执行insert语句，保存数据，并返回成功！");
}
}

复制代码

/**
* 代理类
*/
public class UserMapperInterfaceProxy implements IUserMapperInterface {
private IUserMapperInterface userMapperInterface;
public UserMapperInterfaceProxy(IUserMapperInterface userMapperInterface) {
this.userMapperInterface = userMapperInterface;
}
@Override
public void save(String userName, String userNumber) {
System.out.println("开启事务~~~");
userMapperInterface.save(userName, userNumber);
System.out.println("提交事务");
}
}

复制代码

/**
* 客户端
*/
public class Client {
public static void main(String[] args) {
String userName = "user name";
String userNumber = "user number";
UserMapperInterfaceProxy proxy = new UserMapperInterfaceProxy(new UserMapperInterfaceImpl());
proxy.save(userName, userNumber);
}
}

复制代码

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
/**
* 代理的工厂类
*/
public class ProxyFactory {
//需要代理的目标类
private Object target;
public ProxyFactory(Object target) {
this.target = target;
}
public Object getTargetInstance() {
//Proxy是反射包下（java.lang.reflect）的一个代理类，通过这个类的newProxyInstance（新建代理对象实例）来动态的加载一个代理目标对象，并返回
//newProxyInstance方法需要传递三个参数，1、目标对象的类加载器， 2、目标对象实现的接口（如果有实现就有，没有实现就没有），3、目标对象需要执行的方法，相当于扩展静态代理中的那个save方法
return Proxy.newProxyInstance(target.getClass().getClassLoader(), target.getClass().getInterfaces(), new InvocationHandler() {
//，目标对象被代理后需要执行的扩展方法，也有三个参数，1、目标对象，2、目标对象需要执行的方法实例，3、方法实例需要传递的参数
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
System.out.println("开启一个事务~！");
//执行方法,执行的时候把目标对象和方法参数传递过去
method.invoke(target, args);
System.out.println("提交事务");
//返回值是指目标执行的方法的返回值，如果没有就返回null，在静态代理中，目标方法save的返回值是void，因此这里返回null
return null;
}
});
}
}

复制代码

/**
* 客户端
*/
public class Client {
public static void main(String[] args) {
String userName = "user name";
String userNumber = "user number";
//使用静态代理的模式实现代理，此时在类加载的时候就会创建该对象
UserMapperInterfaceProxy proxy = new UserMapperInterfaceProxy(new UserMapperInterfaceImpl());
proxy.save(userName, userNumber);
System.out.println("静态代理实现的类名：" + proxy.getClass().getName());
//使用动态代理的模式实现代理功能，在类加载的时候不会创建对象，在运行过程中才会去创建对象并调用对象的方法
ProxyFactory proxyFactory = new ProxyFactory(new UserMapperInterfaceImpl());
IUserMapperInterface targetInstance = (IUserMapperInterface) proxyFactory.getTargetInstance();
targetInstance.save(userName, userNumber);
System.out.println("动态代理实现的类名：" + targetInstance.getClass().getName());
}
}

复制代码

<dependency>
<groupId>cglib</groupId>
<artifactId>cglib</artifactId>
<version>3.3.0</version>
</dependency>

复制代码

/**
* CGLib方式实现代理的目标类
*/
public class CGLibTargetClass {
public void targetMethod(String userName, String userNumber) {
System.out.println("CGLibTargetClass targetMethod");
System.out.println("保存用户信息：username=" + userName + ",usernumber=" + userNumber);
}
}

复制代码

public class CGLibProxyIntercept implements MethodInterceptor {
@Override
public Object intercept(Object o, Method method, Object[] objects, MethodProxy methodProxy) throws Throwable {
System.out.println("保存用户信息前开启事务");
System.out.println(objects.toString());
System.out.println(o.getClass().getName());
methodProxy.invokeSuper(o, objects);
System.out.println("保存用户信息后提交事务");
return o;
}
}

复制代码