Java的SPI机制详解

作者:京东物流 杨苇苇

1.SPI简介

SPI(Service Provicer Interface)是Java语言提供的一种接口发现机制,用来实现接口和接口实现的解耦。简单来说,就是系统只需要定义接口规范以及可以发现接口实现的机制,而不需要实现接口。

SPI机制在Java中应用广泛。例如:JDBC中的数据库连接驱动使用SPI机制,只定义了数据库连接接口的规范,而具体实现由各大数据库厂商实现,不同数据库的实现不同,我们常用的mysql的驱动也实现了其接口规范,通过这种方式,JDBC数据库连接可以适配不同的数据库。

SPI机制在各种框架中也有应用,例如:springboot的自动装配中查找spring.factories文件的步骤就是应用了SPI机制;dubbo也对Java的SPI机制进行扩展,实现了自己的SPI机制。

2.SPI入门案例

2.1.创建工程

我们刚才在介绍中说过了,SPI机制需要定义接口规范,这里我们以一个简单的接口案例来说明。

首先我们需要创建四个工程:

•spi-interface,这里定义SPI的接口类:Person

•spi-impl1,这里定义接口的第一个实现类:Teacher

•spi-impl2,这里定义接口的第二个实现类:Student

•spi-test,这里通过SPI机制加载所有实现类进行测试

在这里插入图片描述

2.2.创建SPI接口规范

接口如下所示:

1package com.jd.spi; 2 3public interface Person { 4 5 String favorite(); 6}

2.3.创建实现类1项目

2.3.1.创建接口

接口如下所示:

1package com.jd.spi; 2 3 4public class Teacher implements Person { 5 6 public String favorite() { 7 return "老师喜欢给学生上课"; 8 } 9}

2.3.2.创建spi配置文件

如下图所示,在项目的resources文件夹下创建两个文件夹META-INF/services,然后在文件夹下面创建名称为com.jd.spi.Person的文件,其文件的内容为当前项目的接口实现类com.jd.spi.Teacher。

在这里插入图片描述

2.4.创建实现类2项目

2.4.1.创建实现类2

接口如下所示:

1package com.jd.spi; 2 3public class Student implements Person { 4 public String favorite() { 5 return "学生喜欢努力学习"; 6 } 7}

2.4.2.创建spi配置文件

如下图所示,在项目的resources文件夹下创建两个文件夹META-INF/services,然后在文件夹下面创建名称为com.jd.spi.Person的文件,其文件的内容为当前项目的接口实现类com.jd.spi.Student。

在这里插入图片描述

2.5.创建测试项目

2.5.1.引入3个maven依赖

这里需要引入接口定义项目和两个接口实现项目。

如下所示:

1 <dependencies> 2 <dependency> 3 <groupId>org.example</groupId> 4 <artifactId>spi-interface</artifactId> 5 <version>1.0-SNAPSHOT</version> 6 </dependency> 7 <dependency> 8 <groupId>org.example</groupId> 9 <artifactId>spi-impl1</artifactId> 10 <version>1.0-SNAPSHOT</version> 11 </dependency> 12 <dependency> 13 <groupId>org.example</groupId> 14 <artifactId>spi-impl2</artifactId> 15 <version>1.0-SNAPSHOT</version> 16 </dependency> 17 </dependencies>

2.5.2.创建测试类

如下所示:

1package com.jd.spi; 2 3import java.util.Iterator; 4import java.util.ServiceLoader; 5 6public class SPITest { 7 8 public static void main(String[] args) { 9 ServiceLoader<Person> loader = ServiceLoader.load(Person.class); 10 for(Iterator<Person> it = loader.iterator(); it.hasNext();){ 11 Person person = it.next(); 12 System.out.println(person.favorite());; 13 } 14 } 15}

运行测试类,其结果如下所示:

在这里插入图片描述

我们发现,Java的SPI机制获取了所有Person类的实现类,并执行其对应的favorite方法。

3.SPI机制的原理

3.1.ServiceLoader的核心属性

其核心机制就是ServiceLoader类的load方法,下面我们将从源码来分析其原理。

首先我们先看下ServiceLoader的核心属性:

1public final class ServiceLoader<S> 2 implements Iterable<S> 3{ 4 5 private static final String PREFIX = "META-INF/services/"; 6 7 // The class or interface representing the service being loaded 8 private final Class<S> service; 9 10 // The class loader used to locate, load, and instantiate providers 11 private final ClassLoader loader; 12 13 // The access control context taken when the ServiceLoader is created 14 private final AccessControlContext acc; 15 16 // Cached providers, in instantiation order 17 private LinkedHashMap<String,S> providers = new LinkedHashMap<>(); 18 19 // The current lazy-lookup iterator 20 private LazyIterator lookupIterator;

这个PREFIX属性、providers属性和lookupIterator属性将在后续的代码中使用到,我们发现PREFIX属性就是示例中说的META-INF/services路径。

3.2.ServiceLoader的遍历器

示例中,我们会获取serviceLoader的遍历器iterator,其方法如下所示:

1 public Iterator<S> iterator() { 2 return new Iterator<S>() { 3 4 Iterator<Map.Entry<String,S>> knownProviders 5 = providers.entrySet().iterator(); 6 7 public boolean hasNext() { 8 if (knownProviders.hasNext()) 9 return true; 10 return lookupIterator.hasNext(); 11 } 12 13 public S next() { 14 if (knownProviders.hasNext()) 15 return knownProviders.next().getValue(); 16 return lookupIterator.next(); 17 } 18 19 public void remove() { 20 throw new UnsupportedOperationException(); 21 } 22 23 }; 24 }

然后需要执行遍历器的next方法获取元素,其next方法执行的是lookupIterator.next()

接下来我们来看下lookupIterator的next方法:

1 public S next() { 2 if (acc == null) { 3 return nextService(); 4 } else { 5 PrivilegedAction<S> action = new PrivilegedAction<S>() { 6 public S run() { return nextService(); } 7 }; 8 return AccessController.doPrivileged(action, acc); 9 } 10 }

其执行的是nextService方法,如下所示:

1 private S nextService() { 2 if (!hasNextService()) 3 throw new NoSuchElementException(); 4 String cn = nextName; 5 nextName = null; 6 Class<?> c = null; 7 try { 8 c = Class.forName(cn, false, loader); 9 } catch (ClassNotFoundException x) { 10 fail(service, 11 "Provider " + cn + " not found"); 12 } 13 if (!service.isAssignableFrom(c)) { 14 fail(service, 15 "Provider " + cn + " not a subtype"); 16 } 17 try { 18 S p = service.cast(c.newInstance()); 19 providers.put(cn, p); 20 return p; 21 } catch (Throwable x) { 22 fail(service, 23 "Provider " + cn + " could not be instantiated", 24 x); 25 } 26 throw new Error(); // This cannot happen 27 }

nextService方法首先执行hasNextService方法,如下所示:

1 private boolean hasNextService() { 2 if (nextName != null) { 3 return true; 4 } 5 if (configs == null) { 6 try { 7 String fullName = PREFIX + service.getName(); 8 if (loader == null) 9 configs = ClassLoader.getSystemResources(fullName); 10 else 11 configs = loader.getResources(fullName); 12 } catch (IOException x) { 13 fail(service, "Error locating configuration files", x); 14 } 15 } 16 while ((pending == null) || !pending.hasNext()) { 17 if (!configs.hasMoreElements()) { 18 return false; 19 } 20 pending = parse(service, configs.nextElement()); 21 } 22 nextName = pending.next(); 23 return true; 24 }

这个方法会执行String fullName = PREFIX + service.getName(),而PREFIX就是我们前面刚才说的非常重要的属性,其值为META-INF/services/service就是接口类,其最终的fullName指的就是META-INF/services文件夹下的名称为com.jd.spi.Person的文件。

接着会执行configs = loader.getResources(fullName)方法,这个方法这里不做详细描述,其主要功能就是获取类路径下所有相对路径为fullName的所有文件的URL对象。

然后会执行pending = parse(service, configs.nextElement())方法,这个方法这里也不详细描述,其主要功能是读取文件,将文件内容变成字符串,然后nextName就被赋值为当前文件的内容,即实现类的接口全限定名

因此,执行hasNextService()方法后,nextName被赋值为一个实现类的全限定名。

我们继续看上面的nextService()方法,其最终会执行c = Class.forName(cn, false, loader)方法,这个方法很明显就是通过反射实例化一个对象。通过一系列操作,最终返回了对应实现类的对象。

3.3.流程总结

我们将其总结为以下几个步骤:

1.创建ServiceLoader对象

2.创建迭代器lookupIterator

3.通过迭代器的hasNextService方法读取类路径下META-INF/services目录的所有名称为接口全限定名的文件,将其内容存入configs对象中

4.从configs对象中获取实现类的全限定名,然后通过反射实例化对象

从上述流程,我们也可以总结实现SPI的几点重要信息:

1.实现工程必须在类路径下的META-INF/services目录下创建接口全限定名的文件,其文件内容必须是接口实现类的全限定名

2.实现类必须有一个无参构造方法,因为SPI默认是使用无参构造方法实例化对象的

4.总结

本文首先概述了Java的SPI机制,随后阐述了其基本使用方法,最后深入探讨了其实现原理。SPI在Java语言体系中具有广泛应用,能够有效地实现系统解耦,众多框架基于此机制进行了拓展和优化,从而实现了更为强大的SPI机制。掌握SPI的使用技巧可以帮助我们设计出更为灵活的系统,而深入理解其原理则有助于提升我们的技术水平。

点赞
收藏

评论区

加载中...

相关推荐

可插拔组件设计机制—SPI

SPI的全称是ServiceProviderInterface,即提供服务接口;是一种服务发现机制,SPI的本质是将接口实现类的全限定名配置在文件中,并由服务加载器读取配置文件,加载实现类。本篇文章聚焦SPI的使用场景及使用介绍。

Dubbo 扩展点加载机制:从 Java SPI 到 Dubbo SPI

!(https://oscimg.oschina.net/oscnet/up1aa4ada0efc8a144d35d25b3443d951c7e3.JPEG)SPI全称为ServiceProviderInterface,是一种服务发现机制。当程序运行调用接口时,会根据配置文件或默认规则信息加载对应的实现类。所以在程序中并没有直接指定使用接口

Dubbo实践(七)扩展点

与JDK的SPI机制类似,Dubbo也在METAINF路径下定义了多种扩展接口。只是JDKSPI机制是Java后台帮你实现读取文件并对接具体的实现类,而Dubbo是自己去读文件。扩展点配置扩展点机制有几个要点:1. 根据关键字去读取配置文件,获得具体的实现类比如在dubboprovider.xml文件中配置:<dub

JAVA的SPI机制

JAVA的SPI机制是什么?SPI(ServiceProviderInterface):,“服务提供者接口”,是指在服务使用方角度提出的“接口要求”,是对“服务提供方”提出的约定,简单说就是:“我需要这样的服务,现在你们来满足”。是不是看起来很高深的样子.其实特别简单我们先来一个例子,大家更容易理解什么是JA

Java编程技术之浅析SPI服务发现机制

SPI服务发现机制SPI是JavaJDK内部提供的一种服务发现机制。SPIServiceProviderInterface,服务提供接口,是JavaJDK内置的一种服务发现机制通过在ClassPath路径下的METAINF/services文件夹查找文件,自动加载文件里所定义的类

浅析Java - SPI机制 | 京东云技术团队

SPI是什么SPI全称ServiceProviderInterface,是Java提供的一套用来被第三方实现或者扩展的API,它可以用来启用框架扩展和替换组件。整体机制如下图JavaSPI实际上是“基于接口的编程+策略模式+配置文件”组合实现的动态加载机制