当服务集群规模进一步扩大，带动IT治理结构进一步升级，需要实现动态部署，进行流动计算，现有分布式服务架构不 会带来阻力。下图是未来可能的一种架构:

 

 

 

框架分层结构中，各个层次的设计要求：

1. 服务接口层（service）：该层是与实际业务逻辑相关的，根据服务提供方和服务消费方的业务设计对应的接口和实现
2. 配置层（Config）：对外配置接口，以ServiceConfig和ReferenceConfig为中心，可以直接new配置类，也可以通过spring解析配置生成配置类
3. 服务代理层（Proxy）：服务接口透明代理，生成服务的客户端stub和服务器端Skeleton，以ServiceProxy为中心，扩展接口为ProxyFactory
4. 服务注册层（Registry）：封装服务地址的注册与发现，以服务URL为中心，扩展接口为RegistryFactory、Registry和RegistryService。可能没有服务注册中心，此时服务提供方直接暴露服务。
5. 集群层（Cluster）：封装多个提供者的路由及负载均衡，并桥接注册中心，以Invoker为中心，扩展接口为Cluster、Directory、Router、和LoadBalance。将多个服务提供房租和为一个提供服务方，实现服务消费来透明，只需要与一个服务提供方进行交互。
6. 监控层(Monitor)：RPC调用次数和调用时间监控，以Statistics为中心，扩展接口为MonitorFactory、Monitor和MonitorService
7. 远程调用层（Protocol）：封装RPC调用，以Invocation和Result为中心，扩展接口为Protocol、Invoker和Exporter。Protocol是服务域，它是Invoker暴露和引用的主功能入口，它负责Invoker的声明周期管理。Invoker是实体域，它是dubbo的核心模型，其他模型都向他靠拢，它代表一个可以执行的体，可向他发起invoker电泳，他有可能是一个本地的实现，也有可能是一个远程的实现，也可能一个集群实现
8. 信息交换层（Exchange）：封装请求响应模式，同步转异步，以Request和Response为中心，扩展接口为Exchanger、ExchangeChannel、ExchangeClient和ExchangeServer。
9. 网络传输层（Transport）：抽象main和netty为统一接口，以Message为中心，扩展接口为:channel、Transporter、Client、Server、Codec
10. 数据序列化层（Serialize）:可复用的一些工具，扩展接口为Serialization、ObjectInput、ObjectOutput和ThreadPool

节点角色说明

节点	角色说明
Deployer	自动部署服务的本地代理
Repository	仓库用于存储服务应用发布包
Scheduler	调度中心基于访问压力自动增减服务提供者
Admin	统一管理控制台
Registry	服务注册与发现的注册中心
Monitor	统计服务的调用次数和调用时间的监控中心

Demo:

• 创建一个普通的Maven工程 dubboparent，在pom.xml文件中导入要使用的坐标

  <dependencies>

         <dependency>

             <groupId>com.alibaba</groupId>

             <artifactId>dubbo</artifactId>

             <version>2.6.</version>

         </dependency>

         <dependency>

             <groupId>com.101tec</groupId>

             <artifactId>zkclient</artifactId>

             <version>0.9</version>

         </dependency>

         <dependency>

             <groupId>org.apache.zookeeper</groupId>

             <artifactId>zookeeper</artifactId>

             <version>3.4.</version>

             <exclusions>

                 <exclusion>

                     <groupId>log4j</groupId>

                     <artifactId>log4j</artifactId>

                 </exclusion>

             </exclusions>

         </dependency>

         <dependency>

             <groupId>log4j</groupId>

             <artifactId>log4j</artifactId>

             <version>1.2.</version>

         </dependency>

         <dependency>

             <groupId>junit</groupId>

             <artifactId>junit</artifactId>

             <version>4.12</version>

             <scope>test</scope>

         </dependency>

         <dependency>

             <groupId>org.springframework</groupId>

             <artifactId>spring-test</artifactId>

             <version>4.3..RELEASE</version>

             <scope>test</scope>

         </dependency>

     </dependencies>

• 在dubboparent的上面新建一个模块dubbo-provider的工程和dubbo-consumer的工程和dubbo-common(分别作为提供者和消费者)。
• 上述的工程建好之后，在三个子模块的pom的文件中会自动引入父工程例如：

       <parent>
  
           <artifactId>dubbo-parent</artifactId>
  
           <groupId>zh.stu.Dubbo</groupId>
  
           <version>1.0-SNAPSHOT</version>
  
       </parent>

• 当然在父工程中也会引入子工程例如：

       <modules>
  
           <module>dubbo-provider</module>
  
           <module>dubbo-consumer</module>
  
           <module>dubbo-consumer</module>
  
           <module>dubbo-common</module>
  
       </modules>

  每一个模块都会加入进来

• 因为consumer和provider模块都会依赖common模块，所以在他们两个的模块中添加common的依赖（引入common）

       <dependencies>
  
           <dependency>
  
               <groupId>zh.stu.Dubbo</groupId>
  
               <artifactId>dubbocommon</artifactId>
  
               <version>1.0-SNAPSHOT</version>
  
           </dependency>
  
       </dependencies>

• 在common模块中添加一个接口

   package zh.stu.service;
  
   public interface HelloService {
  
       public String HelloDubbo(String name);
  
   }

• 在provider中实现这个接口

   package zh.stu.service.iml;
  
   import zh.stu.service.HelloService;
  
  import com.alibaba.dubbo.config.annotation.Service; 

  @Service

  
  5 public class HelloServiceImpl implements HelloService {
  
       public String HelloDubbo(String name) {
  
           return "hello"+name;
  
       }
  
   }

  接着在resource中新建一个spring的文件夹，用于存放配置文件。再在spring这个文件夹下创建一个XML Configuration File下的Spring config命名为：dubbo-provider。在配置文件中配置：

   <beans xmlns="http://www.springframework.org/schema/beans"
  
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  
          xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  
          xsi:schemaLocation="http://www.springframework.org/schema/beans
  
           http://www.springframework.org/schema/beans/spring-beans.xsd
  
         http://code.alibabatech.com/schema/dubbo
  
         http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  
       <!-- 提供方应用信息，用于计算依赖关系 -->
  
       <dubbo:application name="hello-world-app" />
  
       <!-- 使用multicast广播注册中心暴露服务地址 ,注意其中multicast主要是用来做测试用的，一般到实际的项目中就是使用zookeeper-->
  
       <dubbo:registry address="multicast://224.5.6.7:1234" />
  
       <!-- 用dubbo协议在20880端口暴露服务 -->
  
       <dubbo:protocol name="dubbo" port="20880" />
  
       <!-- 用dubbo协议在20880端口暴露服务 -->
  
       <dubbo:protocol name="dubbo" port="20880" />
  
       <!-- 声明需要暴露的服务接口 -->
  
       <dubbo:service interface="zh.stu.service.HelloService" ref="demoService" />
  
       <!-- 和本地bean一样实现服务 -->
  
       <bean id="demoService" class="zh.stu.service.iml.HelloServiceImpl" />
  
   </beans>

• 最后写一个测试类进行测试。同样是在provider模块下在Test文件夹下新建一个Java类。

   package zh.stu.test;
  
   import org.junit.Test;
  
   import org.junit.runner.RunWith;
  
   import org.springframework.beans.factory.annotation.Autowired;
  
   import org.springframework.test.context.ContextConfiguration;
  
   import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  
   import zh.stu.service.HelloService;
  
   import java.io.IOException;
  
   @RunWith(SpringJUnit4ClassRunner.class)
  
   @ContextConfiguration(locations = {"classpath:spring/dubbo-provider.xml"})
  
   public class HelloServiceDubbo {
  
       @Autowired
  
       private HelloService helloService;
  
       @Test
  
       public void starttest() throws IOException {
  
   //        helloService.HelloDubbo("dubbo");
  
           System.out.println("启动dubbo服务");
  
           System.in.read();
  
       }
  
   }

  控制台会输出【启动dubbo服务】