漫谈代理模式

// 1.创建抽象主题角色
public interface ISubject {
    public void doSomeThing();
}
// 2. 创建真实主题角色
public class RealSubject implements ISubject{
    @Override
    public void doSomeThing() {
        PrintUtill.println("真正的对象做一些事情");
    }
}
// 3.创建代理主题角色
public class SubjectProxy implements ISubject{
    private ISubject subject;
    // 初始化时传入真实主题角色的引用
    public SubjectProxy(ISubject subject) {
        this.subject = subject;
    }

    @Override
    public void doSomeThing() {
        before();
        this.subject.doSomeThing();
        after();
    }

    private void before() {
        PrintUtill.println("真正对象执行操作之前的附加功能>>>>>>>>>");
    }

    private void after() {
        PrintUtill.println("真正对象执行操作之后的附加功能>>>>>>>>>");
    }

}
// 4. 客户端--用于调用测试
public class SubejctClient {
    public static void main(String[] args) {
        SubjectProxy subjectProxy = new SubjectProxy(new RealSubject());
        subjectProxy.doSomeThing();
    }
}

// 支付接口，
public interface PayService {
    void pay();
    void pay(int a);
}
// 微信支付实现
public class WXPayService implements PayService{
    @Override
    public void pay() {
        PrintUtill.println("微信支付>>>>>>WXPayService>>>>>>>>>pay>>>>>>>>>>>");
    }

    @Override
    public void pay(int a) {
        PrintUtill.println("微信支付>>>>>>WXPayService>>>>>>>>>pay>>>>>>>>>>>"+a);
    }
}
// 客户端
public class LoggerDynamicClient {
    public static void main(String[] args) {
      	// 用于生成在运行时产生的代理类--非必需
        System.getProperties().put("sun.misc.ProxyGenerator.saveGeneratedFiles","true");
        // 创建日志调度处理器
        LoggerDynamicProxyHandler proxy =  new LoggerDynamicProxyHandler();
      	// 为 微信支付 添加日志
        PayService pay = (PayService) proxy.getInstance(new WXPayService());
        pay.pay();
        PrintUtill.printlnRule();
        // 为 用户服务 添加日志 -实现与支付服务类似。
        BaseService userService = (BaseService) proxy.getInstance(new UserService());
        userService.add();
	// showProxyClass();
    }
    // 代理类文件生成方式一，可指定要生成的代理类以及代理类名称
    public static void showProxyClass() {
        String path = "./$Proxy0.class";
        // 生成字节码的方法，在运行时产生一个描述代理类的字节码byte[]数组。
        byte[] classFile = ProxyGenerator.generateProxyClass("$Proxy0",
                WXPayService.class.getInterfaces());
        FileOutputStream out = null;
        try {
            out = new FileOutputStream(path);
            out.write(classFile);
            out.flush();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                out.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

public class LoggerDynamicProxyHandler implements InvocationHandler {
    private SimpleDateFormat sdf = new SimpleDateFormat("YYYY-MM-DD hh:mm:ss");
    private Object target;
		
		// 返回一个实现了接口，并且代理了真实对象实例行为的对象
    public Object getInstance(Object target) {
        this.target = target;
        Class<?> clazz = target.getClass();
        // newProxyInstance 初始化代理，基于被代理者的类加载器、实现的接口，以及当前代理类
        // 返回一个实现了PayService接口的，并且代理了new WXPayService()实例行为的对象
        return Proxy.newProxyInstance(clazz.getClassLoader(),clazz.getInterfaces(),this);
    }
		// 用于实现代理的行为
		// proxy：动态生成的匿名代理类
		// method：调用的方法
		// args：真实主题类method的参数
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        before();
        Object obj = method.invoke(target,args);
        after();
        return obj;
    }

    private void before() {
        PrintUtill.println("日志动态代理开始>>>>>>>>>>>>>" + sdf.format(System.currentTimeMillis()) + ">>>>>>>>>>>");
    }

    private void after() {
        PrintUtill.println("日志动态代理完成>>>>>>>>>>>>>" + sdf.format(System.currentTimeMillis()) + ">>>>>>>>>>>");
    }
}

// 用于生成在运行时产生的代理类--非必需
System.getProperties().put("sun.misc.ProxyGenerator.saveGeneratedFiles","true");

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

// 客户端
public class LoggerCGlibProxyClient {
    public static void main(String[] args) {
        LoggerCGlibProxyInterceptor proxy = new LoggerCGlibProxyInterceptor();
        PayService pay = (PayService) proxy.getInstance(WXPayService.class);
        pay.pay();
    }
}
// 调度处理器接口实现
public class LoggerCGlibProxyInterceptor implements MethodInterceptor {
    public Object getInstance(Class target) {
      	// 创建一个字节码增强器,可以用来为无接口的类创建代理
        Enhancer enhancer = new Enhancer();
      	// 设置要代理的业务类（即：为下面生成的代理类指定父类）
        enhancer.setSuperclass(target);
      	// 设置回调方法实现类：调用被代理类的方法时，会通过调用该实现类的intercept的方法，从而实现代理的行为。
        enhancer.setCallback(this);
      	// create方法生成Target的代理类，并返回代理类的实例
        return enhancer.create();
    }
    @Override
    public Object intercept(Object obj, Method method, Object[] args, 
      MethodProxy proxy) throws Throwable {
        System.out.println("windcoder.com日志开始...");
        //代理类调用父类的方法
        proxy.invokeSuper(obj, args);
        System.out.println("windcoder.com日志结束...");
        return null;
    }
}

// 设置输出目录，方便之后查看CGLIB生成的class---第二个参数是路径，可自行修改
System.setProperty(DebuggingClassWriter.DEBUG_LOCATION_PROPERTY, "./tmp/");