溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

spring中代理的創(chuàng)建方法有哪些

發(fā)布時(shí)間:2021-10-13 11:58:57 來(lái)源:億速云 閱讀:129 作者:iii 欄目:編程語(yǔ)言

本篇內(nèi)容介紹了“spring中代理的創(chuàng)建方法有哪些”的有關(guān)知識(shí),在實(shí)際案例的操作過(guò)程中,不少人都會(huì)遇到這樣的困境,接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!

spring 中創(chuàng)建代理使用了 Jdk 和 Cglib 兩種方式創(chuàng)建,JdkDynamicAopProxyObjenesisCglibAopProxy,通過(guò)使用配置 AdvisedProxyConfig來(lái)管理配置,根據(jù)配置決定使用哪種方式創(chuàng)建代理,下面來(lái)介紹這幾個(gè)關(guān)鍵的類。

Advised

Advised 是一個(gè)管理 AOP 代理工廠配置的接口,在spring中的所有AopProxy都可以轉(zhuǎn)換為 Advised。

ProxyConfig

在 spring 中,使用 ProxyConfig 來(lái)配置代理創(chuàng)建屬性。

/**
 * 代理工廠的超類,用于統(tǒng)一管理代理工廠類的屬性。
 */
public class ProxyConfig implements Serializable {
   // true:使用子類代理,false:使用接口代理
   private boolean proxyTargetClass = false;
   // 啟動(dòng)代理優(yōu)化
   private boolean optimize = false;
   // 使用該代理工長(zhǎng)創(chuàng)建的代理是否可以轉(zhuǎn)換為 Advised,默認(rèn)為false:表示可以,
   // 如果為false,可以將bean轉(zhuǎn)換為Advised:Advised testBean  = (Advised) context.getBean("testBean");
   boolean opaque = false;
   // 將代理暴露出去,綁定到 ThreadLocal 的 currentProxy,用于代理類自己的方法調(diào)用自己的場(chǎng)景。
   boolean exposeProxy = false;
   // 凍結(jié)配置,true:不能修改該代理工長(zhǎng)的配置。
   private boolean frozen = false;
}

實(shí)現(xiàn)了ProxyConfig 的直接子類有4個(gè):

ScopedProxyFactoryBean、ProxyProcessorSupport、AbstractSingletonProxyFactoryBean、AdvisedSupport,這幾個(gè)類使用不同的方式來(lái)創(chuàng)建代理,但是最后還是會(huì)將創(chuàng)建代理的工作委托給 ProxyFactory,下面來(lái)查看4個(gè)直接子類的相關(guān)代碼。

  1. ScopedProxyFactoryBean:用于@Scope 注解,實(shí)現(xiàn)bean的作用域控制。他實(shí)現(xiàn)了 BeanFactory 、BeanFactoryAware接口,具有創(chuàng)建、管理bean的能力。

    這個(gè)類生成的代理只會(huì)記錄類的名稱,然后根據(jù)作用域獲取bean,如果是prototype的,則beanFactory會(huì)創(chuàng)建一個(gè)新的bean。

    public class ScopedProxyFactoryBean extends ProxyConfig
          implements FactoryBean<Object>, BeanFactoryAware, AopInfrastructureBean{
    
        // 使用它來(lái)管理bean的作用域,他的實(shí)現(xiàn)很簡(jiǎn)答,就是獲取對(duì)象時(shí),委托給 beanFactory,然后 beanFactory 根據(jù)作用域獲取對(duì)應(yīng)的bean。
        private final SimpleBeanTargetSource scopedTargetSource = new SimpleBeanTargetSource();
        @Override
    	public void setBeanFactory(BeanFactory beanFactory) {
    		if (!(beanFactory instanceof ConfigurableBeanFactory)) {
    			throw new IllegalStateException("Not running in a ConfigurableBeanFactory: " + beanFactory);
    		}
    		ConfigurableBeanFactory cbf = (ConfigurableBeanFactory) beanFactory;
    
            // 將beanFactory 與 scopedTargetSource 關(guān)聯(lián),獲取代理目標(biāo)類時(shí),從 scopedTargetSource 中獲取,
            // SimpleBeanTargetSource 將獲取bean的操作委托給了beanFactory
    		this.scopedTargetSource.setBeanFactory(beanFactory);
    
    		ProxyFactory pf = new ProxyFactory();
    		pf.copyFrom(this);
    		pf.setTargetSource(this.scopedTargetSource);
    
    		Assert.notNull(this.targetBeanName, "Property 'targetBeanName' is required");
    		Class<?> beanType = beanFactory.getType(this.targetBeanName);
    		if (beanType == null) {
    			throw new IllegalStateException("Cannot create scoped proxy for bean '" + this.targetBeanName +
    					"': Target type could not be determined at the time of proxy creation.");
    		}
            // 使用接口代理
    		if (!isProxyTargetClass() || beanType.isInterface() || Modifier.isPrivate(beanType.getModifiers())) {
    			pf.setInterfaces(ClassUtils.getAllInterfacesForClass(beanType, cbf.getBeanClassLoader()));
    		}
    		// 簡(jiǎn)單的代理增強(qiáng),在調(diào)用代理類時(shí),從 beanFactory 中獲取bean進(jìn)行調(diào)用,這樣就做到作用域的控制了。
    		ScopedObject scopedObject = new DefaultScopedObject(cbf, this.scopedTargetSource.getTargetBeanName());
    		pf.addAdvice(new DelegatingIntroductionInterceptor(scopedObject));
    
            // 標(biāo)記代理需要不需要被AOP攔截,及時(shí)有切入點(diǎn)匹配 
    		pf.addInterface(AopInfrastructureBean.class);
    
            // 創(chuàng)建代理對(duì)像:將創(chuàng)建代理交給 ProxyFactory
    		this.proxy = pf.getProxy(cbf.getBeanClassLoader());
    	}
    }


  2. ProxyProcessorSupport:為 ProxyFactory 提供了常用的公共方法。

public class ProxyProcessorSupport extends ProxyConfig implements Ordered, BeanClassLoaderAware, AopInfrastructureBean {
    /**
     * 可以自定義排序
     */
    public void setOrder(int order) { this.order = order; }
	@Override
	public int getOrder() { return this.order; }
    
    /**
     * 當(dāng)實(shí)現(xiàn)了接口時(shí),使用接口代理,沒(méi)有實(shí)現(xiàn)接口則使用類代理。
     */
    protected void evaluateProxyInterfaces(Class<?> beanClass, ProxyFactory proxyFactory) {
		Class<?>[] targetInterfaces = ClassUtils.getAllInterfacesForClass(beanClass, getProxyClassLoader());
		boolean hasReasonableProxyInterface = false;
		for (Class<?> ifc : targetInterfaces) {
			if (!isConfigurationCallbackInterface(ifc) && !isInternalLanguageInterface(ifc) &&
					ifc.getMethods().length > 0) {
				hasReasonableProxyInterface = true;
				break;
			}
		}
		if (hasReasonableProxyInterface) {
			for (Class<?> ifc : targetInterfaces) {
				proxyFactory.addInterface(ifc);
			}
		}
		else {
			proxyFactory.setProxyTargetClass(true);
		}
	}
}
  1. AbstractSingletonProxyFactoryBean : 創(chuàng)建單例代理對(duì)象,在需要代理的對(duì)象實(shí)例化后,使用 InitializingBean#afterPropertiesSet()來(lái)創(chuàng)建代理,并為其設(shè)置前置通知和后置通知。

    public abstract class AbstractSingletonProxyFactoryBean extends ProxyConfig
    		implements FactoryBean<Object>, BeanClassLoaderAware, InitializingBean {
    	// 代理目標(biāo)對(duì)象
        private Object target;
    
    	// 需要代理的接口
    	private Class<?>[] proxyInterfaces;
    
    	// 前置攔截器
    	private Object[] preInterceptors;
    
    	// 后置攔截器
    	private Object[] postInterceptors;
    
    	// 全局 Advisor 注冊(cè)器
    	private AdvisorAdapterRegistry advisorAdapterRegistry = GlobalAdvisorAdapterRegistry.getInstance();
    
    	// 類加載器
    	private transient ClassLoader proxyClassLoader;
    
    	// 代理對(duì)象
    	private Object proxy;
    
        // 實(shí)例化之后調(diào)用
        @Override
    	public void afterPropertiesSet() {
            // ....
    
            // 將代理創(chuàng)建工作委托給 ProxyFactory
    		ProxyFactory proxyFactory = new ProxyFactory();
    
            // 將預(yù)處理器、主處理器、后置處理器按順序添加,可以組成一個(gè)處理器鏈根據(jù)添加順序來(lái)執(zhí)行所有的處理器。
            // 添加預(yù)處理器
    		if (this.preInterceptors != null) {
    			for (Object interceptor : this.preInterceptors) {
    				proxyFactory.addAdvisor(this.advisorAdapterRegistry.wrap(interceptor));
    			}
    		}
            // 添加主要的處理器,交給子類實(shí)現(xiàn)
    		proxyFactory.addAdvisor(this.advisorAdapterRegistry.wrap(createMainInterceptor()));
            // 添加后置處理器
    		if (this.postInterceptors != null) {
    			for (Object interceptor : this.postInterceptors) {
    				proxyFactory.addAdvisor(this.advisorAdapterRegistry.wrap(interceptor));
    			}
    		}
            // 復(fù)制屬性
    		proxyFactory.copyFrom(this);
    		// 創(chuàng)建代理目標(biāo)源:默認(rèn)是 SingletonTargetSource 
    		TargetSource targetSource = createTargetSource(this.target);
    		proxyFactory.setTargetSource(targetSource);
    
            // 設(shè)置代理的接口
    		if (this.proxyInterfaces != null) {
    			proxyFactory.setInterfaces(this.proxyInterfaces);
    		}
            // 如果沒(méi)有使用類代理的方式,解析目標(biāo)類的接口。
    		else if (!isProxyTargetClass()) {
    			// Rely on AOP infrastructure to tell us what interfaces to proxy.
    			Class<?> targetClass = targetSource.getTargetClass();
    			if (targetClass != null) {
    				proxyFactory.setInterfaces(ClassUtils.getAllInterfacesForClass(targetClass, this.proxyClassLoader));
    			}
    		}
    
            // 代理工廠后置處理方法,由子類實(shí)現(xiàn),更改代理配置
    		postProcessProxyFactory(proxyFactory);
            // 創(chuàng)建代理對(duì)象,委托給了 ProxyFactory
    		this.proxy = proxyFactory.getProxy(this.proxyClassLoader);
    	}
    }		


  2. AdvisedSupport:實(shí)現(xiàn)了 Advised,將 ProxyConfigAdvised進(jìn)行適配,為 Advised 提供了支持,他的唯一子類 ProxyCreatorSupport為創(chuàng)建代理提供了支持。

    public class AdvisedSupport extends ProxyConfig implements Advised {
        // 空代理對(duì)象
    	public static final TargetSource EMPTY_TARGET_SOURCE = EmptyTargetSource.INSTANCE;
    	// 代理目標(biāo)源:默認(rèn)為空目標(biāo)源
    	TargetSource targetSource = EMPTY_TARGET_SOURCE;
    	// 是否已經(jīng)對(duì)Advisors進(jìn)行了過(guò)慮
    	private boolean preFiltered = false;
        // Advisor 調(diào)用鏈工長(zhǎng)
    	AdvisorChainFactory advisorChainFactory = new DefaultAdvisorChainFactory();
    	// 緩存方法對(duì)應(yīng)的 Advisor 調(diào)用鏈。
    	private transient Map<MethodCacheKey, List<Object>> methodCache;
    	// 要實(shí)現(xiàn)的代理接口,按順序存儲(chǔ)。
    	private List<Class<?>> interfaces = new ArrayList<>();
    	// Advisor 列表
    	private List<Advisor> advisors = new ArrayList<>();
    	// Advisor 數(shù)據(jù),為了方便內(nèi)部操作。
    	private Advisor[] advisorArray = new Advisor[0];
    }


    ProxyCreatorSupport 為創(chuàng)建代理提供了支持,他使用了AopProxyFactory 來(lái)創(chuàng)建AopProxy,最后ProxyFactory使用 AopProxy來(lái)創(chuàng)建代理對(duì)象。

    在創(chuàng)建ProxyCreatorSupport 時(shí)默認(rèn)創(chuàng)建 DefaultAopProxyFactory,由他來(lái)判斷使用接口代理還是子類代理。

    public class ProxyCreatorSupport extends AdvisedSupport {
    	private AopProxyFactory aopProxyFactory;
    
    	private final List<AdvisedSupportListener> listeners = new LinkedList<>();
    
        // 在創(chuàng)建第一個(gè)代理后將置為true,表示進(jìn)入活動(dòng)狀態(tài),將會(huì)觸發(fā) listeners。
    	private boolean active = false;
    
      	/**
      	 * 無(wú)參構(gòu)造器,將會(huì)創(chuàng)建一個(gè)默認(rèn)的aopProxyFactory。
      	 * DefaultAopProxyFactory 是一個(gè)創(chuàng)建代理的工長(zhǎng),用于根據(jù)配置創(chuàng)建代理。
      	 */
        public ProxyCreatorSupport() {
    		this.aopProxyFactory = new DefaultAopProxyFactory();
    	}
    
        // 創(chuàng)建AOP代理,根據(jù)自身的配置屬性覺(jué)得使用JDK代理還是Cglib代理。
        protected final synchronized AopProxy createAopProxy() {
    		if (!this.active) {
    			activate();
    		}
    		return getAopProxyFactory().createAopProxy(this);
    	}
    }


    上面提到使用 DefaultAopProxyFactory 來(lái)決定使用 jdk代理還是 Cglib代理,他通過(guò)接收一個(gè) AdvisedSupport


    // AopProxy 工廠
    public class DefaultAopProxyFactory implements AopProxyFactory, Serializable {
    
    	@Override
    	public AopProxy createAopProxy(AdvisedSupport config) throws AopConfigException {
            // 啟用優(yōu)化或使用子類代理、沒(méi)有實(shí)現(xiàn)接口,就會(huì)使用子類代理方式。
    		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.");
    			}
                // 代理目標(biāo)是接口,或者也是一個(gè)代理對(duì)象,使用jdk代理,否則使用Cglib 代理
    			if (targetClass.isInterface() || Proxy.isProxyClass(targetClass)) {
    				return new JdkDynamicAopProxy(config);
    			}
    			return new ObjenesisCglibAopProxy(config);
    		}
            // 使用接口代理:JDK代理 
    		else {
    			return new JdkDynamicAopProxy(config);
    		}
    	}
    }


    ProxyFactoryProxyCreatorSupport 的子類,通過(guò)調(diào)用父類的方法獲取AopProxy來(lái)創(chuàng)建目標(biāo)代理對(duì)象。

    public class ProxyFactory extends ProxyCreatorSupport {
        public Object getProxy() {
            // 掉用 `ProxyCreatorSupport#createAopProxy` 方法之后根據(jù)配置來(lái)判斷使用 JDK生成代理還是 Cglib生成代理
    		return createAopProxy().getProxy();
    	}
        // 與上面的方法區(qū)別在于傳入了類加載器
    	public Object getProxy(@Nullable ClassLoader classLoader) {
    		return createAopProxy().getProxy(classLoader);
    	}
    }


JdkDynamicAopProxy
final class JdkDynamicAopProxy implements AopProxy, InvocationHandler, Serializable {
	/** 代理配置. */
	private final AdvisedSupport advised;

	/**
	 * 代理的接口上是否定義了equals方法
	 */
	private boolean equalsDefined;

	/**
	 * 代理的接口是否定義了hashCode 方法
	 */
	private boolean hashCodeDefined;
    
    public JdkDynamicAopProxy(AdvisedSupport config) throws AopConfigException {
		Assert.notNull(config, "AdvisedSupport must not be null");
        // 通知不為空,并且目標(biāo)源不為空。
		if (config.getAdvisors().length == 0 && config.getTargetSource() == AdvisedSupport.EMPTY_TARGET_SOURCE) {
			throw new AopConfigException("No advisors and no TargetSource specified");
		}
		this.advised = config;
	}

	// 創(chuàng)建代理
	@Override
	public Object getProxy() {
        // 傳入默認(rèn)類加載器
		return getProxy(ClassUtils.getDefaultClassLoader());
	}
	
	@Override
	public Object getProxy(@Nullable ClassLoader classLoader) {
		if (logger.isTraceEnabled()) {
			logger.trace("Creating JDK dynamic proxy: " + this.advised.getTargetSource());
		}
        // 獲取代理目標(biāo)類的所有接口
		Class<?>[] proxiedInterfaces = AopProxyUtils.completeProxiedInterfaces(this.advised, true);
        // 檢查接口是否實(shí)現(xiàn)了equals 和 hashCode 方法
		findDefinedEqualsAndHashCodeMethods(proxiedInterfaces);
        // 創(chuàng)建代理對(duì)象,這里傳入了this對(duì)象,因?yàn)?nbsp;JdkDynamicAopProxy 實(shí)現(xiàn)了 InvocationHandler,使用這一段代理邏輯進(jìn)行代理
		return Proxy.newProxyInstance(classLoader, proxiedInterfaces, this);
	}
    
    /**
     * aop代理使用jdk代理將執(zhí)行的邏輯
     */
    @Override
	@Nullable
	public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
		Object oldProxy = null;
		boolean setProxyContext = false;
		TargetSource targetSource = this.advised.targetSource;
		Object target = null;
		try {
           	// 執(zhí)行equals方法時(shí),接口未定義 equals 方法 ,執(zhí)行JdkDynamicAopProxy 的 equals 方法
			if (!this.equalsDefined && AopUtils.isEqualsMethod(method)) {
				return equals(args[0]);
			}
            //  執(zhí)行 hashCode 方法時(shí),接口未定義 hashCode 方法,執(zhí)行JdkDynamicAopProxy的hashCode方法
			else if (!this.hashCodeDefined && AopUtils.isHashCodeMethod(method)) {
				return hashCode();
			}
            // 
			else if (method.getDeclaringClass() == DecoratingProxy.class) {
				return AopProxyUtils.ultimateTargetClass(this.advised);
			}
           	// 能夠轉(zhuǎn)換為Advised,將轉(zhuǎn)換為Advised,然后執(zhí)行
			else if (!this.advised.opaque && method.getDeclaringClass().isInterface() &&
					method.getDeclaringClass().isAssignableFrom(Advised.class)) {
				return AopUtils.invokeJoinpointUsingReflection(this.advised, method, args);
			}

			Object retVal;
			// 是否暴露當(dāng)前的代理,綁定到ThreadLocal中,
			if (this.advised.exposeProxy) {
				oldProxy = AopContext.setCurrentProxy(proxy);
				setProxyContext = true;
			}
			// 獲取目標(biāo)對(duì)象
			target = targetSource.getTarget();
			Class<?> targetClass = (target != null ? target.getClass() : null);

            // 根據(jù)代理目標(biāo)對(duì)象和方法獲取切入點(diǎn)、方法攔截器等。
			List<Object> chain = this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass);
			
            // 如果與該方法匹配的攔截器或通知為空,則進(jìn)行直接調(diào)用,避免創(chuàng)建MethodInvocation
			if (chain.isEmpty()) {
                // 找到方法
				Object[] argsToUse = AopProxyUtils.adaptArgumentsIfNecessary(method, args);
                // 直接調(diào)用原始對(duì)象方法
				retVal = AopUtils.invokeJoinpointUsingReflection(target, method, argsToUse);
			}
			else {
                // 調(diào)用 切入點(diǎn)、方法攔截器,目標(biāo)類
				MethodInvocation invocation =
						new ReflectiveMethodInvocation(proxy, target, method, args, targetClass, chain);
				retVal = invocation.proceed();
			}
			// 
			Class<?> returnType = method.getReturnType();
            // 如果返回值是目標(biāo)對(duì)象,并且代理對(duì)象是返回值類型的一個(gè)實(shí)例,則將返回值替換為代理對(duì)象
            // 方法的聲明類未實(shí)現(xiàn) RawTargetAccess
			if (retVal != null && retVal == target &&
					returnType != Object.class && returnType.isInstance(proxy) &&
					!RawTargetAccess.class.isAssignableFrom(method.getDeclaringClass())) {
				retVal = proxy;
			}
            // 如果返回值類型時(shí)基礎(chǔ)數(shù)據(jù)類型,并且為null。
			else if (retVal == null && returnType != Void.TYPE && returnType.isPrimitive()) {
				throw new AopInvocationException(
						"Null return value from advice does not match primitive return type for: " + method);
			}
			return retVal;
		}
		finally {
			if (target != null && !targetSource.isStatic()) {
				targetSource.releaseTarget(target);
			}
			if (setProxyContext) {
				AopContext.setCurrentProxy(oldProxy);
			}
		}
	}
}

JdkDynamicAopProxy 中,有2處關(guān)鍵代碼,1是獲取代理目標(biāo)的接口,2是執(zhí)行切入點(diǎn)、攔截器。

  1. AopProxyUtils#completeProxiedInterfaces()方法獲取代理目標(biāo)的接口,按照規(guī)則添加一部分接口SpringProxy、Advised、DecoratingProxy

    // AopProxyUtils
    static Class<?>[] completeProxiedInterfaces(AdvisedSupport advised, boolean decoratingProxy) {
       // 獲取目標(biāo)類實(shí)現(xiàn)的接口接口
       Class<?>[] specifiedInterfaces = advised.getProxiedInterfaces();
       // 目標(biāo)類的接口為空
       if (specifiedInterfaces.length == 0) {
          // 獲取代理目標(biāo)class
          Class<?> targetClass = advised.getTargetClass();
          if (targetClass != null) {
              // 判斷目標(biāo)類型是否是接口
             if (targetClass.isInterface()) {
                advised.setInterfaces(targetClass);
             }
              // 代理目標(biāo)類型是代理
             else if (Proxy.isProxyClass(targetClass)) {
                advised.setInterfaces(targetClass.getInterfaces());
             }
             // 重新獲取代理對(duì)象的接口集
             specifiedInterfaces = advised.getProxiedInterfaces();
          }
       }
    
       // 如果目標(biāo)類未實(shí)現(xiàn) SpringProxy 接口,將添加 SpringProxy 到接口集中。
       boolean addSpringProxy = !advised.isInterfaceProxied(SpringProxy.class);
       // 目標(biāo)類能轉(zhuǎn)換為Advised,并且未實(shí)現(xiàn) Advised 接口,則添加 Advised 到接口集中
       boolean addAdvised = !advised.isOpaque() && !advised.isInterfaceProxied(Advised.class);
       // decoratingProxy 為true,且目標(biāo)類未實(shí)現(xiàn) DecoratingProxy 接口,將 DecoratingProxy 添加進(jìn)接口集中
       boolean addDecoratingProxy = (decoratingProxy && !advised.isInterfaceProxied(DecoratingProxy.class));
    
       // 劃分接口數(shù)組長(zhǎng)度
       int nonUserIfcCount = 0;
       if (addSpringProxy) {
          nonUserIfcCount++;
       }
       if (addAdvised) {
          nonUserIfcCount++;
       }
       if (addDecoratingProxy) {
          nonUserIfcCount++;
       }
       Class<?>[] proxiedInterfaces = new Class<?>[specifiedInterfaces.length + nonUserIfcCount];
       // 拷貝
       System.arraycopy(specifiedInterfaces, 0, proxiedInterfaces, 0, specifiedInterfaces.length);
       // 將接口class設(shè)置進(jìn)對(duì)應(yīng)的數(shù)組位置
       int index = specifiedInterfaces.length;
       if (addSpringProxy) {
          proxiedInterfaces[index] = SpringProxy.class;
          index++;
       }
       if (addAdvised) {
          proxiedInterfaces[index] = Advised.class;
          index++;
       }
       if (addDecoratingProxy) {
          proxiedInterfaces[index] = DecoratingProxy.class;
       }
       // 返回需要代理的接口集。
       return proxiedInterfaces;
    }	


  2. 執(zhí)行切面和方法攔截器邏輯 ReflectiveMethodInvocation#proceed

    public class ReflectiveMethodInvocation implements ProxyMethodInvocation, Cloneable {
    
        public Object proceed() throws Throwable {
            // 執(zhí)行完后通知或攔截器后,將執(zhí)行業(yè)務(wù)方法
    		if (this.currentInterceptorIndex == this.interceptorsAndDynamicMethodMatchers.size() - 1) {
    			return invokeJoinpoint();
    		}
    
            // 獲取通知或攔截器
    		Object interceptorOrInterceptionAdvice =
    				this.interceptorsAndDynamicMethodMatchers.get(++this.currentInterceptorIndex);
            // 通知或攔截器是 InterceptorAndDynamicMethodMatcher 
            // InterceptorAndDynamicMethodMatcher 用于將方法匹配器與攔截器結(jié)合,如果方法匹配器匹配了就是用攔截器進(jìn)行調(diào)用
    		if (interceptorOrInterceptionAdvice instanceof InterceptorAndDynamicMethodMatcher) {
    			InterceptorAndDynamicMethodMatcher dm =
    					(InterceptorAndDynamicMethodMatcher) interceptorOrInterceptionAdvice;
    			Class<?> targetClass = (this.targetClass != null ? this.targetClass : this.method.getDeclaringClass());
    			if (dm.methodMatcher.matches(this.method, targetClass, this.arguments)) {
    				return dm.interceptor.invoke(this);
    			}
    			else {
                    // 匹配失敗,調(diào)用下一個(gè)匹配的攔截器
    				return proceed();
    			}
    		}
            // 調(diào)用其他攔截器,其他攔截器需要調(diào)用,因?yàn)閭魅肓藅his,攔截器鏈可以使用引用調(diào)用本方法,以執(zhí)行下一個(gè)切面或攔截器。
    		else {
    			return ((MethodInterceptor) interceptorOrInterceptionAdvice).invoke(this);
    		}
    	}
    }


“spring中代理的創(chuàng)建方法有哪些”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI