Spring5源码(36)-SpringAop创建代理(二)

简介: Spring5源码(36)-SpringAop创建代理(二)


上一篇中的分析已经可以获取到适合给定bean的所有增强,接下来就是创建代理了。

/**
 * 如果需要则包装该bean,例如该bean可以被代理
 * Wrap the given bean if necessary, i.e. if it is eligible for being proxied.
 * @param bean the raw bean instance
 * @param beanName the name of the bean
 * @param cacheKey the cache key for metadata access
 * @return a proxy wrapping the bean, or the raw bean instance as-is
 */
protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey) {
    // 1、如果已经处理过或者不需要创建代理,则返回
    if (StringUtils.hasLength(beanName) && this.targetSourcedBeans.contains(beanName)) {
        return bean;
    }
    if (Boolean.FALSE.equals(this.advisedBeans.get(cacheKey))) {
        return bean;
    }
    if (isInfrastructureClass(bean.getClass()) || shouldSkip(bean.getClass(), beanName)) {
        this.advisedBeans.put(cacheKey, Boolean.FALSE);
        return bean;
    }
    // 2、创建代理
    // 2.1 根据指定的bean获取所有的适合该bean的增强
    Object[] specificInterceptors = getAdvicesAndAdvisorsForBean(bean.getClass(), beanName, null);
    if (specificInterceptors != DO_NOT_PROXY) {
        // 2.2 为指定bean创建代理
        this.advisedBeans.put(cacheKey, Boolean.TRUE);
        Object proxy = createProxy(bean.getClass(), beanName, specificInterceptors, new SingletonTargetSource(bean));
        this.proxyTypes.put(cacheKey, proxy.getClass());
        return proxy;
    }
    // 3、缓存
    this.advisedBeans.put(cacheKey, Boolean.FALSE);
    return bean;
}
1.创建代理流程分析

/**
 * 为给定的bean创建代理
 * Create an AOP proxy for the given bean.
 * @param beanClass the class of the bean
 * @param beanName the name of the bean
 * @param specificInterceptors the set of interceptors that is
 * specific to this bean (may be empty, but not null)
 * @param targetSource the TargetSource for the proxy,
 * already pre-configured to access the bean
 * @return the AOP proxy for the bean
 * @see #buildAdvisors
 */
protected Object createProxy(Class<?> beanClass,
                             @Nullable String beanName,
                             @Nullable Object[] specificInterceptors,
                             TargetSource targetSource) {
    // 1、当前beanFactory是ConfigurableListableBeanFactory类型,则尝试暴露当前bean的target class
    if (this.beanFactory instanceof ConfigurableListableBeanFactory) {
        AutoProxyUtils.exposeTargetClass((ConfigurableListableBeanFactory) this.beanFactory, beanName, beanClass);
    }
    // 2、创建ProxyFactory并配置
    ProxyFactory proxyFactory = new ProxyFactory();
    proxyFactory.copyFrom(this);
    // 是否直接代理目标类以及接口
    if (!proxyFactory.isProxyTargetClass()) {
        // 确定给定bean是否应该用它的目标类而不是接口进行代理
        if (shouldProxyTargetClass(beanClass, beanName)) {
            proxyFactory.setProxyTargetClass(true);
        }
        // 检查给定bean类上的接口,如果合适的话,将它们应用到ProxyFactory。即添加代理接口
        else {
            evaluateProxyInterfaces(beanClass, proxyFactory);
        }
    }
    // 3、确定给定bean的advisors,包括特定的拦截器和公共拦截器,是否适配Advisor接口。
    Advisor[] advisors = buildAdvisors(beanName, specificInterceptors);
    // 设置增强
    proxyFactory.addAdvisors(advisors);
    // 设置代理目标
    proxyFactory.setTargetSource(targetSource);
    // 定制proxyFactory(空的模板方法,可在子类中自己定制)
    customizeProxyFactory(proxyFactory);
    // 锁定proxyFactory
    proxyFactory.setFrozen(this.freezeProxy);
    if (advisorsPreFiltered()) {
        proxyFactory.setPreFiltered(true);
    }
    // 4、创建代理
    return proxyFactory.getProxy(getProxyClassLoader());
}

具体的流程处理,代码注释里已经写的很清楚了,接下来看第四步,创建代理的具体过程。

public Object getProxy(@Nullable ClassLoader classLoader) {
    return createAopProxy().getProxy(classLoader);
}
protected final synchronized AopProxy createAopProxy() {
    if (!this.active) {
        activate();
    }
    return getAopProxyFactory().createAopProxy(this);
}

从上面的代码可以看到,创建代理的具体工作委托给了AopProxyFactory的createAopProxy方法。

/**
 * 创建代理
 * 1、config.isOptimize():判断通过CGLIB创建的代理是否使用了优化策略
 * 2、config.isProxyTargetClass():是否配置了proxy-target-class为true
 * 3、hasNoUserSuppliedProxyInterfaces(config):是否存在代理接口
 * 4、targetClass.isInterface()-->目标类是否为接口
 * 5、Proxy.isProxyClass-->如果targetClass类是代理类,则返回true,否则返回false。
 *
 * @param config the AOP configuration in the form of an AdvisedSupport object
 * @return
 * @throws AopConfigException
 */
@Override
public AopProxy createAopProxy(AdvisedSupport config) throws AopConfigException {
    // 1、判断是否需要创建CGLIB动态代理
    if (config.isOptimize() || config.isProxyTargetClass() || hasNoUserSuppliedProxyInterfaces(config)) {
        Class<?> targetClass = config.getTargetClass();
        if (targetClass == null) {
            throw new AopConfigException("TargetSource cannot determine target class: " +
                    "Either an interface or a target is required for proxy creation.");
        }
        // todo 这里有疑问 即
        // targetClass.isInterface()
        // Proxy.isProxyClass(targetClass)
        // 什么情况下会生效
        if (targetClass.isInterface() || Proxy.isProxyClass(targetClass)) {
            // 创建jdk动态代理
            return new JdkDynamicAopProxy(config);
        }
        // 创建CGLIB动态代理
        return new ObjenesisCglibAopProxy(config);
    }
    // 2、默认创建JDK动态代理
    else {
        return new JdkDynamicAopProxy(config);
    }
}

这里我们终于看到了判断CGLIB和JDK动态代理的判断条件,这也是面试会碰到的一个常见的问题。

我们先分析第一个if判断里的条件:

  • config.isOptimize():判断通过CGLIB创建的代理是否使用了优化策略
    该条件取值于ProxyConfig类的optimize属性。此属性标记是否对代理进行优化。启动优化通常意味着在代理对象被创建后,增强的修改将不会生效,因此默认值为false。如果exposeProxy设置为true,即使optimize为true也会被忽略。
  • config.isProxyTargetClass():是否配置了proxy-target-class为true
    该条件取值于ProxyConfig类的proxyTargetClass属性。此属性标记是否直接对目标类进行代理,而不是通过接口产生代理。
  • hasNoUserSuppliedProxyInterfaces(config):是否存在代理接口

满足以上三者条件的任何一个,则会考虑开启CGLIB动态代理,但是在该if条件里还有另外一层判断 targetClass.isInterface() || Proxy.isProxyClass(targetClass),即如果目标类本身就是一个接口,或者目标类是由Proxy.newProxyInstance()Proxy.getProxyClass()生成时,则依然采用jdk动态代理。(关于这两种情况的实例,网上没有找到例子,了解的同学可以留言哈!

到这里,代理的创建过程勉强的分析完了。。。,接下来我们看获取代理的过程。

2.获取CGLIB动态代理

public Object getProxy(@Nullable ClassLoader classLoader) {
    logger.info("Creating CGLIB proxy: target source is " + this.advised.getTargetSource());
    try {
        Class<?> rootClass = this.advised.getTargetClass();
        Class<?> proxySuperClass = rootClass;
        if (ClassUtils.isCglibProxyClass(rootClass)) {
            proxySuperClass = rootClass.getSuperclass();
            Class<?>[] additionalInterfaces = rootClass.getInterfaces();
            for (Class<?> additionalInterface : additionalInterfaces) {
                this.advised.addInterface(additionalInterface);
            }
        }
        // Validate the class, writing log messages as necessary.
        validateClassIfNecessary(proxySuperClass, classLoader);
        // 新建并配置Enhancer
        Enhancer enhancer = createEnhancer();
        if (classLoader != null) {
            enhancer.setClassLoader(classLoader);
            if (classLoader instanceof SmartClassLoader &&
                    ((SmartClassLoader) classLoader).isClassReloadable(proxySuperClass)) {
                enhancer.setUseCache(false);
            }
        }
        enhancer.setSuperclass(proxySuperClass);
        enhancer.setInterfaces(AopProxyUtils.completeProxiedInterfaces(this.advised));
        enhancer.setNamingPolicy(SpringNamingPolicy.INSTANCE);
        enhancer.setStrategy(new ClassLoaderAwareUndeclaredThrowableStrategy(classLoader));
        Callback[] callbacks = getCallbacks(rootClass);
        Class<?>[] types = new Class<?>[callbacks.length];
        for (int x = 0; x < types.length; x++) {
            types[x] = callbacks[x].getClass();
        }
        // fixedInterceptorMap only populated at this point, after getCallbacks call above
        enhancer.setCallbackFilter(new ProxyCallbackFilter(this.advised.getConfigurationOnlyCopy(), this.fixedInterceptorMap, this.fixedInterceptorOffset));
        enhancer.setCallbackTypes(types);
        // Generate the proxy class and create a proxy instance.
        // 生成代理类并创建代理实例
        return createProxyClassAndInstance(enhancer, callbacks);
    }
    catch (CodeGenerationException | IllegalArgumentException ex) {
        throw new AopConfigException("Could not generate CGLIB subclass of " + this.advised.getTargetClass() +
                ": Common causes of this problem include using a final class or a non-visible class",
                ex);
    }
    catch (Throwable ex) {
        // TargetSource.getTarget() failed
        throw new AopConfigException("Unexpected AOP exception", ex);
    }
}
3.获取JDK动态代理

public Object getProxy(@Nullable ClassLoader classLoader) {
    logger.info("Creating JDK dynamic proxy: target source is " + this.advised.getTargetSource());
    // 确定用于给定AOP配置的代理的完整接口集。
    Class<?>[] proxiedInterfaces = AopProxyUtils.completeProxiedInterfaces(this.advised, true);
    // 判断被代理接口有没有重写equals和hashCode方法
    findDefinedEqualsAndHashCodeMethods(proxiedInterfaces);
    // 为接口创建代理
    return Proxy.newProxyInstance(classLoader, proxiedInterfaces, this);
}
4.总结

代理的具体创建过程与我们之前篇幅中分析的过程大致相同,这里不详细的分析了,感兴趣的同学,可以自己跟踪调试一下代码。

另外在本篇中还有一个疑问就是判断创建代理类型里的 targetClass.isInterface() || Proxy.isProxyClass(targetClass),这句话会在什么样的场景下生效,知道的同学请留言,万分感激。。



作者:闲来也无事

链接:https://www.jianshu.com/p/ee41c5fee6ff

来源:简书

著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

上一篇中的分析已经可以获取到适合给定bean的所有增强,接下来就是创建代理了。

/**
 * 如果需要则包装该bean,例如该bean可以被代理
 * Wrap the given bean if necessary, i.e. if it is eligible for being proxied.
 * @param bean the raw bean instance
 * @param beanName the name of the bean
 * @param cacheKey the cache key for metadata access
 * @return a proxy wrapping the bean, or the raw bean instance as-is
 */
protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey) {
    // 1、如果已经处理过或者不需要创建代理,则返回
    if (StringUtils.hasLength(beanName) && this.targetSourcedBeans.contains(beanName)) {
        return bean;
    }
    if (Boolean.FALSE.equals(this.advisedBeans.get(cacheKey))) {
        return bean;
    }
    if (isInfrastructureClass(bean.getClass()) || shouldSkip(bean.getClass(), beanName)) {
        this.advisedBeans.put(cacheKey, Boolean.FALSE);
        return bean;
    }
    // 2、创建代理
    // 2.1 根据指定的bean获取所有的适合该bean的增强
    Object[] specificInterceptors = getAdvicesAndAdvisorsForBean(bean.getClass(), beanName, null);
    if (specificInterceptors != DO_NOT_PROXY) {
        // 2.2 为指定bean创建代理
        this.advisedBeans.put(cacheKey, Boolean.TRUE);
        Object proxy = createProxy(bean.getClass(), beanName, specificInterceptors, new SingletonTargetSource(bean));
        this.proxyTypes.put(cacheKey, proxy.getClass());
        return proxy;
    }
    // 3、缓存
    this.advisedBeans.put(cacheKey, Boolean.FALSE);
    return bean;
}
1.创建代理流程分析

/**
 * 为给定的bean创建代理
 * Create an AOP proxy for the given bean.
 * @param beanClass the class of the bean
 * @param beanName the name of the bean
 * @param specificInterceptors the set of interceptors that is
 * specific to this bean (may be empty, but not null)
 * @param targetSource the TargetSource for the proxy,
 * already pre-configured to access the bean
 * @return the AOP proxy for the bean
 * @see #buildAdvisors
 */
protected Object createProxy(Class<?> beanClass,
                             @Nullable String beanName,
                             @Nullable Object[] specificInterceptors,
                             TargetSource targetSource) {
    // 1、当前beanFactory是ConfigurableListableBeanFactory类型,则尝试暴露当前bean的target class
    if (this.beanFactory instanceof ConfigurableListableBeanFactory) {
        AutoProxyUtils.exposeTargetClass((ConfigurableListableBeanFactory) this.beanFactory, beanName, beanClass);
    }
    // 2、创建ProxyFactory并配置
    ProxyFactory proxyFactory = new ProxyFactory();
    proxyFactory.copyFrom(this);
    // 是否直接代理目标类以及接口
    if (!proxyFactory.isProxyTargetClass()) {
        // 确定给定bean是否应该用它的目标类而不是接口进行代理
        if (shouldProxyTargetClass(beanClass, beanName)) {
            proxyFactory.setProxyTargetClass(true);
        }
        // 检查给定bean类上的接口,如果合适的话,将它们应用到ProxyFactory。即添加代理接口
        else {
            evaluateProxyInterfaces(beanClass, proxyFactory);
        }
    }
    // 3、确定给定bean的advisors,包括特定的拦截器和公共拦截器,是否适配Advisor接口。
    Advisor[] advisors = buildAdvisors(beanName, specificInterceptors);
    // 设置增强
    proxyFactory.addAdvisors(advisors);
    // 设置代理目标
    proxyFactory.setTargetSource(targetSource);
    // 定制proxyFactory(空的模板方法,可在子类中自己定制)
    customizeProxyFactory(proxyFactory);
    // 锁定proxyFactory
    proxyFactory.setFrozen(this.freezeProxy);
    if (advisorsPreFiltered()) {
        proxyFactory.setPreFiltered(true);
    }
    // 4、创建代理
    return proxyFactory.getProxy(getProxyClassLoader());
}

具体的流程处理,代码注释里已经写的很清楚了,接下来看第四步,创建代理的具体过程。

public Object getProxy(@Nullable ClassLoader classLoader) {
    return createAopProxy().getProxy(classLoader);
}
protected final synchronized AopProxy createAopProxy() {
    if (!this.active) {
        activate();
    }
    return getAopProxyFactory().createAopProxy(this);
}

从上面的代码可以看到,创建代理的具体工作委托给了AopProxyFactory的createAopProxy方法。

/**
 * 创建代理
 * 1、config.isOptimize():判断通过CGLIB创建的代理是否使用了优化策略
 * 2、config.isProxyTargetClass():是否配置了proxy-target-class为true
 * 3、hasNoUserSuppliedProxyInterfaces(config):是否存在代理接口
 * 4、targetClass.isInterface()-->目标类是否为接口
 * 5、Proxy.isProxyClass-->如果targetClass类是代理类,则返回true,否则返回false。
 *
 * @param config the AOP configuration in the form of an AdvisedSupport object
 * @return
 * @throws AopConfigException
 */
@Override
public AopProxy createAopProxy(AdvisedSupport config) throws AopConfigException {
    // 1、判断是否需要创建CGLIB动态代理
    if (config.isOptimize() || config.isProxyTargetClass() || hasNoUserSuppliedProxyInterfaces(config)) {
        Class<?> targetClass = config.getTargetClass();
        if (targetClass == null) {
            throw new AopConfigException("TargetSource cannot determine target class: " +
                    "Either an interface or a target is required for proxy creation.");
        }
        // todo 这里有疑问 即
        // targetClass.isInterface()
        // Proxy.isProxyClass(targetClass)
        // 什么情况下会生效
        if (targetClass.isInterface() || Proxy.isProxyClass(targetClass)) {
            // 创建jdk动态代理
            return new JdkDynamicAopProxy(config);
        }
        // 创建CGLIB动态代理
        return new ObjenesisCglibAopProxy(config);
    }
    // 2、默认创建JDK动态代理
    else {
        return new JdkDynamicAopProxy(config);
    }
}

这里我们终于看到了判断CGLIB和JDK动态代理的判断条件,这也是面试会碰到的一个常见的问题。

我们先分析第一个if判断里的条件:

  • config.isOptimize():判断通过CGLIB创建的代理是否使用了优化策略
    该条件取值于ProxyConfig类的optimize属性。此属性标记是否对代理进行优化。启动优化通常意味着在代理对象被创建后,增强的修改将不会生效,因此默认值为false。如果exposeProxy设置为true,即使optimize为true也会被忽略。
  • config.isProxyTargetClass():是否配置了proxy-target-class为true
    该条件取值于ProxyConfig类的proxyTargetClass属性。此属性标记是否直接对目标类进行代理,而不是通过接口产生代理。
  • hasNoUserSuppliedProxyInterfaces(config):是否存在代理接口

满足以上三者条件的任何一个,则会考虑开启CGLIB动态代理,但是在该if条件里还有另外一层判断 targetClass.isInterface() || Proxy.isProxyClass(targetClass),即如果目标类本身就是一个接口,或者目标类是由Proxy.newProxyInstance()Proxy.getProxyClass()生成时,则依然采用jdk动态代理。(关于这两种情况的实例,网上没有找到例子,了解的同学可以留言哈!

到这里,代理的创建过程勉强的分析完了。。。,接下来我们看获取代理的过程。

2.获取CGLIB动态代理

public Object getProxy(@Nullable ClassLoader classLoader) {
    logger.info("Creating CGLIB proxy: target source is " + this.advised.getTargetSource());
    try {
        Class<?> rootClass = this.advised.getTargetClass();
        Class<?> proxySuperClass = rootClass;
        if (ClassUtils.isCglibProxyClass(rootClass)) {
            proxySuperClass = rootClass.getSuperclass();
            Class<?>[] additionalInterfaces = rootClass.getInterfaces();
            for (Class<?> additionalInterface : additionalInterfaces) {
                this.advised.addInterface(additionalInterface);
            }
        }
        // Validate the class, writing log messages as necessary.
        validateClassIfNecessary(proxySuperClass, classLoader);
        // 新建并配置Enhancer
        Enhancer enhancer = createEnhancer();
        if (classLoader != null) {
            enhancer.setClassLoader(classLoader);
            if (classLoader instanceof SmartClassLoader &&
                    ((SmartClassLoader) classLoader).isClassReloadable(proxySuperClass)) {
                enhancer.setUseCache(false);
            }
        }
        enhancer.setSuperclass(proxySuperClass);
        enhancer.setInterfaces(AopProxyUtils.completeProxiedInterfaces(this.advised));
        enhancer.setNamingPolicy(SpringNamingPolicy.INSTANCE);
        enhancer.setStrategy(new ClassLoaderAwareUndeclaredThrowableStrategy(classLoader));
        Callback[] callbacks = getCallbacks(rootClass);
        Class<?>[] types = new Class<?>[callbacks.length];
        for (int x = 0; x < types.length; x++) {
            types[x] = callbacks[x].getClass();
        }
        // fixedInterceptorMap only populated at this point, after getCallbacks call above
        enhancer.setCallbackFilter(new ProxyCallbackFilter(this.advised.getConfigurationOnlyCopy(), this.fixedInterceptorMap, this.fixedInterceptorOffset));
        enhancer.setCallbackTypes(types);
        // Generate the proxy class and create a proxy instance.
        // 生成代理类并创建代理实例
        return createProxyClassAndInstance(enhancer, callbacks);
    }
    catch (CodeGenerationException | IllegalArgumentException ex) {
        throw new AopConfigException("Could not generate CGLIB subclass of " + this.advised.getTargetClass() +
                ": Common causes of this problem include using a final class or a non-visible class",
                ex);
    }
    catch (Throwable ex) {
        // TargetSource.getTarget() failed
        throw new AopConfigException("Unexpected AOP exception", ex);
    }
}
3.获取JDK动态代理

public Object getProxy(@Nullable ClassLoader classLoader) {
    logger.info("Creating JDK dynamic proxy: target source is " + this.advised.getTargetSource());
    // 确定用于给定AOP配置的代理的完整接口集。
    Class<?>[] proxiedInterfaces = AopProxyUtils.completeProxiedInterfaces(this.advised, true);
    // 判断被代理接口有没有重写equals和hashCode方法
    findDefinedEqualsAndHashCodeMethods(proxiedInterfaces);
    // 为接口创建代理
    return Proxy.newProxyInstance(classLoader, proxiedInterfaces, this);
}
4.总结

代理的具体创建过程与我们之前篇幅中分析的过程大致相同,这里不详细的分析了,感兴趣的同学,可以自己跟踪调试一下代码。

另外在本篇中还有一个疑问就是判断创建代理类型里的 targetClass.isInterface() || Proxy.isProxyClass(targetClass),这句话会在什么样的场景下生效,知道的同学请留言,万分感激。。



作者:闲来也无事

链接:https://www.jianshu.com/p/ee41c5fee6ff

来源:简书

著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

上一篇中的分析已经可以获取到适合给定bean的所有增强,接下来就是创建代理了。

/**
 * 如果需要则包装该bean,例如该bean可以被代理
 * Wrap the given bean if necessary, i.e. if it is eligible for being proxied.
 * @param bean the raw bean instance
 * @param beanName the name of the bean
 * @param cacheKey the cache key for metadata access
 * @return a proxy wrapping the bean, or the raw bean instance as-is
 */
protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey) {
    // 1、如果已经处理过或者不需要创建代理,则返回
    if (StringUtils.hasLength(beanName) && this.targetSourcedBeans.contains(beanName)) {
        return bean;
    }
    if (Boolean.FALSE.equals(this.advisedBeans.get(cacheKey))) {
        return bean;
    }
    if (isInfrastructureClass(bean.getClass()) || shouldSkip(bean.getClass(), beanName)) {
        this.advisedBeans.put(cacheKey, Boolean.FALSE);
        return bean;
    }
    // 2、创建代理
    // 2.1 根据指定的bean获取所有的适合该bean的增强
    Object[] specificInterceptors = getAdvicesAndAdvisorsForBean(bean.getClass(), beanName, null);
    if (specificInterceptors != DO_NOT_PROXY) {
        // 2.2 为指定bean创建代理
        this.advisedBeans.put(cacheKey, Boolean.TRUE);
        Object proxy = createProxy(bean.getClass(), beanName, specificInterceptors, new SingletonTargetSource(bean));
        this.proxyTypes.put(cacheKey, proxy.getClass());
        return proxy;
    }
    // 3、缓存
    this.advisedBeans.put(cacheKey, Boolean.FALSE);
    return bean;
}
1.创建代理流程分析

/**
 * 为给定的bean创建代理
 * Create an AOP proxy for the given bean.
 * @param beanClass the class of the bean
 * @param beanName the name of the bean
 * @param specificInterceptors the set of interceptors that is
 * specific to this bean (may be empty, but not null)
 * @param targetSource the TargetSource for the proxy,
 * already pre-configured to access the bean
 * @return the AOP proxy for the bean
 * @see #buildAdvisors
 */
protected Object createProxy(Class<?> beanClass,
                             @Nullable String beanName,
                             @Nullable Object[] specificInterceptors,
                             TargetSource targetSource) {
    // 1、当前beanFactory是ConfigurableListableBeanFactory类型,则尝试暴露当前bean的target class
    if (this.beanFactory instanceof ConfigurableListableBeanFactory) {
        AutoProxyUtils.exposeTargetClass((ConfigurableListableBeanFactory) this.beanFactory, beanName, beanClass);
    }
    // 2、创建ProxyFactory并配置
    ProxyFactory proxyFactory = new ProxyFactory();
    proxyFactory.copyFrom(this);
    // 是否直接代理目标类以及接口
    if (!proxyFactory.isProxyTargetClass()) {
        // 确定给定bean是否应该用它的目标类而不是接口进行代理
        if (shouldProxyTargetClass(beanClass, beanName)) {
            proxyFactory.setProxyTargetClass(true);
        }
        // 检查给定bean类上的接口,如果合适的话,将它们应用到ProxyFactory。即添加代理接口
        else {
            evaluateProxyInterfaces(beanClass, proxyFactory);
        }
    }
    // 3、确定给定bean的advisors,包括特定的拦截器和公共拦截器,是否适配Advisor接口。
    Advisor[] advisors = buildAdvisors(beanName, specificInterceptors);
    // 设置增强
    proxyFactory.addAdvisors(advisors);
    // 设置代理目标
    proxyFactory.setTargetSource(targetSource);
    // 定制proxyFactory(空的模板方法,可在子类中自己定制)
    customizeProxyFactory(proxyFactory);
    // 锁定proxyFactory
    proxyFactory.setFrozen(this.freezeProxy);
    if (advisorsPreFiltered()) {
        proxyFactory.setPreFiltered(true);
    }
    // 4、创建代理
    return proxyFactory.getProxy(getProxyClassLoader());
}

具体的流程处理,代码注释里已经写的很清楚了,接下来看第四步,创建代理的具体过程。

public Object getProxy(@Nullable ClassLoader classLoader) {
    return createAopProxy().getProxy(classLoader);
}
protected final synchronized AopProxy createAopProxy() {
    if (!this.active) {
        activate();
    }
    return getAopProxyFactory().createAopProxy(this);
}

从上面的代码可以看到,创建代理的具体工作委托给了AopProxyFactory的createAopProxy方法。

/**
 * 创建代理
 * 1、config.isOptimize():判断通过CGLIB创建的代理是否使用了优化策略
 * 2、config.isProxyTargetClass():是否配置了proxy-target-class为true
 * 3、hasNoUserSuppliedProxyInterfaces(config):是否存在代理接口
 * 4、targetClass.isInterface()-->目标类是否为接口
 * 5、Proxy.isProxyClass-->如果targetClass类是代理类,则返回true,否则返回false。
 *
 * @param config the AOP configuration in the form of an AdvisedSupport object
 * @return
 * @throws AopConfigException
 */
@Override
public AopProxy createAopProxy(AdvisedSupport config) throws AopConfigException {
    // 1、判断是否需要创建CGLIB动态代理
    if (config.isOptimize() || config.isProxyTargetClass() || hasNoUserSuppliedProxyInterfaces(config)) {
        Class<?> targetClass = config.getTargetClass();
        if (targetClass == null) {
            throw new AopConfigException("TargetSource cannot determine target class: " +
                    "Either an interface or a target is required for proxy creation.");
        }
        // todo 这里有疑问 即
        // targetClass.isInterface()
        // Proxy.isProxyClass(targetClass)
        // 什么情况下会生效
        if (targetClass.isInterface() || Proxy.isProxyClass(targetClass)) {
            // 创建jdk动态代理
            return new JdkDynamicAopProxy(config);
        }
        // 创建CGLIB动态代理
        return new ObjenesisCglibAopProxy(config);
    }
    // 2、默认创建JDK动态代理
    else {
        return new JdkDynamicAopProxy(config);
    }
}

这里我们终于看到了判断CGLIB和JDK动态代理的判断条件,这也是面试会碰到的一个常见的问题。

我们先分析第一个if判断里的条件:

  • config.isOptimize():判断通过CGLIB创建的代理是否使用了优化策略
    该条件取值于ProxyConfig类的optimize属性。此属性标记是否对代理进行优化。启动优化通常意味着在代理对象被创建后,增强的修改将不会生效,因此默认值为false。如果exposeProxy设置为true,即使optimize为true也会被忽略。
  • config.isProxyTargetClass():是否配置了proxy-target-class为true
    该条件取值于ProxyConfig类的proxyTargetClass属性。此属性标记是否直接对目标类进行代理,而不是通过接口产生代理。
  • hasNoUserSuppliedProxyInterfaces(config):是否存在代理接口

满足以上三者条件的任何一个,则会考虑开启CGLIB动态代理,但是在该if条件里还有另外一层判断 targetClass.isInterface() || Proxy.isProxyClass(targetClass),即如果目标类本身就是一个接口,或者目标类是由Proxy.newProxyInstance()Proxy.getProxyClass()生成时,则依然采用jdk动态代理。(关于这两种情况的实例,网上没有找到例子,了解的同学可以留言哈!

到这里,代理的创建过程勉强的分析完了。。。,接下来我们看获取代理的过程。

2.获取CGLIB动态代理

public Object getProxy(@Nullable ClassLoader classLoader) {
    logger.info("Creating CGLIB proxy: target source is " + this.advised.getTargetSource());
    try {
        Class<?> rootClass = this.advised.getTargetClass();
        Class<?> proxySuperClass = rootClass;
        if (ClassUtils.isCglibProxyClass(rootClass)) {
            proxySuperClass = rootClass.getSuperclass();
            Class<?>[] additionalInterfaces = rootClass.getInterfaces();
            for (Class<?> additionalInterface : additionalInterfaces) {
                this.advised.addInterface(additionalInterface);
            }
        }
        // Validate the class, writing log messages as necessary.
        validateClassIfNecessary(proxySuperClass, classLoader);
        // 新建并配置Enhancer
        Enhancer enhancer = createEnhancer();
        if (classLoader != null) {
            enhancer.setClassLoader(classLoader);
            if (classLoader instanceof SmartClassLoader &&
                    ((SmartClassLoader) classLoader).isClassReloadable(proxySuperClass)) {
                enhancer.setUseCache(false);
            }
        }
        enhancer.setSuperclass(proxySuperClass);
        enhancer.setInterfaces(AopProxyUtils.completeProxiedInterfaces(this.advised));
        enhancer.setNamingPolicy(SpringNamingPolicy.INSTANCE);
        enhancer.setStrategy(new ClassLoaderAwareUndeclaredThrowableStrategy(classLoader));
        Callback[] callbacks = getCallbacks(rootClass);
        Class<?>[] types = new Class<?>[callbacks.length];
        for (int x = 0; x < types.length; x++) {
            types[x] = callbacks[x].getClass();
        }
        // fixedInterceptorMap only populated at this point, after getCallbacks call above
        enhancer.setCallbackFilter(new ProxyCallbackFilter(this.advised.getConfigurationOnlyCopy(), this.fixedInterceptorMap, this.fixedInterceptorOffset));
        enhancer.setCallbackTypes(types);
        // Generate the proxy class and create a proxy instance.
        // 生成代理类并创建代理实例
        return createProxyClassAndInstance(enhancer, callbacks);
    }
    catch (CodeGenerationException | IllegalArgumentException ex) {
        throw new AopConfigException("Could not generate CGLIB subclass of " + this.advised.getTargetClass() +
                ": Common causes of this problem include using a final class or a non-visible class",
                ex);
    }
    catch (Throwable ex) {
        // TargetSource.getTarget() failed
        throw new AopConfigException("Unexpected AOP exception", ex);
    }
}
3.获取JDK动态代理

public Object getProxy(@Nullable ClassLoader classLoader) {
    logger.info("Creating JDK dynamic proxy: target source is " + this.advised.getTargetSource());
    // 确定用于给定AOP配置的代理的完整接口集。
    Class<?>[] proxiedInterfaces = AopProxyUtils.completeProxiedInterfaces(this.advised, true);
    // 判断被代理接口有没有重写equals和hashCode方法
    findDefinedEqualsAndHashCodeMethods(proxiedInterfaces);
    // 为接口创建代理
    return Proxy.newProxyInstance(classLoader, proxiedInterfaces, this);
}
4.总结

代理的具体创建过程与我们之前篇幅中分析的过程大致相同,这里不详细的分析了,感兴趣的同学,可以自己跟踪调试一下代码。

另外在本篇中还有一个疑问就是判断创建代理类型里的 targetClass.isInterface() || Proxy.isProxyClass(targetClass),这句话会在什么样的场景下生效,知道的同学请留言,万分感激。。


目录
相关文章
|
2月前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
121 2
|
2月前
|
数据采集 监控 前端开发
二级公立医院绩效考核系统源码,B/S架构,前后端分别基于Spring Boot和Avue框架
医院绩效管理系统通过与HIS系统的无缝对接,实现数据网络化采集、评价结果透明化管理及奖金分配自动化生成。系统涵盖科室和个人绩效考核、医疗质量考核、数据采集、绩效工资核算、收支核算、工作量统计、单项奖惩等功能,提升绩效评估的全面性、准确性和公正性。技术栈采用B/S架构,前后端分别基于Spring Boot和Avue框架。
126 5
|
23天前
|
监控 JavaScript 数据可视化
建筑施工一体化信息管理平台源码,支持微服务架构,采用Java、Spring Cloud、Vue等技术开发。
智慧工地云平台是专为建筑施工领域打造的一体化信息管理平台,利用大数据、云计算、物联网等技术,实现施工区域各系统数据汇总与可视化管理。平台涵盖人员、设备、物料、环境等关键因素的实时监控与数据分析,提供远程指挥、决策支持等功能,提升工作效率,促进产业信息化发展。系统由PC端、APP移动端及项目、监管、数据屏三大平台组成,支持微服务架构,采用Java、Spring Cloud、Vue等技术开发。
|
1月前
|
存储 缓存 Java
Spring面试必问:手写Spring IoC 循环依赖底层源码剖析
在Spring框架中,IoC(Inversion of Control,控制反转)是一个核心概念,它允许容器管理对象的生命周期和依赖关系。然而,在实际应用中,我们可能会遇到对象间的循环依赖问题。本文将深入探讨Spring如何解决IoC中的循环依赖问题,并通过手写源码的方式,让你对其底层原理有一个全新的认识。
67 2
|
2月前
|
前端开发 Java 开发者
Spring生态学习路径与源码深度探讨
【11月更文挑战第13天】Spring框架作为Java企业级开发中的核心框架,其丰富的生态系统和强大的功能吸引了无数开发者的关注。学习Spring生态不仅仅是掌握Spring Framework本身,更需要深入理解其周边组件和工具,以及源码的底层实现逻辑。本文将从Spring生态的学习路径入手,详细探讨如何系统地学习Spring,并深入解析各个重点的底层实现逻辑。
81 9
|
10天前
|
XML Java 应用服务中间件
Spring Boot 两种部署到服务器的方式
本文介绍了Spring Boot项目的两种部署方式:jar包和war包。Jar包方式使用内置Tomcat,只需配置JDK 1.8及以上环境,通过`nohup java -jar`命令后台运行,并开放服务器端口即可访问。War包则需将项目打包后放入外部Tomcat的webapps目录,修改启动类继承`SpringBootServletInitializer`并调整pom.xml中的打包类型为war,最后启动Tomcat访问应用。两者各有优劣,jar包更简单便捷,而war包适合传统部署场景。需要注意的是,war包部署时,内置Tomcat的端口配置不会生效。
105 17
Spring Boot 两种部署到服务器的方式
|
10天前
|
Dart 前端开发 JavaScript
springboot自动配置原理
Spring Boot 自动配置原理:通过 `@EnableAutoConfiguration` 开启自动配置,扫描 `META-INF/spring.factories` 下的配置类,省去手动编写配置文件。使用 `@ConditionalXXX` 注解判断配置类是否生效,导入对应的 starter 后自动配置生效。通过 `@EnableConfigurationProperties` 加载配置属性,默认值与配置文件中的值结合使用。总结来说,Spring Boot 通过这些机制简化了开发配置流程,提升了开发效率。
45 17
springboot自动配置原理
|
15天前
|
XML JavaScript Java
SpringBoot集成Shiro权限+Jwt认证
本文主要描述如何快速基于SpringBoot 2.5.X版本集成Shiro+JWT框架,让大家快速实现无状态登陆和接口权限认证主体框架,具体业务细节未实现,大家按照实际项目补充。
62 11
|
17天前
|
缓存 安全 Java
Spring Boot 3 集成 Spring Security + JWT
本文详细介绍了如何使用Spring Boot 3和Spring Security集成JWT,实现前后端分离的安全认证概述了从入门到引入数据库,再到使用JWT的完整流程。列举了项目中用到的关键依赖,如MyBatis-Plus、Hutool等。简要提及了系统配置表、部门表、字典表等表结构。使用Hutool-jwt工具类进行JWT校验。配置忽略路径、禁用CSRF、添加JWT校验过滤器等。实现登录接口,返回token等信息。
199 12
|
1月前
|
Java 数据库连接 Maven
最新版 | 深入剖析SpringBoot3源码——分析自动装配原理(面试常考)
自动装配是现在面试中常考的一道面试题。本文基于最新的 SpringBoot 3.3.3 版本的源码来分析自动装配的原理,并在文未说明了SpringBoot2和SpringBoot3的自动装配源码中区别,以及面试回答的拿分核心话术。
最新版 | 深入剖析SpringBoot3源码——分析自动装配原理(面试常考)