王国_Spring繁华的AOP王国第二讲

篇首语：本文由编程笔记#小编为大家整理，主要介绍了Spring繁华的AOP王国---第二讲相关的知识，希望对你有一定的参考价值。

Spring繁华的AOP王国---第二讲

• Spring AOP的织入
• • 如何与ProxyFactory打交道
  • • 1.基于接口的代理
    • 2.基于类的代理
    • 3.Introduction的织入
    
    
  • 看清ProxyFactory的本质
  • • ProxyConfig
    • Advised
    • AdvisedSupport
    • ProxyFactory,AopProxy,AdvisedSupport与ProxyFactory的关系
    • 小结
    
    
  • 容器中的织入器---ProxyFactoryBean
  • • ProxyFactoryBean的本质
    • ProxyFactoryBean的使用
    
    
  • 加快织入的自动化进程
  • • 使用自动代理的实现机制
    • 可用的AutoProxyCreator
    • • BeanNameAutoProxyCreator
      • DefaultAdvisorAutoProxyCreator
      • 扩展AutoProxyCreator
      
      
    
    
  
  
• TargetSource
• • 可用的targetSource实现类
  • • SingletonTargetSource
    • PrototypeTargetSource
    • HotSwappableTargetSource
    • CommonsPool2TargetSource
    • ThreadLocalTargetSource
    • 自定义TargetSource
    
    
  
  

Spring繁华的AOP王国—第一讲

如何与ProxyFactory打交道

public interface ITask
void excute();



public class MockTask implements ITask
&＃64;Override
public void excute()
System.out.println("task excuted!");




public class PerformanceMethodInterceptor implements MethodInterceptor
&＃64;Nullable
&＃64;Override
public Object invoke(&＃64;Nonnull MethodInvocation methodInvocation) throws Throwable
long start &＃61; System.currentTimeMillis();
System.out.println("方法执行前...");
Thread.sleep(1000);
Object proceed &＃61; methodInvocation.proceed();
Thread.sleep(1000);
System.out.println("方法执行后");
long end &＃61; System.currentTimeMillis();
System.out.println("方法执行总耗时: "&＃43;String.valueOf(end-start));
return proceed;




1.基于接口的代理

MockTask task&＃61;new MockTask();
ProxyFactory weaver&＃61;new ProxyFactory(task);
weaver.setInterfaces(ITask.class);
NameMatchMethodPointcutAdvisor advisor&＃61;new NameMatchMethodPointcutAdvisor();
advisor.setMappedName("excute");
advisor.setAdvice(new PerformanceMethodInterceptor());
weaver.addAdvisor(advisor);
ITask proxyObject&＃61; (ITask) weaver.getProxy();
proxyObject.excute();


MockTask task&＃61;new MockTask();
ProxyFactory weaver&＃61;new ProxyFactory(task);
NameMatchMethodPointcutAdvisor advisor&＃61;new NameMatchMethodPointcutAdvisor();
advisor.setMappedName("excute");
advisor.setAdvice(new PerformanceMethodInterceptor());
weaver.addAdvisor(advisor);
ITask proxyObject&＃61; (ITask) weaver.getProxy();
proxyObject.excute();


2.基于类的代理

public class MockTask
public void excute()
System.out.println("task excuted!");




MockTask task&＃61;new MockTask();
ProxyFactory weaver&＃61;new ProxyFactory(task);
NameMatchMethodPointcutAdvisor advisor&＃61;new NameMatchMethodPointcutAdvisor();
advisor.setMappedName("excute");
advisor.setAdvice(new PerformanceMethodInterceptor());
weaver.addAdvisor(advisor);
MockTask proxy &＃61; (MockTask)weaver.getProxy();
proxy.excute();
System.out.println(proxy.getClass());


3.Introduction的织入

看清ProxyFactory的本质

public interface AopProxy
Object getProxy();
Object getProxy(&＃64;Nullable ClassLoader var1);



public interface AopProxyFactory
AopProxy createAopProxy(AdvisedSupport var1) throws AopConfigException;



public class DefaultAopProxyFactory implements AopProxyFactory, Serializable
public DefaultAopProxyFactory()

public AopProxy createAopProxy(AdvisedSupport config) throws AopConfigException
if (NativeDetector.inNativeImage() || !config.isOptimize() && !config.isProxyTargetClass() && !this.hasNoUserSuppliedProxyInterfaces(config))
return new JdkDynamicAopProxy(config);
else
Class<?> targetClass &＃61; config.getTargetClass();
if (targetClass &＃61;&＃61; null)
throw new AopConfigException("TargetSource cannot determine target class: Either an interface or a target is required for proxy creation.");
else
return (AopProxy)(!targetClass.isInterface() && !Proxy.isProxyClass(targetClass) ? new ObjenesisCglibAopProxy(config) : new JdkDynamicAopProxy(config));



private boolean hasNoUserSuppliedProxyInterfaces(AdvisedSupport config)
Class<?>[] ifcs &＃61; config.getProxiedInterfaces();
return ifcs.length &＃61;&＃61; 0 || ifcs.length &＃61;&＃61; 1 && SpringProxy.class.isAssignableFrom(ifcs[0]);




ProxyConfig

public class ProxyConfig implements Serializable
private static final long serialVersionUID &＃61; -8409359707199703185L;
private boolean proxyTargetClass &＃61; false;
private boolean optimize &＃61; false;
boolean opaque &＃61; false;
boolean exposeProxy &＃61; false;
private boolean frozen &＃61; false;
....



Advised

public interface Advised extends TargetClassAware
boolean isFrozen();
boolean isProxyTargetClass();
Class<?>[] getProxiedInterfaces();
boolean isInterfaceProxied(Class<?> var1);
void setTargetSource(TargetSource var1);
TargetSource getTargetSource();
void setExposeProxy(boolean var1);
boolean isExposeProxy();
void setPreFiltered(boolean var1);
boolean isPreFiltered();
Advisor[] getAdvisors();
default int getAdvisorCount()
return this.getAdvisors().length;

void addAdvisor(Advisor var1) throws AopConfigException;
void addAdvisor(int var1, Advisor var2) throws AopConfigException;
boolean removeAdvisor(Advisor var1);
void removeAdvisor(int var1) throws AopConfigException;
int indexOf(Advisor var1);
boolean replaceAdvisor(Advisor var1, Advisor var2) throws AopConfigException;
void addAdvice(Advice var1) throws AopConfigException;
void addAdvice(int var1, Advice var2) throws AopConfigException;
boolean removeAdvice(Advice var1);
int indexOf(Advice var1);
String toProxyConfigString();



AdvisedSupport

ProxyFactory,AopProxy,AdvisedSupport与ProxyFactory的关系

小结

上面的图只是画了一个大概的联系&＃xff0c;大家再结合上面的文件好好理解一下

ProxyCreatorSupport内部拥有一个AopProxyFactory的对象实例&＃xff0c;但是获取AopProxy的时候&＃xff0c;是通过AopProxyFactory 的createAopProxy方法中传入自身实例ProxyCreatorSupport&＃xff0c;来得到一个指定的AopProxy的&＃xff0c;通过AopProxy 我们就可以获取到被代理后的对象

之说以传入自身&＃xff0c;是因为ProxyCreatorSupport实现了AdvisedSupport&＃xff0c;AdvisedSupport又实现了Advised接口&＃xff0c;可以因此来获取到被代理对象实例和横切逻辑

public class ProxyCreatorSupport extends AdvisedSupport
private AopProxyFactory aopProxyFactory;
private final List<AdvisedSupportListener> listeners &＃61; new ArrayList();
private boolean active &＃61; false;
public ProxyCreatorSupport()
this.aopProxyFactory &＃61; new DefaultAopProxyFactory();


public ProxyCreatorSupport(AopProxyFactory aopProxyFactory)
Assert.notNull(aopProxyFactory, "AopProxyFactory must not be null");
this.aopProxyFactory &＃61; aopProxyFactory;

....
protected final synchronized AopProxy createAopProxy()
if (!this.active)
this.activate();

return this.getAopProxyFactory().createAopProxy(this);



容器中的织入器—ProxyFactoryBean

ProxyFactoryBean的本质

&＃64;Nullable
public Object getObject() throws BeansException
this.initializeAdvisorChain();
if (this.isSingleton())
return this.getSingletonInstance();
else
if (this.targetName &＃61;&＃61; null)
this.logger.info("Using non-singleton proxies with singleton targets is often undesirable. Enable prototype proxies by setting the &＃39;targetName&＃39; property.");

return this.newPrototypeInstance();




ProxyFactoryBean的使用

加快织入的自动化进程

使用自动代理的实现机制

可用的AutoProxyCreator

需要明确一点&＃xff0c;既然我们使用了自动代理来自动为容器中符合条件的bean生成代理对象&＃xff0c;那么我们只需要在配置文件中指定切入点和advice即可了

BeanNameAutoProxyCreator

DefaultAdvisorAutoProxyCreator

扩展AutoProxyCreator

可用的targetSource实现类

SingletonTargetSource

PrototypeTargetSource

HotSwappableTargetSource

var cpro_id = "u6885494";