Spring AOP(二) 修飾者模式和JDK Proxy

Jackwoo 發(fā)布于2019-08-16 15:11 / 1840人閱讀

摘要：修飾者模式設(shè)計(jì)模式中的修飾者模式能動態(tài)地給目標(biāo)對象增加額外的職責(zé)。修飾者模式調(diào)用的時序圖如下圖所示。的實(shí)現(xiàn)原理和修飾者模式類似。

?在上邊一篇文章中我們介紹了Spring AOP的基本概念，今天我們就來學(xué)習(xí)一下與AOP實(shí)現(xiàn)相關(guān)的修飾者模式和Java Proxy相關(guān)的原理，為之后源碼分析打下基礎(chǔ)。

修飾者模式

?Java設(shè)計(jì)模式中的修飾者模式能動態(tài)地給目標(biāo)對象增加額外的職責(zé)(Responsibility)。它使用組合(object composition)，即將目標(biāo)對象作為修飾者對象(代理)的成員變量，由修飾者對象決定調(diào)用目標(biāo)對象的時機(jī)和調(diào)用前后所要增強(qiáng)的行為。

?裝飾模式包含如下組成部分：

Component: 抽象構(gòu)件，也就是目標(biāo)對象所實(shí)現(xiàn)的接口，有operation函數(shù)

ConcreteComponent: 具體構(gòu)件，也就是目標(biāo)對象的類

Decorator: 抽象裝飾類，也實(shí)現(xiàn)了抽象構(gòu)件接口，也就是目標(biāo)類和裝飾類都實(shí)現(xiàn)了相同的接口

ConcreteDecorator: 具體裝飾類，其中addBeavior函數(shù)就是增強(qiáng)的行為，裝飾類可以自己決定addBeavior函數(shù)和目標(biāo)對象函數(shù)operation函數(shù)的調(diào)用時機(jī)。

?修飾者模式調(diào)用的時序圖如下圖所示。程序首先創(chuàng)建目標(biāo)對象，然后創(chuàng)建修飾者對象，并將目標(biāo)對象傳入作為其成員變量。當(dāng)程序調(diào)用修飾者對象的operation函數(shù)時，修飾者對象會先調(diào)用目標(biāo)對象的operation函數(shù)，然后再調(diào)用自己的addBehavior函數(shù)。這就是類似于AOP的后置增強(qiáng)器，在目標(biāo)對象的行為之后添加新的行為。

?Spring AOP的實(shí)現(xiàn)原理和修飾者模式類似。在上一篇文章中說到AOP的動態(tài)代理有兩種實(shí)現(xiàn)方式，分別是JDK Proxy和cglib。

?如下圖所示，JDK Proxy的類結(jié)構(gòu)和上文中修飾者的類圖結(jié)構(gòu)類似，都是代理對象和目標(biāo)對象都實(shí)現(xiàn)相同的接口，代理對象持有目標(biāo)對象和切面對象，并且決定目標(biāo)函數(shù)和切面增強(qiáng)函數(shù)的調(diào)用時機(jī)。
?而cglib的實(shí)現(xiàn)略有不同，它沒有實(shí)現(xiàn)實(shí)現(xiàn)相同接口，而是代理對象繼承目標(biāo)對象類。

?本文后續(xù)就講解一下JDK Proxy的相關(guān)源碼分析。

JDK Proxy

?JDK提供了Proxy類來實(shí)現(xiàn)動態(tài)代理的，可通過它的newProxyInstance函數(shù)來獲得代理對象。JDK還提供了InvocationHandler類，代理對象的函數(shù)被調(diào)用時，會調(diào)用它的invoke函數(shù)，程序員可以在其中實(shí)現(xiàn)所需的邏輯。

?JDK Proxy的基本語法如下所示。先構(gòu)造一個InvocationHandler 的實(shí)現(xiàn)類，然后調(diào)用Proxy的newProxyInstance 函數(shù)生成代理對象，傳入類加載器，目標(biāo)對象的接口和自定義的InvocationHandler實(shí)例。

public class CustomInvocationHandler implements InvocationHandler {
    private Object target;

    public CustomInvocationHandler(Object target) {
        this.target = target;
    }

    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        System.out.println("Before invocation");
        Object retVal = method.invoke(target, args);
        System.out.println("After invocation");
        return retVal;
    }
}

CustomInvocationHandler customInvocationHandler = new CustomInvocationHandler(
        helloWord);
//通過Proxy.newProxyInstance生成代理對象
ProxyTest proxy = (ProxyTest) Proxy.newProxyInstance(
        ProxyTest.class.getClassLoader(),
       proxyObj.getClass().getInterfaces(), customInvocationHandler);

生成代理對象

?我們首先來看一下Proxy的newProxyInstance函數(shù)。newProxyInstance函數(shù)的邏輯大致如下：

首先根據(jù)傳入的目標(biāo)對象接口動態(tài)生成代理類

然后獲取代理類的構(gòu)造函數(shù)實(shí)例

最后將InvocationHandler作為參數(shù)通過反射調(diào)用構(gòu)造函數(shù)實(shí)例，生成代理類對象。

?具體源碼如下所示。

public static Object newProxyInstance(ClassLoader loader,
                                        Class[] interfaces,
                                        InvocationHandler h)
    throws IllegalArgumentException
{

    final Class[] intfs = interfaces.clone();
    final SecurityManager sm = System.getSecurityManager();
    if (sm != null) {
        checkProxyAccess(Reflection.getCallerClass(), loader, intfs);
    }
    // 1 動態(tài)生成代理對象的類
    Class cl = getProxyClass0(loader, intfs);

    // ... 代碼省略，下邊代碼其實(shí)是在try catch中的
    if (sm != null) {
        checkNewProxyPermission(Reflection.getCallerClass(), cl);
    }
    // 2 獲取代理類的構(gòu)造函數(shù)
    final Constructor cons = cl.getConstructor(constructorParams);
    final InvocationHandler ih = h;
    if (!Modifier.isPublic(cl.getModifiers())) {
        AccessController.doPrivileged(new PrivilegedAction() {
            public Void run() {
                cons.setAccessible(true);
                return null;
            }
        });
    }
    // 3調(diào)用構(gòu)造函數(shù)，傳入InvocationHandler對象
    return cons.newInstance(new Object[]{h});
}

?getProxyClass0函數(shù)的源碼如下所示，通過代理類緩存獲取代理類信息，如果不存在則會生成代理類。

// 生成代理類
private static Class getProxyClass0(ClassLoader loader,
                                        Class... interfaces) {
    if (interfaces.length > 65535) {
        throw new IllegalArgumentException("interface limit exceeded");
    }

    // 如果已經(jīng)有Proxy類的緩存則直接返回，否則要進(jìn)行創(chuàng)建
    return proxyClassCache.get(loader, interfaces);
}

生成代理類

?JDK Proxy通過ProxyClassFactory生成代理類。其apply函數(shù)大致邏輯如下：

校驗(yàn)接口是否符合規(guī)范

生成代理類的名稱和包名

生成代理類字節(jié)碼

根據(jù)字節(jié)碼生成代理類Class

// 生成代理類的工廠類
private static final class ProxyClassFactory
    implements BiFunction[], Class>
{
    // 所有代理類名的前綴
    private static final String proxyClassNamePrefix = "$Proxy";

    // 生成唯一類名的原子Long對象
    private static final AtomicLong nextUniqueNumber = new AtomicLong();

    @Override
    public Class apply(ClassLoader loader, Class[] interfaces) {

        Map, Boolean> interfaceSet = new IdentityHashMap<>(interfaces.length);
        for (Class intf : interfaces) {
            // 通過loader找到接口對應(yīng)的類信息。
            Class interfaceClass = null;
            try {
                interfaceClass = Class.forName(intf.getName(), false, loader);
            } catch (ClassNotFoundException e) {
            }
            if (interfaceClass != intf) {
                throw new IllegalArgumentException(
                    intf + " is not visible from class loader");
            }
            // 判斷找出來的類確實(shí)是一個接口
            if (!interfaceClass.isInterface()) {
                throw new IllegalArgumentException(
                    interfaceClass.getName() + " is not an interface");
            }
            // 判斷接口是否重復(fù)
            if (interfaceSet.put(interfaceClass, Boolean.TRUE) != null) {
                throw new IllegalArgumentException(
                    "repeated interface: " + interfaceClass.getName());
            }
        }
        // 代理類的包路徑
        String proxyPkg = null;
        int accessFlags = Modifier.PUBLIC | Modifier.FINAL;

        // 記錄非公開的代理接口，以便于生成的代理類和原來的類在同一個路徑下。 
        for (Class intf : interfaces) {
            int flags = intf.getModifiers();
            if (!Modifier.isPublic(flags)) {
                accessFlags = Modifier.FINAL;
                String name = intf.getName();
                int n = name.lastIndexOf(".");
                String pkg = ((n == -1) ? "" : name.substring(0, n + 1));
                if (proxyPkg == null) {
                    proxyPkg = pkg;
                } else if (!pkg.equals(proxyPkg)) {
                    throw new IllegalArgumentException(
                        "non-public interfaces from different packages");
                }
            }
        }
        // 如果沒有非公開的Proxy接口，使用com.sun.proxy報名
        if (proxyPkg == null) {
            proxyPkg = ReflectUtil.PROXY_PACKAGE + ".";
        }

        long num = nextUniqueNumber.getAndIncrement();
        // 默認(rèn)情況下，代理類的完全限定名為：com.sun.proxy.$Proxy0，$Proxy1……依次遞增  
        String proxyName = proxyPkg + proxyClassNamePrefix + num;

        // 生成代理類字節(jié)碼
        byte[] proxyClassFile = ProxyGenerator.generateProxyClass(
            proxyName, interfaces, accessFlags);
        try {
            // 根據(jù)字節(jié)碼返回相應(yīng)的Class實(shí)例
            return defineClass0(loader, proxyName,
                                proxyClassFile, 0, proxyClassFile.length);
        } catch (ClassFormatError e) {
            throw new IllegalArgumentException(e.toString());
        }
    }
}

?其中關(guān)于字節(jié)碼生成的部分邏輯我們就暫時不深入介紹了，感興趣的同學(xué)可以自行研究。

$Proxy反編譯

?我們來看一下生成的代理類的反編譯代碼。代理類實(shí)現(xiàn)了Object的基礎(chǔ)函數(shù)，比如toString、hasCode和equals ，也實(shí)現(xiàn)了目標(biāo)接口中定義的函數(shù)，比如說ProxyTest接口的test 函數(shù)。

? $Proxy中函數(shù)的實(shí)現(xiàn)都是直接調(diào)用了InvocationHandler 的invoke函數(shù)。

public final class $Proxy0 extends Proxy
  implements ProxyTest 
// 會實(shí)現(xiàn)目標(biāo)接口，但是由于集成了Proxy，所以無法再集成其他類
{
  private static Method m1;
  private static Method m0;
  private static Method m3;
  private static Method m2;
  // 構(gòu)造函數(shù)要傳入一個InvocationHandler對象
  public $Proxy0(InvocationHandler paramInvocationHandler)
    throws 
  {
    super(paramInvocationHandler);
  }
  // equal函數(shù)
  public final boolean equals(Object paramObject)
    throws 
  {
      try
    {
      return ((Boolean)this.h.invoke(this, m1, new Object[] { paramObject })).booleanValue();
    }
    catch (RuntimeException localRuntimeException)
    {
      throw localRuntimeException;
    }
    catch (Throwable localThrowable)
    {
    }
    throw new UndeclaredThrowableException(localThrowable);
  }

  public final int hashCode()
    throws 
  {
    try
    {
      return ((Integer)this.h.invoke(this, m0, null)).intValue();
    }
    catch (RuntimeException localRuntimeException)
    {
      throw localRuntimeException;
    }
    catch (Throwable localThrowable)
    {
    }
    throw new UndeclaredThrowableException(localThrowable);
  }
  // test函數(shù)，也就是ProxyTest接口中定義的函數(shù)
  public final void test(String paramString)
    throws 
  {
    try
    {
      // 調(diào)用InvocationHandler的invoke函數(shù)
      this.h.invoke(this, m3, new Object[] { paramString });
      return;
    }
    catch (RuntimeException localRuntimeException)
    {
      throw localRuntimeException;
    }
    catch (Throwable localThrowable)
    {
    }
    throw new UndeclaredThrowableException(localThrowable);
  }

  public final String toString()
    throws 
  {
    try
    {
      return (String)this.h.invoke(this, m2, null);
    }
    catch (RuntimeException localRuntimeException)
    {
      throw localRuntimeException;
    }
    catch (Throwable localThrowable)
    {
    }
    throw new UndeclaredThrowableException(localThrowable);
  }
  // 獲取各個函數(shù)的Method對象
  static
  {
    try
    {
      m1 = Class.forName("java.lang.Object").getMethod("equals", new Class[] { Class.forName("java.lang.Object") });
      m0 = Class.forName("java.lang.Object").getMethod("hashCode", new Class[0]);
      m3 = Class.forName("com.proxy.test2.HelloTest").getMethod("say", new Class[] { Class.forName("java.lang.String") });
      m2 = Class.forName("java.lang.Object").getMethod("toString", new Class[0]);
      return;
    }
    catch (NoSuchMethodException localNoSuchMethodException)
    {
      throw new NoSuchMethodError(localNoSuchMethodException.getMessage());
    }
    catch (ClassNotFoundException localClassNotFoundException)
    {
    }
    throw new NoClassDefFoundError(localClassNotFoundException.getMessage());
  }
}

后記

?下一篇文章就是AOP的源碼分析了，希望大家繼續(xù)關(guān)注。

GPU云服務(wù)器云服務(wù)器 Spring AOP 代理 spring-aop 策略者模式裝飾者模式

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/73330.html

發(fā)表評論

登陸后可評論

0條評論

Jackwoo

男|高級講師

我要關(guān)注我要私信

TA的文章

關(guān)于C++基礎(chǔ)的一些“碎碎念”

閱讀 1867·2021-09-29 09:35
云服務(wù)器和云虛擬主機(jī)有什么區(qū)別-云主機(jī)、云服務(wù)器、虛擬主機(jī)有什么區(qū)別呢？

閱讀 2729·2021-09-22 15:25
PIGYun：“喜迎金秋" 香港、韓國BGP混合CN2大帶寬僅14元起

閱讀 1984·2021-08-23 09:43
前端進(jìn)階（12） - css 的弱化與 js 的強(qiáng)化

閱讀 2063·2019-08-30 15:54
前端每日實(shí)戰(zhàn)：53# 視頻演示如何用純 CSS 創(chuàng)作一個文本淡入淡出的 loader 動畫

閱讀 3361·2019-08-30 15:53
哪些你知道或不知道的css，在這里或許都齊全

閱讀 2398·2019-08-30 13:50
移動端鍵盤和光標(biāo)的兼容那點(diǎn)事

閱讀 2409·2019-08-30 11:24
前端框架這么多，該如何抉擇？

閱讀 2283·2019-08-29 15:37

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Spring AOP(二) 修飾者模式和JDK Proxy

相關(guān)文章

**慕課網(wǎng)_《探秘Spring AOP》學(xué)習(xí)總結(jié)**

Spring筆記03_AOP

面試官:“談?wù)?em>Spring中都用到了那些設(shè)計(jì)模式?”。

**Java設(shè)計(jì)模式綜合運(yùn)用(動態(tài)代理+Spring AOP)**

Spring自定義注解不生效原因解析及解決方法

發(fā)表評論

0條評論

Jackwoo

男|高級講師

TA的文章

關(guān)于C++基礎(chǔ)的一些“碎碎念”

云服務(wù)器和云虛擬主機(jī)有什么區(qū)別-云主機(jī)、云服務(wù)器、虛擬主機(jī)有什么區(qū)別呢？

PIGYun：“喜迎金秋" 香港、韓國BGP混合CN2大帶寬僅14元起

前端進(jìn)階（12） - css 的弱化與 js 的強(qiáng)化

前端每日實(shí)戰(zhàn)：53# 視頻演示如何用純 CSS 創(chuàng)作一個文本淡入淡出的 loader 動畫

哪些你知道或不知道的css，在這里或許都齊全

移動端鍵盤和光標(biāo)的兼容那點(diǎn)事

前端框架這么多，該如何抉擇？

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Spring AOP(二) 修飾者模式和JDK Proxy

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！