簡單分析JDK中「SPI」的原理
一、SPI簡介
1、概念
SPI即service-provider-interface的簡寫；
JDK內(nèi)置的服務提供加載機制，可以為服務接口加載實現(xiàn)類，解耦是其核心思想，也是很多框架和組件的常用手段；
2、入門案例
2.1 定義接口
就是普通的接口，在SPI的機制中稱為【service】，即服務；
public interface Animal {
String animalName () ;
}
2.2 兩個實現(xiàn)類
提供兩個模擬用來測試，就是普通的接口實現(xiàn)類，在SPI的機制中稱為【service-provider】即服務提供方；
CatAnimal實現(xiàn)類；
public class CatAnimal implements Animal {
@Override
public String animalName() {
System.out.println("Cat-Animal：布偶貓");
return "Ragdoll";
}
}
DogAnimal實現(xiàn)類；
public class DogAnimal implements Animal {
@Override
public String animalName() {
System.out.println("Dog-Animal：哈士奇");
return "husky";
}
}
2.3 配置文件
文件目錄：在代碼工程中創(chuàng)建META-INF.services文件夾；
文件命名：butte.program.basics.spi.inf.Animal，即全限定接口名稱；
文件內(nèi)容：添加相應實現(xiàn)類的全限定命名；
butte.program.basics.spi.impl.CatAnimal butte.program.basics.spi.impl.DogAnimal
2.4 測試代碼
通過ServiceLoader加載配置文件中指定的服務實現(xiàn)類，然后遍歷并調(diào)用Animal接口方法，從而執(zhí)行不同服務提供方的具體邏輯；
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());
}
}
}
結(jié)果輸出
Cat-Animal：布偶貓 \n animal-name:ragdoll Dog-Animal：哈士奇 \n animal-name:husky
二、原理分析
1、ServiceLoader結(jié)構(gòu)
很顯然，分析SPI機制的原理，從ServiceLoader源碼中l(wèi)oad方法切入即可，但是需要先從核心類的結(jié)構(gòu)開始分析；
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;
// 創(chuàng)建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構(gòu)造方法
*/
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;
// 實現(xiàn)類URL
Enumeration<URL> configs = null;
// 實現(xiàn)類全名
Iterator<String> pending = null;
// 下個實現(xiàn)類全名
String nextName = null;
}
}
斷點截圖：
2、iterator迭代方法
在ServiceLoader類的迭代器方法中，實際使用的是LazyIterator內(nèi)部類的方法；
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方法
從上面迭代方法的源碼中可知，最終執(zhí)行的是LazyIterator#hasNextService判斷方法，該方法通過解析最終會得到實現(xiàn)類的全限定名稱；
private class LazyIterator implements Iterator<S> {
private boolean hasNextService() {
// 1、拼接名稱
String fullName = PREFIX + service.getName();
// 2、加載資源文件
configs = loader.getResources(fullName);
// 3、解析文件內(nèi)容
pending = parse(service, configs.nextElement());
nextName = pending.next();
return true;
}
}
斷點截圖：
4、nextService方法
迭代器的next方法最終執(zhí)行的是LazyIterator#nextService獲取方法，會基于上面hasNextService方法獲取的實現(xiàn)類全限定名稱，獲取其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驅(qū)動接口
在JDK中提供了數(shù)據(jù)庫驅(qū)動接口java.sql.Driver，無論是MySQL驅(qū)動包還是Druid連接池，都提供了該接口的實現(xiàn)類，通過SPI機制可以加載到這些驅(qū)動實現(xiàn)類；
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日志工廠類中，負責加載具體的日志實現(xiàn)類，比如常用的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; } }
斷點截圖：
到此這篇關于簡單分析JDK中「SPI」的原理的文章就介紹到這了,更多相關JDK中「SPI」的原理內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
SpringBoot解析指定Yaml配置文件的實現(xiàn)過程
這篇文章主要介紹了SpringBoot解析指定Yaml配置文件,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-03-03
本文介紹了限流算法的基本概念和常見的限流算法,包括計數(shù)器算法、漏桶算法和令牌桶算法,還介紹了如何在Spring?Boot中使用Guava庫和自定義注解以及AOP實現(xiàn)接口限流功能,感興趣的朋友一起看看吧2024-12-12
@Autowired是Spring框架中的一個核心注解,用于實現(xiàn)依賴注入,它允許Spring容器自動裝配依賴,從而解耦代碼、提高可測試性和可維護性,該注解可以用于字段、構(gòu)造器和Setter方法上,并且可以結(jié)合@Qualifier注解解決依賴沖突,理解@Autowired`的使用對于掌握Spring開發(fā)至關重要2025-11-11
Spring與Struts整合之讓Spring管理控制器操作示例
這篇文章主要介紹了Spring與Struts整合之讓Spring管理控制器操作,結(jié)合實例形式詳細分析了Spring管理控制器相關配置、接口實現(xiàn)與使用技巧,需要的朋友可以參考下2020-01-01
這篇文章主要給大家介紹了關于使用JAVA命令運行JAR包以及日志輸出的相關資料,文中通過代碼示例介紹的非常詳細,對大家學習或者使用java具有一定的參考借鑒價值,需要的朋友可以參考下2023-09-09
Java中防止重復提交的八種解決方案(最后一種很優(yōu)雅)
重復提交是指用戶在短時間內(nèi)多次發(fā)送相同請求到服務端,導致數(shù)據(jù)被多次處理的現(xiàn)象,下面這篇文章主要介紹了Java中防止重復提交的八種解決方案的相關資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2026-03-03
這篇文章主要介紹了springboot整合阿里云oss上傳的方法示例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-08-08
SpringBoot中實現(xiàn)數(shù)據(jù)脫敏處理的方法詳解
項目開發(fā)中,在處理敏感信息時,數(shù)據(jù)脫敏是一項重要的安全措施,本文主要為大家介紹了如何在SpringBoot項目中進行數(shù)據(jù)脫敏處理,有需要的可以了解下2025-03-03
在Java開發(fā)中,我們經(jīng)常會遇到各種性能問題、內(nèi)存泄漏、線程阻塞等問題,這些問題往往難以通過常規(guī)的日志和監(jiān)控工具來定位和解決,Arthas作為一款開源的Java診斷工具,提供了強大的實時監(jiān)控和診斷功能,本文將詳細介紹Arthas的安裝、基本使用以及一些常用命令2025-02-02
在本篇文章里小編給大家整理的是一篇關于Java Mybatis架構(gòu)設計詳解內(nèi)容，對此有興趣的朋友們可以參考下,希望能夠給你帶來幫助2021-11-11