Java动态代理原理入门与面试话术汇总

// 1. 定义接口
public interface UserService {
    void saveUser(String name);
    void deleteUser(Long id);
}
​
// 2. 真正的实现类
public class UserServiceImpl implements UserService {
    @Override
    public void saveUser(String name) {
        System.out.println("保存用户：" + name);
    }
​
    @Override
    public void deleteUser(Long id) {
        System.out.println("删除用户：" + id);
    }
}
​
// 3. 代理类（需要手动写，代理谁就写谁的代理）
public class UserServiceProxy implements UserService {
    private UserService target;  // 持有真正的实现类
​
    public UserServiceProxy(UserService target) {
        this.target = target;
    }
​
    @Override
    public void saveUser(String name) {
        System.out.println("【代理】开始执行");
        long start = System.currentTimeMillis();
        target.saveUser(name);  // 调用真正的实现
        long cost = System.currentTimeMillis() - start;
        System.out.println("【代理】执行完成，耗时 " + cost + "ms");
    }
​
    @Override
    public void deleteUser(Long id) {
        System.out.println("【代理】开始执行");
        target.deleteUser(id);
        System.out.println("【代理】执行完成");
    }
}
​
// 4. 使用
public class Main {
    public static void main(String[] args) {
        UserService target = new UserServiceImpl();
        UserService proxy = new UserServiceProxy(target);
        proxy.saveUser("张三");
    }
}

java.lang.reflect.Proxy（创建代理对象）
java.lang.reflect.InvocationHandler（拦截调用的处理器）

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
​
public class JdkProxyDemo {
​
    public static void main(String[] args) {
​
        // 1. 创建目标对象
        UserService target = new UserServiceImpl();
​
        // 2. 创建代理对象
        UserService proxy = (UserService) Proxy.newProxyInstance(
            target.getClass().getClassLoader(),      // 类加载器
            target.getClass().getInterfaces(),        // 要代理的接口
            new MyInvocationHandler(target)           // 调用处理器
        );
​
        // 3. 调用代理对象的方法
        proxy.saveUser("张三");
        proxy.deleteUser(1L);
    }
}
​
// 3. 定义调用处理器（核心！拦截所有方法调用）
class MyInvocationHandler implements InvocationHandler {
​
    private Object target;  // 被代理的目标对象
​
    public MyInvocationHandler(Object target) {
        this.target = target;
    }
​
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
​
        // --- 代理逻辑开始 ---
        String methodName = method.getName();
        System.out.println("【代理】方法开始：" + methodName);
        long start = System.currentTimeMillis();
        // --- 代理逻辑结束 ---
​
        // 调用真正的目标方法
        Object result = method.invoke(target, args);
​
        // --- 代理逻辑开始 ---
        long cost = System.currentTimeMillis() - start;
        System.out.println("【代理】方法结束：" + methodName + "，耗时 " + cost + "ms");
        // --- 代理逻辑结束 ---
​
        return result;
    }
}

// MyBatis 的 Mapper 是接口
public interface UserMapper {
    User selectById(Long id);
}
​
// JDK 动态代理要求：目标必须实现接口 ✅
// Mapper 恰好是接口 → 天然适合 JDK 动态代理
​
// MyBatis 内部大致是这样的
Object mapperProxy = Proxy.newProxyInstance(
    UserMapper.class.getClassLoader(),
    new Class[]{UserMapper.class},
    new MapperProxy(sqlSession)  // 拦截器
);
// 拿到的 mapperProxy 就是你可以直接用的 "Mapper 实现"

import net.sf.cglib.proxy.Enhancer;
import net.sf.cglib.proxy.MethodInterceptor;
import net.sf.cglib.proxy.MethodProxy;

import java.lang.reflect.Method;

public class CglibProxyDemo {

    public static void main(String[] args) {

        // 1. 创建 CGLIB 代理
        Enhancer enhancer = new Enhancer();
        enhancer.setSuperclass(UserServiceImpl.class);  // 父类是谁
        enhancer.setCallback(new MyMethodInterceptor()); // 拦截器

        // 2. 创建代理对象（子类）
        UserServiceImpl proxy = (UserServiceImpl) enhancer.create();

        // 3. 调用
        proxy.saveUser("张三");
    }
}

// 拦截器（类似 JDK 的 InvocationHandler）
class MyMethodInterceptor implements MethodInterceptor {

    @Override
    public Object intercept(Object obj, Method method, Object[] args, MethodProxy methodProxy)
            throws Throwable {

        System.out.println("【CGLIB 代理】方法开始：" + method.getName());
        long start = System.currentTimeMillis();

        // 调用父类的方法（不是 method.invoke）
        Object result = methodProxy.invokeSuper(obj, args);

        long cost = System.currentTimeMillis() - start;
        System.out.println("【CGLIB 代理】方法结束：" + method.getName() + "，耗时 " + cost + "ms");

        return result;
    }
}

// ========== JDK 动态代理 ==========
// 1. 目标必须有接口
public interface UserService { void save(String name); }
public class UserServiceImpl implements UserService { ... }

// 2. 用 Proxy.newProxyInstance
Object proxy = Proxy.newProxyInstance(
    classLoader,
    new Class[]{UserService.class},  // 接口
    new InvocationHandler() {
        public Object invoke(Object p, Method m, Object[] args) {
            // 拦截逻辑
            return m.invoke(target, args);  // 调目标方法
        }
    }
);

// ========== CGLIB 动态代理 ==========
// 1. 目标可以是普通类（不需要接口）
public class UserService { public void save(String name) { ... } }

// 2. 用 Enhancer
Enhancer enhancer = new Enhancer();
enhancer.setSuperclass(UserService.class);  // 父类
enhancer.setCallback(new MethodInterceptor() {
    public Object intercept(Object obj, Method m, Object[] args, MethodProxy mp) {
        // 拦截逻辑
        return mp.invokeSuper(obj, args);  // 调父类方法
    }
});
Object proxy = enhancer.create();

@Service
public class UserService {

    @Transactional  // Spring AOP 拦截这个方法
    public void saveUser(String name) {
        // 你的业务代码
        userMapper.insert(name);
    }
}

// 你写的代码（看起来像直接调）
userService.saveUser("张三");
// 实际执行的（代理拦截后）
@Transactional 开启
    → userService.saveUser("张三")  // 真正的业务方法
@Transactional 提交