[Java知识库]Apache Dubbo:带你去dubbo的世界走一遭

Apache Dubbo:带你去dubbo的世界走一遭

前提

本篇博客是参考dubbo官方文档以及尚硅谷雷丰阳老师的视频所撰写，如果存在不足，请留下您的足迹，我会及时改正。还有在进行后面的学习过程中，如果您使用的开发工具是IDEA，请将其设置为Allow parallel Run模式，这样会运行多个进程，用来模拟多个消费者和提供者。具体步骤如下：
第一步：选择Edit Configurations进入选项编辑

第二步：勾选Allow parallel Run

最后：效果如下

这些预备工作做好之后，让我们开始dubbo学习之旅吧。

8.1 网站应用的演进

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

8.1.1 单一应用架构

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

8.1.2 垂直应用架构

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

8.1.3 分布式服务架构

分布式系统（distributed system）是若干独立计算机的集合，这些计算机对于用户来说就像单个相关系统。

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

8.1.4 流动计算架构

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

8.2 RPC

RPC是远程过程调用（Remote Procedure Call），是一种进程间通信的方式，它允许程序调用另一个地址空间（通常是共享网络的另一台机器上）的过程或函数。RPC两个核心模块：通讯、序列化。

序列化：数据传输需要转换

8.3 Dubbo

Apache Dubbo (incubating) |?d?b??| 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。另外，Dubbo 采用全 Spring 配置方式，透明化接入应用，对应用没有任何 API 侵入，只需用 Spring 加载 Dubbo 的配置即可.

总结：Apache Dubbo 是一款微服务开发框架，它提供了 RPC通信 与 微服务治理 两大关键能力。（dubbo3)

8.3.1 Dubbo 架构

Dubbo2 的服务发现模型:Provider 注册服务地址，Consumer 经过注册中心协调并发现服务地址，进而对地址发起通信，这是被绝大多数微服务框架的经典服务发现流程。

调用关系说明

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

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

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

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

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

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

8.3.2 RPC 通信协议

Dubbo3 提供了 Triple(Dubbo3)、Dubbo2 协议，这是 Dubbo 框架的原生协议。

协议是 RPC 的核心，它规范了数据在网络中的传输内容和格式。

8.3.3 dubbo配置

参考文档：https://dubbo.apache.org/zh/docs/references/configuration/overview/

本文主要介绍Dubbo配置概况，包括配置组件、配置来源、配置方式及配置加载流程。

配置组件

Dubbo框架的配置项比较繁多，为了更好地管理各种配置，将其按照用途划分为不同的组件，最终所有配置项都会汇聚到URL中，传递给后续处理模块。

常用配置组件如下：

• application: Dubbo应用配置
• registry: 注册中心
• protocol: 服务提供者RPC协议
• service: 服务提供者配置
• reference: 远程服务引用配置
• provider: service的默认配置或分组配置
• consumer: reference的默认配置或分组配置
• monitor: 监控配置

consumer与reference的关系：

reference可以指定具体的consumer，如果没有指定consumer则会自动使用全局默认的consumer配置。

provider与service的关系：

service可以指定具体的provider，如果没有指定则会自动使用全局默认的provider配置。

配置来源

从Dubbo支持的配置来源说起，默认有6种配置来源：

• JVM System Properties，JVM -D 参数
• System environment，JVM进程的环境变量
• Externalized Configuration，外部化配置，从配置中心读取
• Application Configuration，应用的属性配置，从Spring应用的Environment中提取"dubbo"打头的属性集
• API / XML /注解等编程接口采集的配置可以被理解成配置来源的一种，是直接面向用户编程的配置采集方式
• 从classpath读取配置文件 dubbo.properties

覆盖关系

下图展示了配置覆盖关系的优先级，从上到下优先级依次降低：

配置方式

按照驱动方式可以分为以下四种方式：

• API配置

通过API编码方式组装配置，启动Dubbo，发布及订阅服务，API 属性与XML配置项一一对应，比如：ApplicationConfig.setName(“xxx”) 对应 <dubbo:application name=“xxx” />。

服务提供者：通过ServiceConfig暴露服务接口，发布服务接口到注册中心。

服务消费者：通过ReferenceConfig引用远程服务，从注册中心订阅服务接口。

学习文档：https://dubbo.apache.org/zh/docs/references/configuration/api/

• XML配置

以XML方式配置各种组件，支持与Spring无缝集成。

provider.xml示例

<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.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" port="20890"/>
    <bean id="demoService" class="org.apache.dubbo.samples.basic.impl.DemoServiceImpl"/>
    <dubbo:service interface="org.apache.dubbo.samples.basic.api.DemoService" ref="demoService"/>
</beans>

consumer.xml示例

<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.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <dubbo:application name="demo-consumer"/>
    <dubbo:registry group="aaa" address="zookeeper://127.0.0.1:2181"/>
    <dubbo:reference id="demoService" check="false" interface="org.apache.dubbo.samples.basic.api.DemoService"/>
</beans>

不同粒度配置的覆盖关系

（1）方法级优先，接口级次之，全局配置再次之。

（2）如果级别一样，则消费方优先，提供方次之。

学习文档：https://dubbo.apache.org/zh/docs/references/configuration/xml/

• Annotation配置

以注解方式暴露服务和引用服务接口，支持与Spring无缝集成，需要 2.6.3 及以上版本支持。

@Service注解暴露服务+@Reference引用服务+application.properties(配置dubbo)

参照文档：https://dubbo.apache.org/zh/docs/references/configuration/annotation/

• 属性配置

根据属性Key-value生成配置组件，类似SpringBoot的ConfigurationProperties，目前Dubbo支持的所有配置都是.properties格式的，在Spring应用中也可以将属性配置放到application.yml中，其树层次结构的方式可读性更好一些。

属性与XML配置映射规则：可以将 xml 的 tag 名和属性名组合起来，用 ‘.’ 分隔，每行一个属性。

dubbo.application.name=foo 相当于 <dubbo:application name=“foo” />

参考文档：https://dubbo.apache.org/zh/docs/references/configuration/properties/

.

8.3.4 安装zookeeper

注册中心

1、下载zookeeper网址 https://archive.apache.org/dist/zookeeper/zookeeper-3.5./

2、解压zookeeper解压运行zkServer.cmd ，初次运行会报错，没有zoo.cfg配置文件

3、修改zoo.cfg配置文件将conf下的zoo_sample.cfg复制一份改名为zoo.cfg即可。

注意几个重要位置：

dataDir=./ 临时数据存储的目录（可写相对路径）

clientPort=2181 zookeeper的端口号修改完成后再次启动zookeeper

4、使用zkCli.cmd测试

ls /：列出zookeeper根下保存的所有节点

create –e /atguigu 123：创建一个atguigu节点，值为123

get /atguigu：获取/atguigu节点的值

8.3.5 安装dubbo-admin

监控中心

dubbo本身并不是一个服务软件。它其实就是一个jar包能够帮你的java程序连接到zookeeper，并利用zookeeper消费、提供服务。所以你不用在Linux上启动什么dubbo服务。

但是为了让用户更好的管理监控众多的dubbo服务，官方提供了一个可视化的监控程序，不过这个监控即使不装也不影响使用。

1、下载dubbo-admin

https://github.com/apache/incubator-dubbo-ops

2、进入目录，修改dubbo-admin配置

修改 src\main\resources\application.properties 指定zookeeper地址(zookeeper默认端口是2181)

server.port=7001
spring.velocity.cache=false
spring.velocity.charset=UTF-8
spring.velocity.layout-url=/templates/default.vm
spring.messages.fallback-to-system-locale=false
spring.messages.basename=i18n/message
spring.root.password=root
spring.guest.password=guest

dubbo.registry.address=zookeeper://127.0.0.1:2181

3、打包dubbo-admin

 mvn clean package 

4、运行dubbo-admin

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

默认使用root/root 登陆

注意：前提要使zookeeper先启动

8.3.6 安装dubbo-monitor-simple

可选，简单的监控中心。

安装

1、下载 dubbo-ops

https://github.com/apache/incubator-dubbo-ops

2、修改配置指定注册中心地址（可选）

进入 dubbo-monitor-simple\src\main\resources\conf修改 dubbo.properties文件

3、打包dubbo-monitor-simple

mvn clean package

4、解压 tar.gz 文件，并运行start.bat

5、启动访问8080

监控中心配置

     所有服务配置连接监控中心，进行监控统计
    <!-- 监控中心协议，如果为protocol="registry"，表示从注册中心发现监控中心地址，否则直连监控中心 -->
	<dubbo:monitor protocol="registry"></dubbo:monitor>

Simple Monitor 挂掉不会影响到 Consumer 和 Provider 之间的调用，所以用于生产环境不会有风险。

8.3.7 dubbo入门案例

需求：订单服务web模块在A服务器，用户服务模块在B服务器，A可以远程调用B的功能。

工程架构：

• 分包

  建议将服务接口，服务模型，服务异常等均放在 API 包中。

• 粒度

  服务接口尽可能大粒度，每个服务方法应代表一个功能。
  

创建模块

• gmall-interface(公共接口层) model，service，exception…

  作用：定义公共接口，也可以导入公共依赖
  
  Entity实体类

  @Data
  @ToString
  @NoArgsConstructor
  @AllArgsConstructor
  public class User implements Serializable {
      private Integer id;
      private String name;
      private String userAddress;
      private String userId;
      private String phoneNum;
  }
  

  service接口

  /*UserService.java
  */
  public List<User> getUserAddressList(String userId);
  
  /*
  OrderService.java
  */
  public List<User> initOrder(String userId);
  

• gmall-user 用户模块（对用户接口的实现）

  通过pom.xml导入公共接口

  <dependency>
  			<groupId>com.pinkhub</groupId>
  			<artifactId>gmall-api</artifactId>
  			<version>0.0.1-SNAPSHOT</version>
  </dependency>
  

  编写用户接口实现类

  public class UserServiceImpl implements UserService {		
  	@Override
  	public List<User> getUserAddressList() {
  		User user1 = new User(1, "屈明明", "河南省洛阳市洛龙区", "212", "13137041655");
          User user2 = new User(2, "屈明明", "陕西省渭南市白水县", "212", "13759699712");
          List<User> users = Arrays.asList(user1, user2);
          return users;
  	}
  }
  

• gmall-order-web 订单模块（调用用户模块）

  通过pom.xml导入公共接口

  <dependency>
  			<groupId>com.pinkhub</groupId>
  			<artifactId>gmall-api</artifactId>
  			<version>0.0.1-SNAPSHOT</version>
  </dependency>
  

使用dubbo改造

文档参考:https://dubbo.apache.org/zh/docsv2.7/user/quick-start/

基于xml配置模式

• 改造gmall-user作为服务提供者

  • 引入dubbo

    由于我们使用zookeeper作为注册中心，所以需要操作zookeeper
    (1)dubbo 2.6以前的版本引入zkclient操作zookeeper
    (2)dubbo 2.6及以后的版本引入curator操作zookeeper

    <!-- 引入dubbo -->
    <dependency>
    	<groupId>com.alibaba</groupId>
    	<artifactId>dubbo</artifactId>
    	<version>2.6.2</version>
    </dependency>
    <dependency>
    	<groupId>org.apache.curator</groupId>
    	<artifactId>curator-framework</artifactId>
    	<version>2.12.0</version>
    </dependency>
    

  • 配置提供者

    provider.xml：用 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://dubbo.apache.org/schema/dubbo"
           xmlns:context="http://www.springframework.org/schema/context"
           xsi:schemaLocation="http://www.springframework.org/schema/beans         http://www.springframework.org/schema/beans/spring-beans.xsd
    		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
    		http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
    		http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
        <!--1.指定当前应用/服务的名字-->
        <dubbo:application name="gmall-user"></dubbo:application>
        <!--2.指定注册中心的地址  -->
        <dubbo:registry address="zookeeper://127.0.0.1:2181" />
        <!--3.指定通信规则及端口，dubbo协议，将服务暴露在20880端口  -->
        <dubbo:protocol name="dubbo" port="20880" />
        <!--4.暴露服务，ref:指向服务的真正实现对象 -->
        <dubbo:service interface="com.pinkhub.gmallapi.service.UserService" ref="userServiceImpl" />
        <!--5.服务的实现 -->
        <bean id="userServiceImpl" class="com.pinkhub.userserviceprovider.service.impl.UserServiceImpl"></bean>
    </beans>
    

  • 启动Zookeeper注册中心、dubbo监控中心，编写测试类，将提供者注册到Zookeeper注册中心。

    public static void main(String[] args) throws IOException {
    		ClassPathXmlApplicationContext ioc = 
    				new ClassPathXmlApplicationContext("classpath:provider.xml");
    		ioc.start();
    		System.in.read();// 按任意键退出 
    	}
    

  • 运行截图
    

• 改造gmall-order-web作为服务消费者

  • 引入dubbo

    <!-- 引入dubbo -->
    <dependency>
    	<groupId>com.alibaba</groupId>
    	<artifactId>dubbo</artifactId>
    	<version>2.6.2</version>
    </dependency>
    <dependency>
    	<groupId>org.apache.curator</groupId>
    	<artifactId>curator-framework</artifactId>
    	<version>2.12.0</version>
    </dependency>
    

  • 配置消费者信息-----通过 Spring 配置引用远程服务

    consumer.xml

    <?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://dubbo.apache.org/schema/dubbo" xmlns:context="http://www.springframework.org/schema/context"
           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 http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">
        <context:component-scan base-package="com.pinkhub.orderserviceconsumer.service.impl"></context:component-scan>
        <!--1.应用名 -->
        <dubbo:application name="order-service-consumer"></dubbo:application>
        <!-- 2.指定注册中心地址 -->
        <dubbo:registry address="zookeeper://127.0.0.1:2181" />
        <!-- 3.需要调用的远程服务接口，生成远程服务代理-->
        <dubbo:reference id="userService" interface="com.pinkhub.gmallapi.service.UserService"></dubbo:reference>
        <!--4.配置当前消费者的统一规则
              服务启动时不检查，调用时检查;
              配置超时,单位ms；
              重试次数，3次，幂等操作（查、删、修---每次运行结果相同）
        （建议配置）-->
        <dubbo:consumer check="false" timeout="5000" retries="3"/>
    </beans>
    

  • 编写OrderServiceImpl.java

    @Service
    public class OrderServiceImpl implements OrderService{
        @Autowried
        UserService userService;
        public void initOrder(){
            //1.查询用户的收货地址
            List<UserAddress> addressList=userService.getUserAddressList();
            for(UserAddress userAddress:addressList){
                System.out.println(addressList);  
            }
        }
    }
    

• 测试调用

  访问gmall-order-web的initOrder请求，会调用UserService获取用户地址；若调用成功，说明order已经可以调用远程的UserService了。

  【前提】：

  必须开启Zookeeper注册中心、dubbo监控中心、运行提供者服务，然后运行测试代码

  测试代码：

  @SuppressingWarning("resource")
  public static void main(String[] args) throws IOException {
  		ClassPathXmlApplicationContext ioc = 
  				new ClassPathXmlApplicationContext("classpath:consumer.xml");
  		OrderService orderService=ioc.getBean(OrderService.class);
          orderService.initOrder();
  		System.in.read();// 按任意键退出 
  	}
  

  运行截图如下
  
  

与springboot整合

springboot与dubbo整合的3种方式：

（1）导入dubbo-starter，在application.properties中配置属性，同时在主类使用@EnableDubbo开启dubbo服务，使用@Service暴露服务、@Reference引用服务。

（2）保留dubbo.xml配置文件。导入dubbo-starter，在主类上标注@ImportResource导入dubbo的配置文件

@ImportResource(locations="classpath:provider.xml")

（3）配置类 （API配置）

在主配置类上标注@EnableDubbo(scanBasePackages=“xxx”)注解，然后在配置类上标注@Configuration,将dubbo.xml每一个标签映射为配置方法XxxConfig.

案例优化：

前提：运行消费者主类时，必须开启zookeeper注册中心、dubbo监控中心服务、服务提供者主类保证已运行

• 服务提供者

  第一步：引入公共接口包、dubbo-spring-boot-starter

  <dependency>
  			<groupId>com.pinkhub</groupId>
  			<artifactId>gmall-api</artifactId>
  			<version>0.0.1-SNAPSHOT</version>
  </dependency>
  <dependency>
  			<groupId>com.alibaba.boot</groupId>
  			<artifactId>dubbo-spring-boot-starter</artifactId>
  			<version>0.2.0</version>
  </dependency>
  

  第二步：在主配置类上标记@EnableDubbo,开启基于注解的dubbo服务

  第三步：在application.properties中配置dubbo

  dubbo.application.name=user-service-provider
  dubbo.registry.address=127.0.0.1:2181
  dubbo.registry.protocol=zookeeper
  
  dubbo.protocol.name=dubbo
  dubbo.protocol.port=20881
  
  #监控中心协议，如果为protocol="registry"，表示从注册中心发现监控中心地址，否则直连监控中心 
  dubbo.monitor.protocol=registry
  

  第四步：注册暴露服务，使用dubbo提供的service注解

  @Service   //使用dubbo提供的service注解，注册暴露服务
  public class UserServiceImpl implements UserService {
      @Override
      public List<User> getUserAddressList(String userId) {
          User user1 = new User(1, "屈明明", "河南省洛阳市洛龙区", "212", "13137041655");
          User user2 = new User(2, "屈明明", "陕西省渭南市白水县", "212", "13759699712");
          List<User> users = Arrays.asList(user1, user2);
          return users;
      }
  }
  

• 服务消费者

  第一步：引入公共接口包、dubbo-spring-boot-starter、spring-boot-starter-web

  第二步：在主配置类上标记**@EnableDubbo**,开启基于注解的dubbo服务

  第三步：在application.properties中配置dubbo

  #dubbo-monitor-simple端口号8080，为了避免与tomcat的冲突，需要改下tomcat端口号
  server.port=8088
  
  dubbo.application.name=order-service-consumer
  dubbo.registry.address=zookeeper://127.0.0.1:2181
  dubbo.monitor.protocol=registry
  

  第四步:引用远程服务，使用dubbo提供的**@reference**注解引用远程服务

  @Service
  public class OrderServiceImpl implements OrderService {
      @Reference
      public UserService userService;
      @Override
      public List<User> initOrder(String userId) {
          List<User> userList = userService.getUserAddressList(userId);
          return userList;
      }
  }
  

  第五步：编写控制类，进行远程调用

  @Controller
  public class OrderController {
      @Autowired
      OrderService orderService;
      @ResponseBody
      @RequestMapping("/user")
      public List<User> getUserAddress(@RequestParam("uid") String uid){
          List<User> users = orderService.initOrder(uid);
          return users;
      }
  }
  

• 运行截图

  浏览器访问：http://localhost:7001/进入dubbo监控中心
  

  浏览器访问：http://localhost:8088/user?uid=212
  

8.3.8 高可用

高可用：通过设计，减少系统不能提供服务的时间

zookeeper宕机

现象：zookeeper注册中心宕机，消费者仍能调用提供者远程服务。

原因：健壮性

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

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

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

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

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

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

  dubbo直连是指直接告诉消费者远程调用提供者的地址。

dubbo直连

dubbo直连是指在没有注册中心，比如zookeeper的情况下，采用dubbo直连方式告诉消费者远程调用提供者的地址，来实现远程调用。

@Reference(url=“127.0.0.1:20882”)//dubbo直连

负载均衡机制

LoadBalance 中文意思为负载均衡，它的职责是将网络请求，或者其他形式的负载“均摊”到不同的机器上。避免集群中部分服务器压力过大，而另一些服务器比较空闲的情况。通过负载均衡，可以让每台服务器获取到适合自己处理能力的负载。

在集群负载均衡时，Dubbo 提供了多种均衡策略，缺省为 random 随机调用。可以自行扩展负载均衡策略，

学习文档：https://dubbo.apache.org/zh/docs/v3.0/references/features/loadbalance/

• Random LoadBalance

  基于权重的随机负载均衡机制（dubbo默认）
  

• RoundRobin LoadBalance

  基于权重的轮询负载均衡机制
  

• LeastActive LoadBalance

  最少活跃数负载均衡机制
  

• ConsistentHash LoadBalance

  一致性 Hash-负载均衡机制
  

自定义负载均衡机制 以轮询为例

注解版：

/************服务提供方*******************/
@Service(loadbalance = "roundrobin")
/*************服务消费方*******************/
@Reference(loadbalance = "roundrobin")

xml版：

<dubbo:service interface="..." loadbalance="roundrobin" />

<dubbo:reference interface="..." loadbalance="roundrobin" />

更改提供者权重

服务降级

当服务器压力剧增的情况下，根据实际业务情况及流量，释放非关键性服务的服务器资源以保证核心服务正常运作或高效运作。服务降级可以临时屏蔽某个出错的非关键服务，需要定义降级后的返回策略。

通过Dubbo admin控制台实现，屏蔽或者容错。

• 屏蔽：表示消费方对该服务的方法调用都直接返回 null 值，不发起远程调用。

• 容错：表示消费方对该服务的方法调用在失败后，再返回 null 值，不抛异常

集群容错

在集群调用失败时，Dubbo 提供了多种容错方案，缺省为 failover 重试。

集群容错模式

• Failover Cluster

  当出现失败，重试其它服务器。通过 retries=“2” 来设置重试次数(不含第一次)。

  <dubbo:service retries="2" />
  
  <dubbo:reference retries="2" />
  

• Failfast Cluster

  快速失败，只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。

• Failsafe Cluster

  失败安全，出现异常时，直接忽略。通常用于写入审计日志等操作。

• Failback Cluster

  失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。

• Forking Cluster

  并行调用多个服务器，只要一个成功即返回。通过 forks=“2” 来设置最大并行数，用于实时性要求较高的操作

• Broadcast Cluster

  广播调用所有提供者，逐个调用，任意一台报错则报错

集群模式配置

按照以下示例在服务提供方和消费方配置集群模式

<dubbo:service cluster="failsafe" />
<dubbo:reference cluster="failsafe" />

整合hystrix

Hystrix 旨在通过控制那些访问远程系统、服务和第三方库的节点，从而对延迟和故障提供更强大的容错能力。

第一步：引入依赖

spring boot官方提供了对hystrix的集成，直接在pom.xml里加入依赖

 <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            <version>1.4.4.RELEASE</version>
</dependency>

第二步：在主类上标注==@EnableHystrix==注解来启用hystrix starter

第三步：配置provider端 @HystrixCommand标注在会出现容错的方法上

第四步：配置consumer端 @HystrixCommand(fallbackMethod = “error”)若容错，调用自定义error方法

在学完这些，恭喜你已步入dubbo，如果想深入学习，可以深入源码了解dubbo运行的原理。勇敢牛牛不怕困难，冲冲冲！！！