java框架基礎之SPI機制實現及源碼解析

第java框架基礎之SPI機制實現及源碼解析目錄1定義2案例實現標準接口廠商的具體接口實現3SPI機制源碼分析3.1load加載過程3.2實例化過程

1定義

SPI的全名為ServiceProviderInterface，用于接口尋找服務實現類

實現方式標準制定者制定接口不同廠商編寫針對于該接口的實現類，并在jar的classpath:META-INF/services/全接口名稱文件中指定相應的實現類全類名開發(fā)者直接引入相應的jar，就可以實現為接口自動尋找實現類的功能

2案例實現

比如我們經?？吹降木彺骖怌ache,現在有非常多的緩存框架都會去實現這個接口

標準接口

publicinterfaceCache{

StringgetName();

TTget(Objectkey,ClassTtype);

voidput(Objectkey,Objectvalue);

voidevict(Objectkey);

voidclear();

廠商的具體接口實現

publicclassConcurrentMapCacheimplementsCache{

privatefinalStringname;

privatefinalConcurrentMapObject,Objectstore;

publicConcurrentMapCache(){

this("defaultMapCache");

publicConcurrentMapCache(Stringname){

this(name,newConcurrentHashMap(256),true);

publicConcurrentMapCache(Stringname,ConcurrentMapObject,Objectstore,booleanallowNullValues){

=name;

this.store=store;

@Override

publicfinalStringgetName(){

return;

@Override

publicTTget(Objectkey,ClassTtype){

Objectvalue=this.store.get(key);

if(value!=nulltype!=null!type.isInstance(value)){

thrownewIllegalStateException("Cachedvalueisnotofrequiredtype["+type.getName()+"]:"+value);

return(T)value;

@Override

publicvoidput(Objectkey,Objectvalue){

this.store.putIfAbsent(key,value);

@Override

publicvoidevict(Objectkey){

this.store.remove(key);

@Override

publicvoidclear(){

this.store.clear();

注意:一定要有默認無參構造器，否則之后無法通過SPI機制實例化對象

配置地址

在resouce下的META-INF\services文件下的spi.Cache文件內容是服務類的全限命名：spi.ConcurrentMapCache

打包jar并引入到項目

測試

publicclassCacheSpiTest{

publicstaticvoidmain(String[]args){

ServiceLoaderCacheserviceLoader=ServiceLoader.load(Cache.class);

IteratorCacheiterator=serviceLoader.iterator();

while(iterator.hasNext()){

Cachecache=iterator.next();

System.out.println(cache.getName());

cache.put("user","nana");

System.out.println(cache.get("user",String.class));

打印結果：

defaultMapCache

nana

說明獲取到了定制接口的實現類對象

通過上述例子，我們知道ServiceLoader是用于通過接口獲取接口實現類的工具

3SPI機制源碼分析

3.1load加載過程

ServiceLoader成員變量

//SPI約定獲取擴展接口路徑的文件

privatestaticfinalStringPREFIX="META-INF/services/";

//基礎約定接口

privatefinalClassSservice;

privatefinalClassLoaderloader;

//權限控制上下文

privatefinalAccessControlContextacc;

//廠商接口實現類的實例化對象集合

privateLinkedHashMapString,Sproviders=newLinkedHashMap();//以初始化的順序緩存接口全名稱,實現類實例

//懶加載迭代器

privateLazyIteratorlookupIterator

load()初始化

publicvoidreload(){

providers.clear();

lookupIterator=newLazyIterator(service,loader);

privateServiceLoader(ClassSsvc,ClassLoadercl){

service=Objects.requireNonNull(svc,"Serviceinterfacecannotbenull");

loader=(cl==null)ClassLoader.getSystemClassLoader():cl;

acc=(System.getSecurityManager()!=null)AccessController.getContext():null;

reload();

load()方法并沒有實例化具體實現類，而是加載需要實例化的對象路徑

3.2實例化過程

ClassSservice;//通用接口

ClassLoaderloader;//類加載器

EnumerationURLconfigs=null;//廠商接口文件URL的集合

IteratorStringpending=null;//接口具體實現的路徑類名列表

publicbooleanhasNext(){

if(acc==null){//訪問控制上下文是否為空

returnhasNextService();

}else{

PrivilegedActionBooleanaction=newPrivilegedActionBoolean(){

publicBooleanrun(){returnhasNextService();}

returnAccessController.doPrivileged(action,acc);

publicSnext(){

if(acc==null){

returnnextService();

}else{

PrivilegedActionSaction=newPrivilegedActionS(){

publicSrun(){returnnextService();}

returnAccessController.doPrivileged(action,acc);

hasNext():先從provider中查找，如果有，返回true；如果沒有，通過LazyIterator來進行查找.在hasNext()方法中會獲取當前需要實例化的類名nextName，然后在next()方法中具體實例化

next():先從provider中直接獲取，如果有，返回實現類對象實例；如果沒有，通過LazyIterator中nextService()來進行獲取

privateSnextService(){

if(!hasNextService())//獲取nextName需要加載的類名

thrownewNoSuchElementException();

Stringcn=nextName;

nextName=null;

Classc=null;

try{

c=Class.forName(cn,false,loader);

}catch(ClassNotFoundExceptionx){

fail(service,

"Provider"+cn+"notfound");

if(!service.isAssignableFrom(c)){

fail(service,

"Provider"+cn+"notasubtype");

try{

Sp=service.cast(c.newInstance());//初始化類并類型轉換成Cache對象

providers.put(cn,p);放入實例化對象集合中

returnp;

}catch