dubbo启动服务之容器(Container)---spi原理

2018-05-07

讲解dubbo启动服务的时候先来了解下java的spi机制

1,dubbo的服务端的spring xml文件在dubbo的源码中默认在META-INF/spring上,它会自动在这个目录加载,也可在dubbo.properties配置

2,dubbo的容器启动是基于spi原理的,所以实现了一个接口的子类,在dubbo的加载器加载下会对其所有子类生成代理实例,然后一个一个遍历使用

 3,微服务是基于独立功能模块来说,分层是基于每个微服务的接口(消费端-服务端)

一:SPI 简介

SPI 全称为 (Service Provider Interface) ,是JDK内置的一种服务提供发现机制。 目前有不少框架用它来做服务的扩展发现, 简单来说,它就是一种动态替换发现的机制, 举个例子来说, 有个接口,想运行时动态的给它添加实现,你只需要添加一个实现,而后,把新加的实现,描述给JDK知道就行啦(通过改一个文本文件即可) ,公司内部目前Dubbo框架就基于SPI机制提供扩展功能。

代码例子

dubbo启动服务之容器(Container)---spi原理

public interface Cmand {
    public void execute();
}
public class ShutdownCommand implements Cmand {
    public void execute() {
        System.out.println("shutdown....");  
    }
}
public class StartCommand implements Cmand {
    public void execute() {
        System.out.println("start....");
    }
}
public class SPIMain {
    public static void main(String[] args) {
        ServiceLoader<Cmand> loader = ServiceLoader.load(Cmand.class);
        System.out.println(loader);
        
        
        for (Cmand Cmand : loader) {
            Cmand.execute();
        }
    }
}

配置:

com.unei.serviceloader.impl.ShutdownCommand  

com.unei.serviceloader.impl.StartCommand 

运行结果:

java.util.ServiceLoader[com.unei.serviceloader.Cmand]
shutdown....
start....

相关原理解答

1.配置文件为什么要放在META-INF/services下面?

ServiceLoader类定义如下:

private static final String PREFIX = "META-INF/services/"; (JDK已经写死了)

但是如果ServiceLoader在load时提供Classloader,则可以从其他的目录读取。

2.ServiceLoader读取实现类是什么时候实例化的? 

public void reload() {
        providers.clear();
        lookupIterator = new LazyIterator(service, loader);
    }
    private ServiceLoader(Class<S> svc, ClassLoader cl) {
        service = Objects.requireNonNull(svc, "Service interface cannot be null");
        loader = (cl == null) ? ClassLoader.getSystemClassLoader() : cl;
        acc = (System.getSecurityManager() != null) ? AccessController.getContext() : null;
        reload();
    }

二:dubbo服务启动之Container

Dubbo的总体架构如下图所示:

dubbo启动服务之容器(Container)---spi原理

1:dubbo几大角色

Provider: 暴露服务的服务提供方。

Consumer: 调用远程服务的服务消费方。

Registry: 服务注册与发现的注册中心。

Monitor: 统计服务的调用次调和调用时间的监控中心。

Container: 服务运行容器。

2:Container详解

Dubbo的Container详解模块,是一个独立的容器,因为服务通常不需要Tomcat/JBoss等Web容器的特性,没必要用Web容器去加载服务。

       服务容器只是一个简单的Main方法,并加载一个简单的Spring容器,用于暴露服务。

  

     com.alibaba.dubbo.container.Main 是服务启动的主类

     dubbo启动服务之容器(Container)---spi原理

     通过图可以了解Container接口有只有 start()  stop()他的实现类

     他的实现类有SpringContainer、Log4jContainer、JettyContainer、JavaConfigContainer、LogbackContainer。

     当然你也可以自定义容器

     官网:http://dubbo.io/Developer+Guide.htm#DeveloperGuide-ContainerSPI

     

     Spring Container

     自动加载META-INF/spring目录下的所有Spring配置。 (这个在源码里面已经写死了DEFAULT_SPRING_CONFIG = "classpath*:META-INF/spring/*.xml" 所以服务端的主配置放到META-INF/spring/这个目录下)

     配置:(配在java命令-D参数或者dubbo.properties中) 

     dubbo.spring.config=classpath*:META-INF/spring/*.xml ----配置spring配置加载位置Container

     Jetty Container

     启动一个内嵌Jetty,用于汇报状态。 

     配置:(配在java命令-D参数或者dubbo.properties中) 

     dubbo.jetty.port=8080 ----配置jetty启动端口 

     dubbo.jetty.directory=/foo/bar ----配置可通过jetty直接访问的目录,用于存放静态文件 

     dubbo.jetty.page=log,status,system ----配置显示的页面,缺省加载所有页面

     Log4j Container

     自动配置log4j的配置,在多进程启动时,自动给日志文件按进程分目录。 

     配置:(配在java命令-D参数或者dubbo.properties中) 

     dubbo.log4j.file=/foo/bar.log ----配置日志文件路径 

     dubbo.log4j.level=WARN ----配置日志级别 

     dubbo.log4j.subdirectory=20880 ----配置日志子目录,用于多进程启动,避免冲突

     

3:容器启动

   从上面的我们知道只需执行main方法就能启动服务,那么默认到底是调用那个容器呢?

   查看com.alibaba.dubbo.container.Container接口我们发现他上面有一个注解@SPI("spring")

   通过上面对SPI的了解我们猜想他应该有对应的文件 如图:

   dubbo启动服务之容器(Container)---spi原理

   

   通过上图可以知道默认调用的是com.alibaba.dubbo.container.spring.SpringContainer

   这里main方法里面dubbo他们自定义了一个loader,叫ExtensionLoader

   所以目前启动容器的时候我们可以选:spring、javaconfig、jetty、log4j、logback等参数

   

4:容器停止

Dubbo是通过JDK的ShutdownHook来完成优雅停机的,所以如果用户使用"kill -9    PID"等强制关闭指令,是不会执行优雅停机的,只有通过"kill PID"时,才会执行。

停止源码(在Main方法里面):

if ("true".equals(System.getProperty(SHUTDOWN_HOOK_KEY))) {
            Runtime.getRuntime().addShutdownHook(new Thread() {
                public void run() {
                    for (Container container : containers) {
                        try {
                            container.stop();
                            logger.info("Dubbo " + container.getClass().getSimpleName() + " stopped!");
                        } catch (Throwable t) {
                            logger.error(t.getMessage(), t);
                        }
                        synchronized (Main.class) {
                            running = false;
                            Main.class.notify();
                        }
                    }
                }
            });
            }

   

  原理:

服务提供方

停止时,先标记为不接收新请求,新请求过来时直接报错,让客户端重试其它机器。

然后,检测线程池中的线程是否正在运行,如果有,等待所有线程执行完成,除非超时,则强制关闭。

服务消费方

停止时,不再发起新的调用请求,所有新的调用在客户端即报错。

然后,检测有没有请求的响应还没有返回,等待响应返回,除非超时,则强制关闭。

5:服务jar打包

   我这里用到了maven打,在pom文件里面添加以下内容

<build>

<plugins>

<plugin>

<groupId>org.apache.maven.plugins</groupId>

<artifactId>maven-jar-plugin</artifactId>

<version>2.5</version>

<configuration>

<archive>

<manifest>

<addClasspath>true</addClasspath>

<classpathPrefix>lib</classpathPrefix>

<mainClass>com.alibaba.dubbo.container.Main</mainClass>

<useUniqueVersions>false</useUniqueVersions>

</manifest>

</archive>

</configuration>

</plugin>

<plugin>

<groupId>org.apache.maven.plugins</groupId>

<artifactId>maven-dependency-plugin</artifactId>

<version>2.5</version>

<executions>

<execution>

<id>copy-dependencies</id>

<phase>pre-package</phase>

<goals>

<goal>copy</goal>

</goals>

<configuration>

<artifactItems>

<artifactItem>

<groupId>com.demo.dubbox.service</groupId>

<artifactId>demo_order_api</artifactId>

<outputDirectory>${project.build.directory}/lib</outputDirectory>

<overWrite>true</overWrite>

</artifactItem>

</artifactItems>

</configuration>

</execution>

</executions>

</plugin>

</plugins>

<resources>

<resource>

<targetPath>${project.build.directory}/classes</targetPath>

<directory>src/main/resources</directory>

<filtering>true</filtering>

<includes>

<include>**/*.xml</include>

<include>**/*.properties</include>

</includes>

</resource>

<resource>

<targetPath>${project.build.directory}/classes/META-INF/spring</targetPath>

<directory>src/main/resources/</directory>

<filtering>true</filtering>

<!-- 这个是主配置,把他打包到META-INF/spring/ 其他的xml都在spring-all.xml里面包含了 当然名字自定义-->

<includes>

<include>spring-all.xml</include>

</includes>

</resource>

</resources>

</build>

6:简单启动脚本

#!/bin/sh
 JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_40.jdk/Contents/Home
 JAVA_OPTS="-Xms256m -Xmx512m"
 java  -jar XXX.jar > "log.log" 2>&1

相关推荐