motan扩展机制

简介: motan第二篇,想写motan的rpc调用过程的,但项目中需要对motan进行扩展,所以本来就先记录下

motan第二篇,想写motan的rpc调用过程的,但项目中需要对motan进行扩展,所以本来就先记录下


引导


在一个框架或者在项目中提供编写一些服务时,会出现这种情况,会有一些默认的,但你知道只是很容易满足基本的个人需求,开发人员可能会实现扩展,想自己实现定义一个实现

处理方式

  1. 提供一个设置实现类的setter,开发者在初始化时调用一下
  2. 提供配置入口,给个密钥,配置上自定义类名
  3. 类似slf4j一样,提供桥接类


SPI


motan使用了spi的方式

SPI(Service Provider Interface),服务提供接口;也是一种服务发现机制

系统里抽象的各个模块,往往有很多不同的实现方案,
比如日志模块的方案,xml解析模块、jdbc模块的方案等。面向的对象的设计里,
我们一般推荐模块之间基于接口编程,模块之间不对实现类进行硬编码
。一旦代码里涉及具体的实现类,就违反了可拔插的原则,
如果需要替换一种实现,就需要修改代码。
为了实现在模块装配的时候能不在程序里动态指明,这就需要一种服务发现机制。
java spi就是提供这样的一个机制:为某个接口寻找服务实现的机制。
有点类似IOC的思想,就是将装配的控制权移到程序之外,在模块化设计中这个机制尤其重要。

SPI与API的区别

What is the difference between Service Provider Interface (SPI) and Application Programming Interface (API)?
More specifically, for Java libraries, what makes them an API and/or SPI?the API is the description of classes/interfaces/methods/... 
that you call and use to achieve a goalthe SPI is the description of classes/interfaces/methods/... 
that you extend and implement to achieve a goal
Put differently, the API tells you what a specific class/method does for you and the SPI tells you what you must do to conform.
Sometimes SPI and API overlap. 
For example in JDBC the Driver class is part of the SPI: 
If you simply want to use JDBC, you don't need to use it directly, but everyone who implements a JDBC driver must implement that class.
The Connection interface on the other hand is both SPI and API: 
You use it routinely when you use a JDBC driver and it needs to be implemented by the developer of the JDBC driver。


JDK SPI


使用jdk自带的ServiceLoader写一个示例:

一个接口

public interface Spi {    public void provide();
}

实现类

public class DefaultSpi implements Spi{    @Override
    public void provide() {
        System.out.println("默认spi实现");
    }
}

输入类

/**
 * 一个spi的demo
 *
 */
public class SpiDemoMain{
    public static void main( String[] args )
    {        ServiceLoader<Spi> spiServiceLoader = ServiceLoader.load(Spi.class);        Iterator<Spi> spiIterator = spiServiceLoader.iterator();        while ( spiIterator.hasNext()) {
            spiIterator.next().provide();
        }
    }
}

在META文件夹里面新建个服务文件夹,在services-IN文件夹里面新建一个com.jFk.spi.Spi文件

完整的代码可从https://github.com/zhuxingsheng/spidemo下载

ServiceLoader源码解析

原理很简单,一个类实现这个SPI机制

它的本源,也就是从某个地方加载服务实现类,文件名是服务接口名

定义文件的地方

private static final String PREFIX = "META-INF/services/";

类内部使用了延迟加载LazyIterator,在使用到了实现类的时候,才去实例化。

private S nextService() {            if (!hasNextService())                throw new NoSuchElementException();
            String cn = nextName;
            nextName = null;            Class<?> c = null;            try {
                c = Class.forName(cn, false, loader);
            } catch (ClassNotFoundException x) {
                fail(service,                     "Provider " + cn + " not found");
            }            if (!service.isAssignableFrom(c)) {
                fail(service,                     "Provider " + cn  + " not a subtype");
            }            try {            // 调用next方法时,才实例化
                S p = service.cast(c.newInstance());
                providers.put(cn, p);                return p;
            } catch (Throwable x) {
                fail(service,                     "Provider " + cn + " could not be instantiated",
                     x);
            }            throw new Error();          // This cannot happen
        }


莫坦斯皮


motan的spi,跟java spi差不多,但做了一些加大

先看官方文档

  1. 实现SPI扩展点接口
  2. 类添加注解 @Spi(scope = Scope.SINGLETON) //扩展形式,单例或多例 @SpiMeta(name = "motan")//name 表示扩展点的名称,根据名称加载扩展 @Activation( sequence = 100) //同类型支持扩展非生效顺序,部分扩展点。必填添加SPI实现${classpath}/MATA-INF/services/${SPI接口全名}文件添加SPI接口实现类全可参照motan-core模块/MATA-INF/services/下的配置

主要类就是com.weibo.api.motan.core.extension.ExtensionLoader 代码在https://github.com/zhuxingsheng/motan/blob/master/motan-core/src/main/java/com/weibo/api/ motan/core/extension/ExtensionLoader.java#100-99 其实很简单,需要额外的读取代码,请看懂

还有注解类

@Spi 指定类生命周期

@SpiMeta 给类一个别名,方便配置时使用

目录
相关文章
|
17天前
|
Dubbo 网络协议 Java
性能基础之常见RPC框架浅析
【4月更文挑战第23天】性能基础之常见RPC框架浅析
42 1
性能基础之常见RPC框架浅析
|
Dubbo Java 测试技术
分布式RPC框架性能大比拼 dubbo、motan、rpcx、gRPC、thrift的性能比较
Dubbo?是阿里巴巴公司开源的一个Java高性能优秀的服务框架,使得应用可通过高性能的 RPC 实现服务的输出和输入功能,可以和 Spring框架无缝集成。不过,略有遗憾的是,据说在淘宝内部,dubbo由于跟淘宝另一个类似的框架HSF(非开源)有竞争关系,导致dubbo团队已经解散(参见http://www.oschina.net/news/55059/druid-1-0-9?中的评论),反到是当当网的扩展版本仍在持续发展,墙内开花墙外香。
6894 0
|
17天前
|
XML 缓存 Dubbo
Dubbo的魔法之门:深入解析SPI扩展机制【八】
Dubbo的魔法之门:深入解析SPI扩展机制【八】
38 0
|
11月前
|
XML SQL Dubbo
Dubbo最核心功能——服务暴露的配置、使用及原理(2)
Dubbo最核心功能——服务暴露的配置、使用及原理
151 0
|
11月前
|
存储 缓存 Dubbo
Dubbo最核心功能——服务暴露的配置、使用及原理(1)
Dubbo最核心功能——服务暴露的配置、使用及原理
136 0
|
11月前
|
运维 监控 Dubbo
Dubbo协议异步单一长连接原理与优势
Dubbo协议异步单一长连接原理与优势
441 0
|
数据采集 网络协议 算法
RPC框架整体架构
RPC就是把拦截到的方法参数,转成可以在网络中传输的二进制,并保证在服务提供方能正确地还原出语义,最终实现像调用本地一样地调用远程的目的。
212 0
|
Dubbo Java 应用服务中间件
dubbo协议下的单一长连接与多线程并发如何协同工作
dubbo协议下的单一长连接与多线程并发如何协同工作
187 0
dubbo协议下的单一长连接与多线程并发如何协同工作
|
运维 Dubbo 中间件
Dubbo3 源码解读-宋小生-6:Dubbo的SPI扩展机制之普通扩展对象的创建与Wrapper机制的源码解析
> Dubbo3 已经全面取代 HSF2 成为阿里的下一代服务框架,2022 双十一基于 Dubbo3 首次实现了关键业务不停推、不降级的全面用户体验提升,从技术上,大幅提高研发与运维效率的同时地址推送等关键资源利用率提升超 40%,基于三位一体的开源中间件体系打造了阿里在云上的单元化最佳实践和统一标准,同时将规模化实践经验与技术创新贡献开源社区,极大的推动了开源技术与标准的发展。 > 本文是
173 0
|
Kubernetes Dubbo Cloud Native
Dubbo也支持基于应用粒度的服务发现机制啦
大家都知道,Spring Cloud和Dubbo早期版本在服务发现以及服务间通信方式上有很大的不同:Spring Cloud使用的是应用粒度的服务发现机制,而Dubbo则使用的是接口粒度的服务发现机制;Spring Cloud使用的是Http的协议进行服务间通信,而Dubbo则使用的是RPC基于Tcp层的方式进行通信。
Dubbo也支持基于应用粒度的服务发现机制啦

热门文章

最新文章

http://www.vxiaotou.com