Dubbo基础及监控平台安装部署_dubbo监控中心

目录

 

1、Dubbo背景

2、Dubbo基础概念

2.1 架构图

2.2 Dubbo特性

3、Dubbo入门示例

3.1 基本依赖

3.2 服务提供者

3.3 服务消费者

3.4 纯手工API实现（了解）

4、Dubbo常用功能

4.1 启动时检查

4.2 直连提供者

4.3 只订阅

4.4 只注册

4.5 静态服务

4.6 多协议

4.7 多注册中心

4.8 服务分组

4.9 多版本

4.10 分组聚合

4.11 结果缓存

4.12 回声测试

4.13 令牌验证

5、管理控制台搭建

5.1 下载Dubbo全系源码包

5.2 Dubbo全系maven打包

5.3 上传dubbo-admin包

5.4 配置服务注册中心zookeeper地址

6、监控平台搭建

6.1 监控平台作用

6.2 开启monitor服务

6.3 上传监控插件并配置

6.4 启动monitor并访问

---

1、Dubbo背景

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。

单一应用架构

当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的数据访问框架(ORM)是关键。

垂直应用架构

当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，提升效率的方法之一是将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的Web框架(MVC)是关键。

分布式服务架构

当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键。

弹性服务架构

当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的资源调度和治理中心(SOA)是关键。

总结：服务的调用量越来越大，服务的容量问题就暴露出来，这个服务需要多少机器支撑？什么时候该加机器？

• 第一步，要将服务现在每天的调用量，响应时间，都统计出来，作为容量规划的参考指标。

• 其次，可以动态调整权重，在线上，将某台机器的权重一直加大，并在加大的过程中记录响应时间的变化，直到响应时间到达阈值，记录此时的访问量，再以此访问量乘以机器数反推总容量

以上就是Dubbo的背景需求！

2、Dubbo基础概念

2.1 架构图

节点角色说明

调用关系说明

1. 服务容器负责启动，加载，运行服务提供者。

2. 服务提供者在启动时，向注册中心注册自己提供的服务。

3. 服务消费者在启动时，向注册中心订阅自己所需的服务。

4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

5. 服务消费者，从提供者地址列表中，基于负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

6. 统计服务消费者和提供者在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

2.2 Dubbo特性

下面是dubbo官方首页关于Dubbo特性的介绍

延伸：基于此，Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。

连通性

• 注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小

• 监控中心负责统计各服务调用次数，调用时间等，统计先在内存汇总后每分钟一次发送到监控中心服务器，并以报表展示

• 服务提供者向注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销

• 服务消费者向注册中心获取服务提供者地址列表，并根据负载算法直接调用提供者，同时汇报调用时间到监控中心，此时间包含网络开销

• 注册中心，服务提供者，服务消费者三者之间均为长连接，监控中心除外

• 注册中心通过长连接感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者

• 注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在本地缓存了提供者列表

• 注册中心和监控中心都是可选的，服务消费者可以直连服务提供者

健壮性

• 监控中心宕掉不影响使用，只是丢失部分采样数据

• 数据库宕掉后，注册中心仍能通过缓存提供服务列表查询，但不能注册新服务

• 注册中心集群，任意一台宕掉后，将自动切换到另一台

• 注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯

• 服务提供者无状态，任意一台宕掉后，不影响使用

• 服务提供者全部宕掉后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复

伸缩性

• 注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心

• 服务提供者无状态，可动态增加机器部署实例，注册中心将推送新的服务提供者信息给消费者

升级性

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

节点角色说明

 

3、Dubbo入门示例

Dubbo 可以采用全Spring配置方式，透明化接入应用，对应用没有任何 API侵入，只需用Spring加载Dubbo的配置即可，Dubbo 基于 Spring 的 Schema扩展进行加载。

3.1 基本依赖

<dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.2.9.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.9</version>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.5.3</version>
        </dependency>
​
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
        </dependency>
    </dependencies>

3.2 服务提供者

3.2.1 需要暴露的接口

package com.ydt.dubbo.service;
​
public interface DemoService {
    String sayHello(String name);
}

package com.ydt.dubbo.service;
 
​
public class DemoServiceImpl implements DemoService {
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

3.2.2 Spring配置

<?xml version="1.0" encoding="UTF-8"?>
<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="dubbo-provider"/>
    <!-- 用dubbo协议在20880端口暴露服务 消费方只能被动接受-->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!-- 使用zookeeper注册中心暴露地址 -->
    <dubbo:registry address="zookeeper://192.168.223.128" port="2181"/>
    <!-- 和本地bean一样实现服务 -->
    <bean id="demoService" class="com.ydt.dubbo.service.DemoServiceImpl"/>
    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.ydt.dubbo.service.DemoService" ref="demoService"/>
</beans>

3.2.3 启动Spring容器注册服务

package com.ydt.dubbo.test;
​
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
​
import java.io.IOException;
​
public class DubboProviderTest {
​
    @Test
    public void test() throws IOException {
        ClassPathXmlApplicationContext context
                = new ClassPathXmlApplicationContext(new String[]{"applicationContext.xml"});
        context.start();
        System.in.read(); // 按任意键退出
    }
}

 

3.3 服务消费者

3.3.1 需要消费的接口

这个地方实际生产中一般会单独列一个接口模块出来，生产者和消费者都依赖它

package com.ydt.dubbo.service;
​
public interface DemoService {
    String sayHello(String name);
}

3.3.2 Spring配置

<?xml version="1.0" encoding="UTF-8"?>
<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="dubbo-customer"/>
​
    <!-- 使用zookeeper注册中心发现服务地址 -->
    <dubbo:registry address="zookeeper://192.168.223.128" port="2181"/>
​
    <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
    <dubbo:reference id="demoService" interface="com.ydt.dubbo.service.DemoService" />
</beans>

3.3.3 消费者测试

package com.ydt.dubbo.test;
​
import com.ydt.dubbo.service.DemoService;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
​
public class DubboCustomerTest {
​
    @Test
    public void test(){
        ClassPathXmlApplicationContext context
                = new ClassPathXmlApplicationContext(new String[] {"applicationContext.xml"});
        context.start();
        DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理
        String hello = demoService.sayHello("world"); // 执行远程方法
        System.out.println( hello ); // 显示调用结果
    }
}
​

3.4 纯手工API实现（了解）

3.4.1 生产者

//纯手工服务发布
@Test
public void test2(){
    DemoService demoService = new DemoServiceImpl();
    // 当前应用配置
    ApplicationConfig application = new ApplicationConfig();
    application.setName("dubbo-privider");
​
    // 连接注册中心配置
    RegistryConfig registry = new RegistryConfig();
    registry.setPort(2181);
    registry.setAddress("zookeeper://192.168.223.128");
​
    // 服务提供者协议配置
    ProtocolConfig protocol = new ProtocolConfig();
    protocol.setName("dubbo");
    protocol.setPort(21880);
​
    // 注意：ServiceConfig为重对象，内部封装了与注册中心的连接，以及开启服务端口
    // 服务提供者暴露服务配置,此实例很重，封装了与注册中心的连接，请自行缓存，否则可能造成内存和连接泄漏
    ServiceConfig<DemoService> service = new ServiceConfig<DemoService>();
    service.setApplication(application);
    // 多个注册中心可以用setRegistries(),至于消费者，你去对应的注册中心发现服务即可
    service.setRegistry(registry);
    // 多个协议可以用setProtocols(),消费者被动接受
    service.setProtocol(protocol);
    service.setInterface(DemoService.class);
    service.setRef(demoService);
    service.setVersion("1.0.0");
​
    // 暴露及注册服务
    service.export();
    while (true);
}

3.4.2 消费者

//纯手工消费
@Test
public void test2(){
    // 当前应用配置
    ApplicationConfig application = new ApplicationConfig();
    application.setName("dubbo-customer");
​
    // 连接注册中心配置
    RegistryConfig registry = new RegistryConfig();
    registry.setPort(2181);
    registry.setAddress("zookeeper://192.168.223.128");
​
    // 注意：ReferenceConfig为重对象，内部封装了与注册中心的连接，以及与服务提供方的连接
    // 引用远程服务，此实例很重，封装了与注册中心的连接以及与提供者的连接，请自行缓存，否则可能造成内存和连接泄漏
    ReferenceConfig<DemoService> reference = new ReferenceConfig<DemoService>();
    reference.setApplication(application);
    reference.setRegistry(registry); // 多个注册中心可以用setRegistries()
    reference.setInterface(DemoService.class);
    reference.setVersion("1.0.0");
​
    // 和本地bean一样使用demoService
    // 注意：此代理对象内部封装了所有通讯细节，对象较重，请缓存复用
    DemoService demoService = reference.get();
    System.out.println(demoService.sayHello("laohu"));
}

 

4、Dubbo常用功能

4.1 启动时检查

Dubbo服务消费者默认会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止 Spring 初始化完成，以便上线时，能及早发现问题，默认 check="true"。可以通过 check="false" 关闭检查，比如，测试时，有些服务不关心，或者出现了循环依赖，必须有一方先启动。

另外，如果你的服务提供者Spring容器是懒加载的，请关闭消费者的check，否则服务临时不可用时，会抛出异常，拿到null引用，如果check="false"，总是会返回引用（null也是一种引用），当服务恢复时，能自动连上。

 <dubbo:reference id="demoService" interface="com.ydt.dubbo.service.DemoService" check="true"/>

4.2 直连提供者

在开发及测试环境下，经常需要绕过注册中心，只测试指定服务提供者，这时候可能需要点对点直连，点对点直连方式，将以服务接口为单位，忽略注册中心的提供者列表，A 接口配置点对点，不影响 B 接口从注册中心获取列表

    <!-- 绕开注册中心，直接指向服务提供者 -->
    <!--<dubbo:registry address="zookeeper://192.168.223.128" port="2181"/>-->
​
    <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
    <dubbo:reference id="demoService" interface="com.ydt.dubbo.service.DemoService" url="dubbo://127.0.0.1:20880"/>

4.3 只订阅

为方便开发测试，经常会在线下共用一个所有服务可用的注册中心，这时，如果一个正在开发中的服务提供者注册，可能会影响消费者不能正常运行。可以让服务提供者开发方，只订阅服务(开发的服务可能依赖其它服务)，而不注册正在开发的服务，通过直连测试正在开发的服务。

<!--服务提供者-->
<dubbo:registry address="zookeeper://192.168.223.128" port="2181" register="false"/>

<!--服务消费者-->
<!-- 使用zookeeper注册中心发现服务地址 -->
<!--<dubbo:registry address="zookeeper://192.168.223.128" port="2181"/>-->
<!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
<dubbo:reference id="demoService" interface="com.ydt.dubbo.service.DemoService" url="dubbo://127.0.0.1:20880"/>

4.4 只注册

如果有两个镜像环境，两个注册中心，有一个服务（C）只在其中一个注册中心（R1）有部署，另一个注册中心（R2）没有部署，服务A和B会依赖于D，需要将服务D同时注册到两个注册中心，D又依赖于C，但却不能让D服务同时依赖于两个注册中心的服务，因为C只在R1中有注册。

可以让服务提供者，注册服务D到两个注册中心（R1和R2），但只从一个注册中心（R1）订阅服务，D服务对于R2来讲就是只注册。

<!--服务提供者-->
<dubbo:registry address="zookeeper://192.168.223.129" port="2181"/>

<!--服务消费者-->
<dubbo:registry address="zookeeper://192.168.223.128" port="2181"/>
<dubbo:registry address="zookeeper://192.168.223.129" port="2181" subscribe="false"/>

 

4.5 静态服务

有时候希望人工管理服务提供者的上线和下线，此时需将注册中心标识为非动态管理模式。

<!--服务提供者-->
<dubbo:registry address="zookeeper://192.168.223.128" port="2181" dynamic="false"/>

服务提供者初次注册时为禁用状态，需人工启用。断线时，将不会被自动删除，需人工禁用。

如果是一个第三方服务提供者（必须可用），可以直接向注册中心写入提供者地址信息，消费者正常使用

    //静态服务启用
    @Test
    public void test3(){
        RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getAdaptiveExtension();
        Registry registry = registryFactory.getRegistry(URL.valueOf("zookeeper://192.168.223.128:2181"));
        //注意该服务必须为可用
        registry.register(URL.valueOf("dubbo://127.0.0.1:20880/com.ydt.dubbo.service.DemoService"));
    }
​
    //静态服务禁用
    @Test
    public void test4(){
        RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getAdaptiveExtension();
        Registry registry = registryFactory.getRegistry(URL.valueOf("zookeeper://192.168.223.128:2181"));
        registry.unregister(URL.valueOf("dubbo://127.0.0.1:20880/com.ydt.dubbo.service.DemoService"));
    }

4.6 多协议

Dubbo 允许配置多协议，在不同服务上支持不同协议或者同一服务上同时支持多种协议。

不同服务在性能上适用不同协议进行传输，比如大数据用短连接协议，小数据大并发用长连接协议，当然同一个服务也可以同时以不同的协议进行发布，消费者使用其中之一接受即可！

<!------------------------------------------服务提供者---------------------------------------------------------->
<!-- 声明多个协议端口，如果不声明，使用默认端口，具体查看Protocol接口获取缺省端口具体实现 -->
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:protocol name="rmi" port="20881"/>
​
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.ydt.dubbo.service.DemoService" ref="demoService" protocol="dubbo"/>
<dubbo:service interface="com.ydt.dubbo.service.DemoService2" ref="demoService2" protocol="rmi"/>

<!--------------------------------------------------------服务消费者---------------------------------------------------------->
<!--不设置默认使用dubbo，可以专门指定，当然也必须指定，都说了消费者需要被动接受 -->
<dubbo:reference id="demoService" interface="com.ydt.dubbo.service.DemoService"/>
<dubbo:reference id="demoService2" interface="com.ydt.dubbo.service.DemoService2" protocol="rmi"/>

Dubbo支持的常见协议

面试题：
1、dubbo 默认使用什么序列化框架，你知道的还有哪些？ 
默认使用Hessian序列化。还有Duddo、FastJson、Java自带序列化。
​
2、dubbo推荐用什么协议？ 
默认使用dubbo协议。

4.7 多注册中心

Dubbo 支持同一服务向多注册中心同时注册，或者不同服务分别注册到不同的注册中心上去，甚至可以同时引用注册在不同注册中心上的同名服务。另外，注册中心是支持自定义扩展的。

多注册中心分开注册，主要是为了区分服务面向的依赖对象！

<!--------------------------------------------------------服务提供者---------------------------------------------------------->
<!-- 使用zookeeper注册中心暴露地址 -->
<dubbo:registry id="aaa" address="zookeeper://192.168.223.128" port="2181"/>
<dubbo:registry id="bbb" address="zookeeper://192.168.223.129" port="2181"/>
​
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.ydt.dubbo.service.DemoService" ref="demoService" registry="aaa"/>
<dubbo:service interface="com.ydt.dubbo.service.DemoService2" ref="demoService2" registry="aaa,bbb"/>

<!--------------------------------------------------------服务消费者---------------------------------------------------------->
<!-- 使用zookeeper注册中心发现服务地址 -->
<dubbo:registry id="aaa" address="zookeeper://192.168.223.128" port="2181"/>
<dubbo:registry id="bbb" address="zookeeper://192.168.223.129" port="2181"/>
​
<!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
<dubbo:reference id="demoService" interface="com.ydt.dubbo.service.DemoService" registry="aaa"/>
<dubbo:reference id="demoService2" interface="com.ydt.dubbo.service.DemoService2" registry="bbb"/>

消费者连接多个注册中心配置：

<!-- 使用zookeeper注册中心发现服务地址 -->
<!-- 多注册中心配置，竖号分隔表示同时连接多个不同注册中心，同一注册中心的多个集群地址用逗号分隔 -->
<dubbo:registry id="aaa" address="zookeeper://192.168.223.128|zookeeper://192.168.223.129" port="2181"/>
​
<!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
<dubbo:reference id="demoService" interface="com.ydt.dubbo.service.DemoService"/>
<dubbo:reference id="demoService2" interface="com.ydt.dubbo.service.DemoService2"/>

4.8 服务分组

当一个接口有多种实现时，可以用 group 区分。

<!--------------------------------------------------------服务提供者---------------------------------------------------------->
<!-- DemoServiceImpl2和DemoServiceImpl22实现的同一个接口DemoService2 -->
<bean id="demoService2" class="com.ydt.dubbo.service.DemoServiceImpl2"/>
<bean id="demoService22" class="com.ydt.dubbo.service.DemoServiceImpl22"/>
<!-- 声明需要暴露的服务接口 -->
<dubbo:service group="aaa" interface="com.ydt.dubbo.service.DemoService2" ref="demoService2"/>
<dubbo:service group="bbb" interface="com.ydt.dubbo.service.DemoService2" ref="demoService22"/>

<!--------------------------------------------------------服务消费者---------------------------------------------------------->
<dubbo:reference id="demoService2" group="aaa" interface="com.ydt.dubbo.service.DemoService2"/>
<dubbo:reference id="demoService22" group="bbb" interface="com.ydt.dubbo.service.DemoService2"/>

4.9 多版本

当一个接口实现，出现不兼容升级时，可以用版本号过渡，版本号不同的服务相互间不引用。

可以按照以下的步骤进行版本迁移：

1. 在低压力时间段，先升级一半提供者为新版本

2. 再将所有消费者升级为新版本

3. 然后将剩下的一半提供者升级为新版本

<!-------------------------------服务提供者：同一个服务接口两个实现，使用版本进行区分发布，不影响老版本服务------------------------------------->
<dubbo:service version="1.0.0" interface="com.ydt.dubbo.service.DemoService2" ref="demoService2"/>
<dubbo:service version="2.0.0" interface="com.ydt.dubbo.service.DemoService2" ref="demoService22"/>

<!-------------------------------------服务消费者：使用不同的版本进行消费-------------------------------------------->
<dubbo:reference id="demoService" version="1.0.0" interface="com.ydt.dubbo.service.DemoService2"/>

4.10 分组聚合

按组合并返回结果，比如菜单服务，接口一样，但有多种实现，用group区分，现在消费方需从每种group中调用一次返回结果，合并结果返回，这样就可以实现聚合菜单项。

<!-------------------------------服务提供者：同一个服务接口两个实现，使用分组分别发布------------------------------------->
<dubbo:service group="merger1" interface="com.ydt.dubbo.service.DemoService2" ref="demoService2"/>
<dubbo:service group="merger2" interface="com.ydt.dubbo.service.DemoService2" ref="demoService22"/>

<!-------------------------------------服务消费者：进行合并调用-------------------------------------------->
<dubbo:reference id="demoService2" group="merger1,merger2" interface="com.ydt.dubbo.service.DemoService2">
    <dubbo:method name="getMenuInfo" merger="true"></dubbo:method>
</dubbo:reference>

 

4.11 结果缓存

结果缓存，用于加速热门数据的访问速度，Dubbo 提供声明式缓存，以减少用户加缓存的工作量 。

• lru 基于最近最少使用原则删除多余缓存，保持最热门的数据被缓存。

• threadlocal 当前线程缓存，比如一个页面渲染，用到很多 portal，每个 portal 都要去查用户信息，通过线程缓存，可以减少这种多余访问。ThreadLocal对象，这保证了每个线程对应一个HashMap，每个线程只能访问自己的缓存。

• JCache---自定义缓存实现（实现Cache接口）

<!-------------------------------------服务消费者：多次调用，只会有第一次进入到服务提供者接口-------------------------------------------->
<dubbo:reference id="demoService2" group="merger1,merger2" interface="com.ydt.dubbo.service.DemoService2">
    <dubbo:method name="getMenuInfo" merger="true" cache="lru"></dubbo:method>
</dubbo:reference>

 

 

4.12 回声测试

回声测试用于检测服务是否可用，回声测试按照正常请求流程执行，能够测试整个调用是否通畅，可用于监控。所有服务自动实现 EchoService 接口，只需将任意服务引用强制转型为 EchoService，即可使用。

ClassPathXmlApplicationContext context
        = new ClassPathXmlApplicationContext(new String[] {"applicationContext.xml"});
// 远程服务引用
DemoService2 demoService = (DemoService2)context.getBean("demoService2");
EchoService echoService = (EchoService) demoService; // 强制转型为EchoService
// 回声测试可用性
String status = (String) echoService.$echo("OK");
System.out.println(status);

 

4.13 令牌验证

通过令牌验证在注册中心控制权限，以决定要不要下发令牌给消费者，可以防止消费者绕过注册中心访问提供者

<!--随机token令牌，使用UUID生成-->
<dubbo:service interface="com.ydt.dubbo.service.DemoService" ref="demoService" token="true"/>
<!--固定token令牌，相当于密码-->
<dubbo:service interface="com.ydt.dubbo.service.DemoService" ref="demoService" token="123456"/>
​
<!--消费者消费时必须配置注册中心，并且不能使用url="dubbo://127.0.0.1:20880"这样的直连配置-->

5、管理控制台搭建

5.1 下载Dubbo全系源码包

下载地址：https://github.com/apache/dubbo/tree/2.5.x，也可以下载你心仪的版本，可惜dubbo-admin应用于生产的只能到2.5版本（有缺陷），后续版本分成了好几个项目：https://github.com/apache/dubbo-admin

 

5.2 Dubbo全系maven打包

进入dubbo根目录，执行命令：mvn clean package -Dmaven.test.skip=true

 

5.3 上传dubbo-admin包

上传dubbo-admin包到tomcat服务器webapps目录并启动,并且dubbo-admin的作者设计的并不完美，该项目是基于webx的开发的，所以如果你想要不报一些莫名其妙的404错误，将dubbo-admin下面的文件复制到/ROOT目录下（先把tomcat该目录下的引导页文件删除）

 

启动tomcat：

cd /usr/local/tomcat
./bin/startup.sh

访问地址：http://192.168.223.128:8080/dubbo-admin-2.5.10/ 使用guest/guest登录

 

说明部署成功！

5.4 配置服务注册中心zookeeper地址

vim webapps/dubbo-admin-2.5.10/WEB-INF/dubbo.properties
-------------------------------------------配置如下------------------------------------------------
​
#集群模式zookeeper
#dubbo.registry.address=zookeeper://192.168.223.128:2181?backup=192.168.223.129:2181,192.168.223.130:2181
#单机模式zookeeper
dubbo.registry.address=zookeeper://192.168.223.128:2181
#管理账号
dubbo.admin.root.password=root 
#访问账号
dubbo.admin.guest.password=guest

部署dubbo服务注册到zookeeper，并重启tomcat，可以看到zookeeper上注册的服务信息:

 

注意：管理控制台不是Dubbo搭建分布式系统必须的，但是它可以帮助我们对服务进行更好的治理和监控。

 

6、监控平台搭建

6.1 监控平台作用

Dubbo-Monitor主要是用来统计服务和调用次数和调用时间，服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心，监控中心则使用数据绘制图表来显示。

6.2 开启monitor服务

首先服务消费者和服务提供则都需要开启monitor，开启方式只需要在服务配置spring核心配置文件中添加如下配置即可

<!-- 启动monitor-->
<dubbo:monitor protocol="registry" />

 

6.3 上传监控插件并配置

 

tar -zxvf dubbo-monitor-simple-2.5.10-assembly.tar.gz 
mv dubbo-monitor-simple-2.5.10/ dubbo-monitor 
cd dubbo-monitor/
vim conf/dubbo.properties
​
--------------------------------------修改配置如下-------------------------------------------------------
​
dubbo.container=log4j,spring,registry,jetty
dubbo.application.name=simple-monitor
dubbo.application.owner=
# zookeeper注册中心的配置
#dubbo.registry.address=zookeeper://192.168.223.128:2181?backup=192.168.223.129:2181,192.168.223.130:2181
dubbo.registry.address=zookeeper://192.168.223.128:2181
#dubbo.registry.address=redis://127.0.0.1:6379
#dubbo.registry.address=dubbo://127.0.0.1:9090
# monitor提供远程服务监听端口，服务提供者和消费者都会调用这个端口提供服务，发送统计信息到monitor。
dubbo.protocol.port=7070
# jetty容器的监听地址，注意不要端口冲突
dubbo.jetty.port=8081
dubbo.jetty.directory=/usr/local/dubbo-monitor
dubbo.charts.directory=${dubbo.jetty.directory}/charts
dubbo.statistics.directory=${user.home}/monitor/statistics
dubbo.log4j.file=logs/dubbo-monitor-simple.log
dubbo.log4j.level=WARN
​

6.4 启动monitor并访问

[root@ydt1 dubbo-monitor]# ./bin/start.sh
Starting the simple-monitor .......OK!
PID: 54044
STDOUT: logs/stdout.log
​

启动成功。登录访问http://192.168.223.128:8081

 

PS:如果发现统计结果没出现，请打开dubbo-monitor的后台日志查看，如果报如下错误：

 

说明两个包冲突了，请修改pom.xml文件重新打包：

 

排除掉dubbo核心包中的dubbo-config-spring和dubbo-remoting-api

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>${project.parent.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba</groupId>
                    <artifactId>dubbo-config-spring</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>com.alibaba</groupId>
                    <artifactId>dubbo-remoting-api</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

重新进入dubbo-monitor-simple根目录重新maven打包：

 

重新上传配置即可得到服务的统计数据：