Springboot源碼分析之代理三板斧

来源:https://www.cnblogs.com/qinzj/archive/2019/08/24/11405826.html
-Advertisement-
Play Games

摘要: 在 的版本變遷過程中,註解發生了很多的變化,然而代理的設計也發生了微妙的變化,從 的`ProxyFactoryBean Spring2.x Aspectj`註解,最後到了現在廣為熟知的自動代理。 說明: 代理的相關配置類 實現了 ,封裝了對 和`Advisor`的操作 該類及其子類主要是利用 ...


摘要:

Spring的版本變遷過程中,註解發生了很多的變化,然而代理的設計也發生了微妙的變化,從Spring1.xProxyFactoryBean的硬編碼到Spring2.xAspectj註解,最後到了現在廣為熟知的自動代理。

file

說明:

  • ProxyConfig代理的相關配置類
  • AdvisedSupport實現了Advised,封裝了對AdviceAdvisor的操作
  • ProxyCreatorSupport該類及其子類主要是利用代理工廠幫助創建jdk或者cglib的代理對象
  • ProxyProcessorSupport該類及其子類才是我們目前用得做多的,利用後置處理器來進行自動代理處理

ProxyFactoryBean

    package com.github.dqqzj.springboot.aop;
    
    import org.springframework.aop.MethodBeforeAdvice;
    import org.springframework.aop.TargetSource;
    import org.springframework.aop.framework.ProxyFactoryBean;
    import org.springframework.aop.target.SingletonTargetSource;
    import org.springframework.context.annotation.Bean;
    import org.springframework.stereotype.Component;
    
    import java.lang.reflect.Method;
    
    /**
     * @author qinzhongjian
     * @date created in 2019-08-24 11:05
     * @description: TODO
     * @since JDK 1.8.0_212-b10
     */
    @Component
    public class MyMethodBeforeAdvice implements MethodBeforeAdvice {
        @Override
        public void before(Method method, Object[] args, Object target) throws Throwable {
            if (!method.getName().equals("toString")) {
                System.out.println(target.getClass().getName() + "#" + method.getName());
            }
        }
        /**
         * 代理的目標對象  效果同setTargetSource(@Nullable TargetSource targetSource)
         * TargetSource targetSource = new SingletonTargetSource(aopService);
         * 可以從容器獲取,也可以類似下麵這樣直接new,使用區別需要熟悉spring機制。
         * factoryBean.setTarget(new AopService());
         *
         * 設置需要被代理的介面  效果同factoryBean.setProxyInterfaces(new Class[]{AopService.class});
         * 若沒有實現介面,那就會採用cglib去代理
         * 如果有介面不指定的話會代理所有的介面,否則代理指定的介面
         *
         *  setInterceptorNames方法源代碼中有這樣的一句話:Set the list of Advice/Advisor bean names. This must always be set
         *  to use this factory bean in a bean factory.
         */
        @Bean
        public ProxyFactoryBean proxyFactoryBean(AopService aopService) {
            ProxyFactoryBean factoryBean = new ProxyFactoryBean();
            factoryBean.setTarget(aopService);
            //factoryBean.setInterfaces(AopService.class);
    
            factoryBean.setInterceptorNames("myMethodBeforeAdvice");
            //是否強制使用cglib,預設是false的
            //factoryBean.setProxyTargetClass(true);
            return factoryBean;
        }
    
    }

file

源碼分析:

        @Override
        @Nullable
        public Object getObject() throws BeansException {
            //根據我們配置的interceptorNames來獲取對應的Advisor並加入通知器執行鏈中
            initializeAdvisorChain();
            if (isSingleton()) {
                //生成singleton的代理對象,會利用DefaultAopProxyFactory去生成代理
          //在內部如果你手動沒有去設置需要被代理的介面,Spring會代理你所有的實現介面。
                return getSingletonInstance();
            }
            else {
                if (this.targetName == null) {
                    logger.warn("Using non-singleton proxies with singleton targets is often undesirable. " +
                            "Enable prototype proxies by setting the 'targetName' property.");
                }
          //和單利非常類似 只不過沒有緩存了
                return newPrototypeInstance();
            }
        }
        private synchronized void initializeAdvisorChain() throws AopConfigException, BeansException {
            if (this.advisorChainInitialized) {
                return;
            }
            if (!ObjectUtils.isEmpty(this.interceptorNames)) {
                // 最後一個不能是全局的suffix *,除非我們指定了targetSource之類的
                if (this.interceptorNames[this.interceptorNames.length - 1].endsWith(GLOBAL_SUFFIX) &&
                        this.targetName == null && this.targetSource == EMPTY_TARGET_SOURCE) {
                    throw new AopConfigException("Target required after globals");
                }
                for (String name : this.interceptorNames) {
                    // 如國攔截器的名稱是以*結尾的,說明它要去全局裡面都搜索出來
                    // 全局:去自己容器以及父容器中找,類型為Advisor.class的,名稱是以這個名稱為開頭的prefix的Bean.
                    if (name.endsWith(GLOBAL_SUFFIX)) {
                        addGlobalAdvisor((ListableBeanFactory) this.beanFactory,
                                name.substring(0, name.length() - GLOBAL_SUFFIX.length()));
                    }
                    // 一般的情況下我們都是精確匹配
                    else {
                        Object advice;
                        if (this.singleton || this.beanFactory.isSingleton(name)) {
                            // 從容器里獲取該bean
                            advice = this.beanFactory.getBean(name);
                        }
                        // 原型處理
                        else {
                            advice = new PrototypePlaceholderAdvisor(name);
                        }
                        addAdvisorOnChainCreation(advice, name);
                    }
                }
            }
            this.advisorChainInitialized = true;
        }
      // 將advice對象添加到通知器鏈中
        private void addAdvisorOnChainCreation(Object next, String name) {
            // 這裡調用namedBeanToAdvisor做了一下適配:成統一的Advisor 
            Advisor advisor = namedBeanToAdvisor(next);
            addAdvisor(advisor);
        }
    //方法中首先會調用namedBeanToAdvisor(next)方法,將從ioc容器獲取的普通對象轉換成通知器Advisor對象
        private Advisor namedBeanToAdvisor(Object next) {
            try {
                return this.advisorAdapterRegistry.wrap(next);
            }
        }

DefaultAdvisorAdapterRegistry

file

這個類還允許我們自定義適配器,然後註冊到裡面就行。

      @Override
        public void registerAdvisorAdapter(AdvisorAdapter adapter) {
            this.adapters.add(adapter);
        }

ProxyFactoryBean脫離IoC容器使用

file

ProxyFactory

file

說明:這個類一般是spring自己內部使用的,我們自定義的話很難與容器進行整合,它一般都是返回的原型模式代理

AspectJProxyFactory

file

小結:

根據以上案例可以發現 都是首先進行AdvisedSupport的準備,然後交給子類ProxyCreatorSupport根據條件
得到JDK或者CGLIB的AopProxy,當代理對象被調用的時候在invoke或者intercept方法中會調用ProxyCreatorSupport的getInterceptorsAndDynamicInterceptionAdvice方法去初始化advice和各個方法之間的映射關係並緩存
同類方法代理不生效原因?

很多時候會發現代理方法和非代理方法在同一個類中調用不生效和調用順序有關係,我們進行重構代碼來分析一下原因

    public class AspectJProxyFactoryApplication {
        public static void main(String[] args) {
            AspectJProxyFactory proxyFactory = new AspectJProxyFactory(new AopService());
            // 註意:此處得MyAspect類上面的@Aspect註解必不可少
            proxyFactory.addAspect(MyAspect.class);
            //proxyFactory.setProxyTargetClass(true);//是否需要使用CGLIB代理
            AopService proxy = proxyFactory.getProxy();
            proxy.test();
        }
    }
    @Aspect
    public class MyAspect {
        //@Pointcut("execution(* com.github..aop.*.*(..))")
        @Pointcut("execution(* com.github..aop.AopService.hello(..))")
        private void pointcut() {
        }
    
        @Before("pointcut()")
        public void before() {
            System.out.println("-----------MyAspect#before-----------");
        }
    }
    @Service
    public class AopService {
        public String hello() {
            System.out.println("hello, AopService");
            return "hello, AopService";
        }
        public String test() {
            System.out.println("test");
            return hello();
        }
    }

答案就是不會生效,究竟是什麼引起的呢?其實就是我上面的小結的最後一個知識點。

file

這個時候chain沒有我們的通知器在裡面,
file

file

最終按照我們的程式執行,下麵進行修改切點表達式,如果上面的例子看的咨詢的話下麵就可以忽略了,主要就是是否增強就是第一個入口函數能否匹配上我們的切點表達式後續的根本不會關心你是否能匹配上。

    @Aspect
    public class MyAspect {
        @Pointcut("execution(* com.github..aop.*.*(..))")
        //@Pointcut("execution(* com.github..aop.AopService.hello(..))")
        private void pointcut() {
        }
    
        @Before("pointcut()")
        public void before() {
            System.out.println("-----------MyAspect#before-----------");
        }
    }

file

file

處理完後就會按照下麵代碼正常流程執行完

if (this.currentInterceptorIndex == this.interceptorsAndDynamicMethodMatchers.size() - 1) {
   return invokeJoinpoint();
}

如果同一個類的方法調用都想讓通知器生效怎麼辦?這個就必須要讓通知添加到執行鏈中才行,根據上面所講的內容就可以達到這個目的,然後繼續用此代理對象來調用該內嵌方法。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 修改列表中的元素: output: ['history','Chinese','English'] 列表中添加元素: 在末尾添加: output:['math','English'] ['math','English','Chinese'] 插入元素: output:['math','English ...
  • 在 IntelliJ IDEA 中,沒有類似於 Eclipse 工作空間(Workspace)的概念,而是提出了Project和Module這兩個概念。多module有一個父maven工程,多個子工程。在多個子工程中,可能有一個web工程,也可能有多個web工程。這樣的好處在於大大解耦各個modul... ...
  • 會話技術: 會話是什麼? 瀏覽器和伺服器交互,瀏覽器打開網頁訪問伺服器,會話開始,正常交互. 瀏覽器關閉,會話結束. 會話能幹什麼? 會話可以共用數據. Cookie和session將數據保存在不同的位置 進行數據共用 Cookie入門案例 1.創建一個cookie對象 a. Cookie cook ...
  • 1.iter補充 2.ntp_client和ntp_server 3.time複習 4.udp的客戶端與服務端通信 5.解決粘包 # from socket import * # ip_port=('127.0.0.1',8080) # back_log=5 # buffer_size=1024 # ...
  • 1. course 1.進程創建的兩種方式 1. 開啟進程的第一種方式: 2. 開啟進程的第二種方式: 3. 簡單應用 2.獲取進程pid 3.驗證進程之間的空間隔離 4. join 5.進程的其他參數 6.守護進程 7.僵屍進程孤兒進程 基於 環境( ) 主進程需要等待子進程結束之後,主進程才結束 ...
  • 服務鏈路跟蹤 背景 微服務以微出名,在實際的開發過程中,涉及到成百上千個服務,網路請求引起服務之間的調用極其複雜。 當請求不可用或者變慢時,需要及時排查出故障服務點成為了微服務維護的一大難關。 服務鏈路跟蹤技術應運而生。 ZipKin Zipkin 是一個開放源代碼分散式的跟蹤系統,由Twitter ...
  • Python 入門之常用運算符 算數運算符 比較運算符 賦值運算符 邏輯運算符 成員運算符 位運算符 身份運算符 Python運算符優先順序 ...
  • HTTP不能保持連接,可使用會話保存用戶信息。 常用的會話技術有2種:Cookie、Session。 Cookie 1、原理 當用戶第一次訪問某個網站時,伺服器設置Cookie,存儲用戶信息,放在響應頭欄位中,隨HTTP響應傳給瀏覽器,瀏覽器把Cookie存儲到本地電腦上。 當用戶再次訪問該網站時 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...