Dubbo源码结构

Dubbo源码目录结构.png

在github下载Dubbo源码之后导入本地开发工具，自己用的是idea，导入之后可以看到Dubbo源码的目录结构，主要的几个目录及该目录的作用如下：

dubbo-cluster: 集群容错模块，包含负载均衡策略，集群容错策略以及路由等   
dubbo-common:通用逻辑模块，提供工具类和通用模型
dubbo-compatible:兼容性模块
dubbo-config:配置模块，主要实现API配置，属性配置，XML配置等工功能
dubbo-configcenter:动态配置中心
dubbo-container:容器模块,没有使用Tomcat等Web容器，而是使用Main方法加载Spring容器。
dubbo-demo:提供了三种方式的远程调用示例。
dubbo-monitor：监控模块，主要监控接口调用的次数、时间等信息。
dubbo-registry: 注册中心模块。
dubbo-rpc: 抽象各种通信协议以及动态代理(容易和remoting模块相混淆)
dubbo-remoting:远程通信模块，为消费者和生产者提供远程通信能力。
dubbo-plugin:插件模块。

使用Dubbo框架的几种方式：

dubbo-demo模块提供了几种使用Dubbo框架进行远程调用的方式

使用XML配置的方式：

 使用Dubbo实现远程调用需要满足的几个条件：
  1.服务提供者
  2.服务调用者
  3.注册中心(默认使用zookeeper作为注册中心，需要在本机电脑安装zookeeper并且启动zookeeper服务)。

1.服务提供者

首先创建服务提供者，可以看下示例中项目的结构：

Dubbo服务提供者结构.png

dubbo-provider.xml文件配置了一些注册中心地址，暴露接口等信息。示例中的xml配置文件详解。

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
      xmlns="http://www.springframework.org/schema/beans"
      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
      http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
   <!--服务名称-->
   <dubbo:application name="demo-provider"/>
   <!--注册中心地址-->
   <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
   <!--远程调用协议-->
   <dubbo:protocol name="dubbo"/>
   <!--注册beam-->
   <bean id="demoService" class="org.apache.dubbo.demo.provider.DemoServiceImpl"/>
   <!--暴露提供的服务-->
   <dubbo:service interface="org.apache.dubbo.demo.DemoService" ref="demoService"/>
</beans>

Application类代码：

package org.apache.dubbo.demo.provider;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Application {
    public static void main(String[] args) throws Exception {
        /**加载配置文件*/
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-provider.xml");
        /**启动容器*/
        context.start();
        System.in.read();
    }
}

再看下具体暴露的接口的实现DemoServiceImpl：

package org.apache.dubbo.demo.provider;

import org.apache.dubbo.demo.DemoService;
import org.apache.dubbo.rpc.RpcContext;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class DemoServiceImpl implements DemoService {
   private static final Logger logger = LoggerFactory.getLogger(DemoServiceImpl.class);

   @Override
   public String sayHello(String name) {
       logger.info("Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress());
       return "Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress();
   }
}

主要提供了接口的实现，实现逻辑和简单，主要获取远程调用该方法的地址以及返回一些字符串信息。

2.服务调用者

Dubbo服务调用者结构.png

服务调用者对于dubbo相关信息的配置在dubbo-consumer.xml配置文件中，一下是该配置文件配置信息的详解：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
     xmlns="http://www.springframework.org/schema/beans"
     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
     http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
  <!--应用名称-->
  <dubbo:application name="demo-consumer"/>
  <!--注册中心地址-->
  <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
  <!--定义reference，注意id的值一定要和dubbo-provider.xml中配置的bean的id相同-->
  <dubbo:reference id="demoService" check="false" interface="org.apache.dubbo.demo.DemoService"/>
</beans>

Consumer调用远程方法的实现：

package org.apache.dubbo.demo.consumer;
import org.apache.dubbo.demo.DemoService;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Application {
    public static void main(String[] args) {
        /**加载配置文件*/
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/dubbo-consumer.xml");
        context.start();
        /**获取接口实例*/
        DemoService demoService = context.getBean("demoService", DemoService.class);
        /**调用远程服务*/
        String hello = demoService.sayHello("world");
        System.out.println("result: " + hello);
    }
}

总结：
生产者其实是demoService接口的一种实现，消费者调用demoService接口中的方法，Dubbo封装成远程调用，用户无感知，可以像调用本地接口一样调用接口的远程实现。

3.服务之间的调用

1.启动zookeeper中间件

mac笔记本安装好zookeeper之后进入zookeper的bin目录，输入./zkServer.sh start 指令即可启动zookeeper中间件。一下为几篇各个操作系统下安装zookeeper单机版的教程：
windows系统安装zookeeper教程
mac系统安装zookeeper教程
linux系统安装zookeeper教程

启动zookeeper之后进入日志路径查看启动日志：

zookeeper启动日志.png

2.启动服务提供者：

服务启动者启动时的日志如下：

生产者启动日志1.png
生产者启动日志2.png

有几个关键的步骤：

 1.加载配置信息完成
 2.初始化连接zookeeper客户端
 3.查看缓存中是否有连接zookeeper的客户端，没有客户端则创建客户端
 4.导出本地服务和远程服务，并且打印出了本地服务和远程服务的url地址
 5.将导出的地址注册到注册中心

服务提供者启动之后zookeeper日志

服务提供者启动后zookeeper日志.png

Zookeeper日志主要展示了一下几个信息：

1.接收到来自服务提供者的socket连接请求
2.尝试创建session
3.建立连接

3.启动调用者

消费者启动过程.png

通过日志输出可以看到关键的几个步骤：

1.查找zookeeper缓存文件，没有则创建新的client连接zookeeper
2.向zookeeper进行注册
3.通过Netty客户端连接远程服务，并且调用远程服务

总结：通过生产者和消费者的调用过程大致了解了通过XML配置方式进行远程调用的一个过程，具体调用过程中Dubbo将提供者的地址暴露给zookeeper，调用者怎么通过Dubbo调用的远程服务，需要深入Dubbo的源码进行分析。

使用Dubbo框架的其他两种方式

除了xml的方式,Dubbo还提供了另外两种使用方式，可以运行实例分析其各种实现方式的特点。

我是割草的小猪头，不断学习，不断进步，后续陆续更新Dubbo系列的文章，如您有兴趣一起了解，欢迎关注，如文章中有不妥之处，欢迎指正！

Dubbo系列文章一--Dubbo重点掌握模块
Dubbo系列文章二--配置文件加载过程