JDK中「SPI」原理分析

来源:https://www.cnblogs.com/cicada-smile/archive/2023/08/05/17607737.html
-Advertisement-
Play Games

SPI是JDK內置的服務提供載入機制,可以為服務介面載入實現類,解耦是其核心思想,也是很多框架和組件的常用手段; ...


目錄

基於【JDK1.8】

一、SPI簡介

1、概念

SPI即service-provider-interface的簡寫;

JDK內置的服務提供載入機制,可以為服務介面載入實現類,解耦是其核心思想,也是很多框架和組件的常用手段;

2、入門案例

2.1 定義介面

就是普通的介面,在SPI的機制中稱為【service】,即服務;

public interface Animal {
    String animalName () ;
}

2.2 兩個實現類

提供兩個模擬用來測試,就是普通的介面實現類,在SPI的機制中稱為【service-provider】即服務提供方;

CatAnimal實現類;

public class CatAnimal implements Animal {
    @Override
    public String animalName() {
        System.out.println("Cat-Animal:布偶貓");
        return "Ragdoll";
    }
}

DogAnimal實現類;

public class DogAnimal implements Animal {
    @Override
    public String animalName() {
        System.out.println("Dog-Animal:哈士奇");
        return "husky";
    }
}

2.3 配置文件

文件目錄:在代碼工程中創建META-INF.services文件夾;

文件命名:butte.program.basics.spi.inf.Animal,即全限定介面名稱;

文件內容:添加相應實現類的全限定命名;

butte.program.basics.spi.impl.CatAnimal
butte.program.basics.spi.impl.DogAnimal

2.4 測試代碼

通過ServiceLoader載入配置文件中指定的服務實現類,然後遍歷並調用Animal介面方法,從而執行不同服務提供方的具體邏輯;

public class SpiAnaly {
    public static void main(String[] args) {
        ServiceLoader<Animal> serviceLoader = ServiceLoader.load(Animal.class);
        Iterator<Animal> animalIterator = serviceLoader.iterator();
        while(animalIterator.hasNext()) {
            Animal animal = animalIterator.next();
            System.out.println("animal-name:" + animal.animalName());
        }
    }
}

結果輸出

Cat-Animal:布偶貓 \n animal-name:ragdoll
Dog-Animal:哈士奇 \n animal-name:husky

二、原理分析

1、ServiceLoader結構

很顯然,分析SPI機制的原理,從ServiceLoader源碼中load方法切入即可,但是需要先從核心類的結構開始分析;

public final class ServiceLoader<S> implements Iterable<S> {
    // 配置文件目錄
    private static final String PREFIX = "META-INF/services/";
    // 表示正在載入的服務的類或介面
    private final Class<S> service;
    // 類載入器用來定位,載入,實例化服務提供方
    private final ClassLoader loader;
    // 創建ServiceLoader時採用的訪問控制上下文
    private final AccessControlContext acc;
    // 按實例化的順序緩存服務提供方
    private LinkedHashMap<String,S> providers = new LinkedHashMap<>();
    // 惰性查找迭代器
    private LazyIterator lookupIterator;
    /**
     * service:表示服務的介面或抽象類
     * loader: 類載入器
     */
    public static <S> ServiceLoader<S> load(Class<S> service) {
        ClassLoader cl = Thread.currentThread().getContextClassLoader();
        return ServiceLoader.load(service, cl);
    }
    /**
     * ServiceLoader構造方法
     */
    private ServiceLoader(Class<S> svc, ClassLoader cl) {
        loader = (cl == null) ? ClassLoader.getSystemClassLoader() : cl;
        acc = (System.getSecurityManager() != null) ? AccessController.getContext() : null;
        reload();
    }
    public void reload() {
        providers.clear();
        // 實例化迭代器
        lookupIterator = new LazyIterator(service, loader);
    }
    public static <S> ServiceLoader<S> load(Class<S> service,ClassLoader loader) {
        return new ServiceLoader<>(service, loader);
    }

    private class LazyIterator implements Iterator<S> {
        // 服務介面
        Class<S> service;
        // 類載入器
        ClassLoader loader;
        // 實現類URL
        Enumeration<URL> configs = null;
        // 實現類全名
        Iterator<String> pending = null;
        // 下個實現類全名
        String nextName = null;
    }
}

斷點截圖:

2、iterator迭代方法

ServiceLoader類的迭代器方法中,實際使用的是LazyIterator內部類的方法;

public Iterator<S> iterator() {
    return new Iterator<S>() {
        Iterator<Map.Entry<String,S>> knownProviders = providers.entrySet().iterator();
        public boolean hasNext() {
            if (knownProviders.hasNext())
                return true;
            return lookupIterator.hasNext();
        }
        public S next() {
            if (knownProviders.hasNext())
                return knownProviders.next().getValue();
            return lookupIterator.next();
        }
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}

3、hasNextService方法

從上面迭代方法的源碼中可知,最終執行的是LazyIterator#hasNextService判斷方法,該方法通過解析最終會得到實現類的全限定名稱;

private class LazyIterator implements Iterator<S> {
    private boolean hasNextService() {
        // 1、拼接名稱
        String fullName = PREFIX + service.getName();
        // 2、載入資源文件
        configs = loader.getResources(fullName);
        // 3、解析文件內容
        pending = parse(service, configs.nextElement());
        nextName = pending.next();
        return true;
    }
}

斷點截圖:

4、nextService方法

迭代器的next方法最終執行的是LazyIterator#nextService獲取方法,會基於上面hasNextService方法獲取的實現類全限定名稱,獲取其Class對象,進而得到實例化對象,緩存並返回;

private class LazyIterator implements Iterator<S> {
    private S nextService() {
        // 1、通過全限定命名獲取Class對象
        String cn = nextName;
        Class<?> c = Class.forName(cn, false, loader);
        // 2、實例化對象
        S p = service.cast(c.newInstance());
        // 3、放入緩存並返回該對象
        providers.put(cn, p);
        return p;
    }
}

斷點截圖:

三、SPI實踐

1、Driver驅動介面

在JDK中提供了資料庫驅動介面java.sql.Driver,無論是MySQL驅動包還是Druid連接池,都提供了該介面的實現類,通過SPI機制可以載入到這些驅動實現類;

public class DriverManager {
    private static void loadInitialDrivers() {
        AccessController.doPrivileged(new PrivilegedAction<Void>() {
            public Void run() {
                ServiceLoader<Driver> loadedDrivers = ServiceLoader.load(java.sql.Driver.class);
                Iterator<Driver> driversIterator = loadedDrivers.iterator();
            }
        });
    }
}

斷點截圖:

2、Slf4j日誌介面

SLF4J是門面模式的日誌組件,提供了標準的日誌服務SLF4JServiceProvider介面,在LogFactory日誌工廠類中,負責載入具體的日誌實現類,比如常用的Log4j或Logback日誌組件;

public final class LoggerFactory {
    static List<SLF4JServiceProvider> findServiceProviders() {
        // 服務載入
        ClassLoader classLoaderOfLoggerFactory = org.slf4j.LoggerFactory.class.getClassLoader();
        // 重點看該方法:【getServiceLoader()】
        ServiceLoader<SLF4JServiceProvider> serviceLoader = getServiceLoader(classLoaderOfLoggerFactory);
        // 迭代方法
        List<SLF4JServiceProvider> providerList = new ArrayList();
        Iterator<SLF4JServiceProvider> iterator = serviceLoader.iterator();
        while(iterator.hasNext()) {
            safelyInstantiate(providerList, iterator);
        }
        return providerList;
    }
}

斷點截圖:

四、參考源碼

文檔倉庫:
https://gitee.com/cicadasmile/butte-java-note

應用倉庫:
https://gitee.com/cicadasmile/butte-flyer-parent
Gitee主頁: https://gitee.com/cicadasmile/butte-java-note
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 目錄 一、面向對象編程快速入門 二、深刻認識面向對象 三、對象在電腦中的執行原理 四、類和對象的一些註意事項 五、其他語法:this 六、其他語法:構造器 七、其他語法:封裝 八、其他語法:實體JavaBean 九、面向對象編程綜合案例 十、補充知識:成員變數、局部變數的區別小結 前言 Stude ...
  • 昨天看到個視頻,彈幕挺有意思的,於是想著用Python給他全部扒下來。 代碼非常簡單,接下來我們看看 具體操作。 需要準備這些 軟體 Python 3.8 Pycharm 模塊使用 import requests 數據請求 import jieba 分詞 import wordcloud 詞雲 im ...
  • ### 歡迎訪問我的GitHub > 這裡分類和彙總了欣宸的全部原創(含配套源碼):[https://github.com/zq2599/blog_demos](https://github.com/zq2599/blog_demos) ### 本篇概覽 - 本篇的知識點是bean的生命周期回調:在 ...
  • 本文我將給大家介紹一個 apk 打包工具 VasDolly 的使用介紹、原理以及如何在服務端接入 VasDolly 進行服務端打渠道包操作。 # 使用介紹 ![](https://files.mdnice.com/user/40549/f5237f40-854b-43dd-9786-d0f7aff0 ...
  • 傳說中,有人因為只是遠遠的看了一眼法外狂徒張三就進去了😂 我現在是獲取他視頻,豈不是直接終生了🤩 網友:趕緊跑路吧 😏 好了話不多說,我們直接開始今天的內容吧! 你需要準備 環境使用 Python 3.8 Pycharm 模塊使用 import requests import csv impo ...
  • ## 6.1、場景模擬 ### 6.1.1、創建UserDao介面及實現類 ![image](https://img2023.cnblogs.com/blog/2052479/202308/2052479-20230805110743575-178752173.png) ``` package or ...
  • 寫這篇文章的時候,已經離我找工作有一段時間了,但是覺得這道題不管是面試還是日常的工作中,都會經常遇到,所以還是特意寫一篇文章,記錄下自己對Golang中`==`的理解。如文章中出現不對的地方,請不吝賜教,謝謝。 > 註意,以下文章內容是基於 go1.16.4 進行演示的,如果和你驗證時,結果不一致, ...
  • ## 什麼是Go? - Go是一個跨平臺、開源的編程語言 - Go可用於創建高性能應用程式 - Go是一種快速、靜態類型、編譯型語言,感覺上像動態類型、解釋型語言 - Go由Robert Griesemer、Rob Pike和Ken Thompson於2007年在Google開發 - Go的語法類似 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...