【Dubbo】dubbo学习

小灰灰 2023-02-20 02:08 260阅读 0赞

# 一、分布式和微服务 #

## 1.1 什么是分布式 ##

分布式是一种系统部署方式，即根据实际情况将项目拆分成多个不同的服务，并分散部署在不同的机器是。在分布式中，生产环境的服务器或虚拟机必定超过一台。

> 分布式服务顾名思义服务是分散部署在不同的机器上的，一个服务可能负责几个功能，是一种面向SOA架构的，服务之间也是通过rpc来交互或者是webservice来交互的。逻辑架构设计完后就该做物理架构设计，系统应用部署在超过一台服务器或虚拟机上，且各分开部署的部分彼此通过各种通讯协议交互信息，就可算作分布式部署。

## 1.2 什么是微服务 ##

微服务是一种架构设计方式，即将项目根据实际情况拆分成多个微小的服务，小到一个服务只负责一个单一的功能。这个服务可以单独部署运行，服务间可以通过rpc来互相调用。

**微服务架构：**

> 在做架构设计的时候，先做逻辑架构，再做物理架构，当你拿到需求后，估算过最大用户量和并发量后，计算单个应用服务器能否满足需求，如果用户量只有几百人的小应用，单体应用就能搞定，即所有应用部署在一个应用服务器里，如果是很大用户量，且某些功能会被频繁访问，或者某些功能计算量很大，建议将应用拆解为多个子系统，各自负责各自功能，这就是微服务架构。

## 1.3 两者对比 ##

生产环境下的微服务肯定是分布式部署的，分布式部署的应用不一定是微服务架构的，比如集群部署，它是把相同应用复制到不同服务器上，但是逻辑功能上还是单体应用。

# 二、什么是 Java RPC #

## 2.1 RPC 概念 ##

RPC 全程为  remote procedure call，即远程过程调用。例如两台服务器A、B上分别部署了不同的应用，A服务器上的应用想调用B服务器上的应用提供的方法，就需要通过网络来表达调用的语义和传达调用的数据。

RPC 是一个泛化的概念，严格来说一切远程调用手段都属于 RPC 范畴，Java 中的 RPC 框架 有 RMI、Hessian、Dubbo 等

# #

## 2.2 基本原理图 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70][]

## 2.3 RPC 框架性能 ##

RPC 框架的优劣主要取决于：

*  **通信效率：**是否能快速的在不同服务之间建立起连接
 *  **序列化与反序列化效率：**序列化和反序列化机制是否快速

# 三、Dubbo 学习 #

## 3.1 Dubbo 简介 ##

Apache Dubbo 是一款高性能的 Java RPC 框架，可以和 Spring 框架无缝集成。

**Dubbo 提供了三大核心能力：**

*  面向接口的远程方法调用
 *  智能容错和负载均衡
 *  服务自动注册和发现

## 3.2 Dubbo 架构图 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 1][]

虚线为异步调用，实线为同步调用

蓝色虚线：在启动时未完成的功能

红色线条：在程序运行过程中执行的功能

**节点角色说明：**

<table style="width:601px;"> 
 <tbody> 
  <tr> 
   <td style="width:149px;"><strong>节点</strong></td> 
   <td style="width:475px;"><strong>角色名称</strong></td> 
  </tr> 
  <tr> 
   <td style="width:149px;">Provider</td> 
   <td style="width:475px;">暴露服务的服务提供方</td> 
  </tr> 
  <tr> 
   <td style="width:149px;">Consumer</td> 
   <td style="width:475px;">调用远程服务的消费提供方</td> 
  </tr> 
  <tr> 
   <td style="width:149px;">Registry</td> 
   <td style="width:475px;">服务注册与发现的注册中心</td> 
  </tr> 
  <tr> 
   <td style="width:149px;">Monitor</td> 
   <td style="width:475px;">统计服务的调用次数和调用时间的监控中心</td> 
  </tr> 
  <tr> 
   <td style="width:149px;">Container</td> 
   <td style="width:475px;">服务运行容器</td> 
  </tr> 
 </tbody> 
</table>

## 3.3 服务注册中心 Zookeeper ##

### 3.3.1 什么是注册中心 ###

消费者通过注册中心来调用服务提供方，消费者和服务提供者均要在注册中心进行注册，注册中心能够监控到服务提供方是否在线，以及实现负载均衡。

### 3.3.2 Zookeeper 简介 ###

Zookeeper 是 Apache Hadoop 的子项目，是一个树形的目录服务，支持变更推送，适合作为 Dubbo 服务的注册中心，工业强度较高，可用于生成环境。

### 3.3.3 Zookeeper 结构说明 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 2][]

**流程说明：**

*  服务提供者(Provicer)启动时，向 /dubbo/com.foo.BarService/providers 目录下写入自己的 URL 地址
 *  服务消费者(Consumer)启动时，订阅 /dubbo/com.foo.BarService/providers 目录下的提供者 URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址
 *  监控中心(Monitor)启动时，订阅 /dubbo/com.foo.BarService 目录下所有的提供者和消费者 URL 地址

### 3.3.4 安装 Zookeeper ###

**百度网盘：**

**链接：**https://pan.baidu.com/s/1CL1CYr2-Eb4ZOX-fe4WFRg   **提取码：**13y3

**官网下载地址：**

[http://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/][http_archive.apache.org_dist_zookeeper_zookeeper-3.4.6]

# 解压压缩包
    tar -zxvf zookeeper-3.4.6.tar.gz
    mv zookeeper-3.4.6 zookeeper
    
    
    # 创建data目录
    cd zookeeper
    mkdir data
    
    # 修改配置文件
    cd conf
    mv zoo_sample.cfg zoo.cfg
    
    # 修改 zoo.cfg 文件
    dataDir=/usr/local/lincya/zookeeper/data

### 3.3.4 Zookeeper 使用 ###

# 启动 Zookeeper
    ./zkServer.sh start
    
    # 停止服务命令
    ./zkServer.sh stop
    
    # 查看服务状态
    ./zkServer.sh status

## ##

### 3.3.5 Zookeeper 客户端使用 ###

# 进入客户端
    sh zkCli.sh
    
    # 查看节点
    ls /
    
    # 获取某个节点数据
    get /dubbo
    
    # 创建节点
    create dubbo 123456

### 3.3.6 Zookeeper 可视化界面 ###

**GitHub 项目地址：**

[https://github.com/apache/dubbo-admin][https_github.com_apache_dubbo-admin]

**使用教程：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 3][]

**访问结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 4][]

# 四、Dubbo 搭建基于 xml 的实例 #

# 4.1 提供方搭建 #

### 4.1.1 引入 maven 依赖 ###

<dependencies>
            <dependency>
                <groupId>com.tom</groupId>
                <artifactId>dubbo-interface</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            
            <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>
        </dependencies>

### 4.1.2 增加注解 ###

provider.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"
           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="user-service-provider"/>
    
        
        <dubbo:registry address="zookeeper://www.greattom.xyz:2181"/>
    
        
        <dubbo:protocol name="dubbo" port="20880"/>
    
        
        <dubbo:service interface="com.tom.service.UserService" ref="userServiceImpl"/>
    
        
        <bean id="userServiceImpl" class="com.tom.service.impl.UserServiceImpl"/>
    
        
        <dubbo:provider timeout="5000"></dubbo:provider>
    
        
        <dubbo:monitor protocol="registry"></dubbo:monitor>
    </beans>

### 4.1.3 修改启动类 ###

使用 ClassPathXmlApplicationContext 加载配置文件

public class ProviderApplication {
    
        public static void main(String[] args) throws IOException {
            ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
            ioc.start();
    
            System.in.read();
        }
    }

### 4.1.4 编写服务代码 ###

import com.tom.bean.UserAddress;
    import com.tom.service.UserService;
    
    import java.util.Arrays;
    import java.util.List;
    
    public class UserServiceImpl implements UserService {
        public List<UserAddress> getUserAddressList(String userId) {
            UserAddress address1 = new UserAddress(1, "北京市", "1", "小王", "18030145000", "1");
            UserAddress address2 = new UserAddress(2, "杭州市", "2", "小北", "18030145999", "2");
            return Arrays.asList(address1, address2);
        }
    }

# 4.2 服务方搭建 #

### 4.2.1 引入 maven 依赖 ###

与提供方相同

### 4.2.2 增加注解 ###

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:context="http://www.springframework.org/schema/context"
           xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
           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
           http://www.springframework.org/schema/context/spring-context.xsd">
    
        <context:component-scan base-package="com.tom.service.impl"></context:component-scan>
    
        
        <dubbo:application name="order-service-consumer"/>
    
        
        <dubbo:registry address="zookeeper://www.greattom.xyz:2181"/>
    
        
        <dubbo:reference interface="com.tom.service.UserService" id="userService"/>
    
        
        <dubbo:monitor protocol="registry"></dubbo:monitor>
        
    </beans>

### 4.2.3 修改启动类 ###

public class ConsumerApplication {
    
        public static void main(String[] args) throws IOException {
            ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
            OrderService orderService = applicationContext.getBean(OrderService.class);
            orderService.initOrder("1");
    
            System.out.println("调用完成...");
            System.in.read();
        }
    }

### 4.2.4 编写服务代码 ###

import com.tom.bean.UserAddress;
    import com.tom.service.OrderService;
    import com.tom.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import java.util.List;
    
    @Service
    public class OrderServiceImpl implements OrderService {
    
        @Autowired
        UserService userService;
    
        public void initOrder(String userId) {
            System.out.println("用户ID: " + userId);
            List<UserAddress> addressList = userService.getUserAddressList(userId);
            for (UserAddress item : addressList) {
                System.out.println(item.getUserAddress());
            }
        }
    }

# 五、Dubbo 搭建基于注解的实例 #

**Github项目地址：**[https://github.com/IDLC1/dubboDemos][https_github.com_IDLC1_dubboDemos]

**项目相关依赖版本：**

*  **jdk:** 1.8
 *  **dubbo:** 2.7.7
 *  **zookeeper:** 3.6.1
 *  **curator:** 5.0.0

## 5.1 提供者搭建 ##

### 5.1.1 引入 maven 依赖 ###

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
    
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    
        <dependency>
            <groupId>com.tom</groupId>
            <artifactId>boot-dubbo-common-interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    
        
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>${zookeeper.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>${curator.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>${curator.version}</version>
        </dependency>
    
        
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
    </dependencies>

### 5.1.2 修改配置文件 ###

dubbo.application.name=dubbo-order-provicder
    # 指定 zookeeper 注册，使用 curator 客户端
    dubbo.registry.address=zookeeper://www.greattom.xyz:2181
    dubbo.registry.protocol=zookeeper
    dubbo.registry.client=curator
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=20880
    # 指定要扫描的包
    dubbo.scan.base-packages=com.tom.bootdubboorderprovider.service
    # dubbo监控设置为自动获取
    dubbo.monitor.protocol=registry

### 5.1.3 修改启动类 ###

@SpringBootApplication
    @EnableDubbo
    public class BootDubboOrderProviderApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(BootDubboOrderProviderApplication.class, args);
        }
    }

### 5.1.4 实现类中使用 ###

@DubboService
    public class UserServiceImpl implements UserService {
        @Override
        public List<UserAddress> getUserAddressList(String userId) {
            UserAddress address1 = new UserAddress(1, "北京市", "1", "小王", "18030145000", "1");
            UserAddress address2 = new UserAddress(2, "杭州市", "2", "小北", "18030145999", "2");
            return Arrays.asList(address1, address2);
        }
    }

## ##

## 5.2 消费者搭建 ##

## 5.2.1 引入 maven 依赖 ##

依赖于提供者相同

### 5.2.2 修改配置文件 ###

server.port=8084
    dubbo.application.name=dubbo-user-consumer
    # 指定 zookeeper 注册，使用 curator 客户端
    dubbo.registry.address=zookeeper://www.greattom.xyz:2181
    dubbo.registry.protocol=zookeeper
    dubbo.registry.client=curator
    # dubbo监控设置为自动获取
    dubbo.monitor.protocol=registry

### 5.2.3 修改启动类 ###

@SpringBootApplication
    @EnableDubbo
    public class BootDubboUserConsumerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(BootDubboUserConsumerApplication.class, args);
        }
    
    }

### 5.2.4 实现类中使用 ###

使用 @Reference 来调用 dubbo 上注册的提供者

@Service
    public class OrderServiceImpl implements OrderService {
    
        @DubboReference
        UserService userService;
    
        @Override
        public List<UserAddress> initOrder(String userId) {
            System.out.println("用户ID: " + userId);
            List<UserAddress> addressList = userService.getUserAddressList(userId);
            for (UserAddress item : addressList) {
                System.out.println(item.getUserAddress());
            }
            return addressList;
        }
    
        @Override
        public String orderTest(String id) {
            return "order test!";
        }
    }

## 5.3 Dubbo 配置解析 ##

# 指定 dubbo 在 zookeeper 上注册的服务名
    dubbo.application.name=dubbo-user-consumer
    
    # 指定 zookeeper 注册中心，使用 curator 客户端
    dubbo.registry.address=zookeeper://www.greattom.xyz:2181
    dubbo.registry.protocol=zookeeper
    dubbo.registry.client=curator
    
    # 设置 dubbo 在启动时不检查 zookeeper 上是否已经注册了依赖
    # 用于不同服务间的互相调用
    dubbo.consumer.check=false
    
    # 协议方式和端口，用于其他服务调用。
    # 不同的服务端口不能相同
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=20881
    
    # 要暴露的包路径
    dubbo.scan.base-packages=com.tom.bootdubbouserconsumer
    
    # dubbo监控设置为自动获取
    dubbo.monitor.protocol=registry

# 六、Dubbo 详细配置 #

官网文档：[http://dubbo.apache.org/zh-cn/docs/user/demos/preflight-check.html][http_dubbo.apache.org_zh-cn_docs_user_demos_preflight-check.html]

## 6.1 配置覆盖关系 ##

### 6.1.1 配置优先级 ###

*  **精确优先：**方法级优先，接口次之，全局配置再次之
 *  **消费方优先：**若级别一致，则消费方优先，提供方次之

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 5][]

### **6.1.2 在Provider上尽量多配置Consumer属性** ###

*  服务的提供者，比服务使用方更清楚服务性能参数，如调用的超时时间，合理的重试次数，等等
 *  在 provider 配置后，consumer 不配置则会使用 provider 的配置值，即 provider 配置可以作为 consumer 的缺省值。否则，consumer 会使用 consumer 端的全局设置，这对于 provider 不可控的，并且往往是不合理的

## 6.2 启动时检查 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 6][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 7][]

## 6.3 超时时间配置 ##

根据实际情况，修改 dubbo 访问其他提供者的接口超时时间。Dubbo 默认超时时间为 1 秒，在实际情况中 1 秒对于服务的请求速度要求很高，故应该根据实际情况进行统一或针对性修改

统一修改和针对性修改可以同时存在，且优先级：针对性修改 > 统一修改

### 6.3.1 统一修改 ###

在 springboot 配置文件中增加：

dubbo.provider.timeout=3000

### 6.3.2 针对性修改 ###

@DubboService(timeout = 5000)

@Service
    public class OrderServiceImpl implements OrderService {
    
        @DubboReference(timeout = 3000)
        UserService userService;
    
        @Override
        public List<UserAddress> initOrder(String userId) throws InterruptedException {
            System.out.println("用户ID: " + userId);
            List<UserAddress> addressList = userService.getUserAddressList(userId);
            for (UserAddress item : addressList) {
                System.out.println(item.getUserAddress());
            }
            return addressList;
        }
    }

### 6.3.3 xml 修改 ###

<dubbo:provider timeout="5000"></dubbo:provider>

## 6.4 重试次数配置 ##

可以根据实际情况设置请求的重试次数，默认为 3 次。为实际配置值 N + 1

**方法分类：**

*  **幂等方法：**无论多少次，只要请求数据不变，则响应结果最终都是同一个效果，如查询、删除、修改
 *  **非幂等方法：**每次运行都会产生新的效果，如数据库新增

**设置区别：**

*  **幂等方法：**设置重试次数
 *  **非幂等方法：**不能设置重试次数，设置为0

### 6.4.2 xml 配置 ###

**统一配置：**

<dubbo:provider timeout="2000" retries="5"></dubbo:provider>

**针对方法配置：**

<dubbo:service interface="com.tom.service.UserService" ref="userServiceImpl">
        <dubbo:method name="getUserAddressList" timeout="2000" retries="8"></dubbo:method>
    </dubbo:service>

## 6.5 灰度发布 ##

### 6.5.1 概念 ###

概念：[https://blog.csdn.net/qq\_42234452/article/details/90906692][https_blog.csdn.net_qq_42234452_article_details_90906692]

dubbo多版本控制： [http://dubbo.apache.org/zh-cn/docs/user/demos/multi-versions.html][http_dubbo.apache.org_zh-cn_docs_user_demos_multi-versions.html]

### 6.5.2 适应场景 ###

*  当接口存在不兼容的升级时，要让一部分用户用新版本，又要支持老版本接口的使用，可以使用dubbo多版本控制
 *  当服务要更新时，无法确保线上服务更新正常，需要先进行测试，之后逐步将用户流量指引向新版本

### 6.5.3 示例代码 ###

**提供方：**

<dubbo:service interface="com.tom.service.UserService" ref="userServiceImpl01" version="1.0.0">
        <dubbo:method name="getUserAddressList" timeout="2000" retries="8"></dubbo:method>
    </dubbo:service>
    <dubbo:service interface="com.tom.service.UserService" ref="userServiceImpl02" version="2.0.0">
        <dubbo:method name="getUserAddressList" timeout="2000" retries="8"></dubbo:method>
    </dubbo:service>
    
    
    <bean id="userServiceImpl01" class="com.tom.service.impl.UserServiceImpl"/>
    <bean id="userServiceImpl02" class="com.tom.service.impl.UserServiceImpl2"/>

**调用方：**

<dubbo:reference interface="com.tom.service.UserService" id="userService" version="2.0.0"/>

## 6.6 本地存根 ##

### 6.6.1 概念 ###

> 远程服务后，客户端通常只剩下接口，而实现全在服务器端，但提供方有些时候想在客户端也执行部分逻辑，比如：做 ThreadLocal 缓存，提前验证参数，调用失败后伪造容错数据等等，此时就需要在 API 中带上 Stub，客户端生成 Proxy 实例，会把 Proxy 通过构造函数传给 Stub [\[1\]][1]，然后把 Stub 暴露给用户，Stub 可以决定要不要去调 Proxy。

# 七、Springboot 整合 Dubbo  的三种方式 #

## 7.1 描述 ##

SpringBoot 整合 Dubbo 的方式有：

*  **注解配置方式(常用)：**在 springboot 配置文件中配置相关内容，使用 @Service 和 @Reference 注解实现功能
 *  **xml配置方式(常用)：**使用 xml 配置文件，使用 @ImportResource 导入生效
 *  **注解Api方式(知道)：**创建dubbo配置文件，依次注册 dubbo 组件到项目中

## 7.2 三种方式对比 ##

<table> 
 <tbody> 
  <tr> 
   <td style="width:85px;">&nbsp;</td> 
   <td style="width:333px;"><strong>注解配置方式</strong></td> 
   <td style="width:207px;"><strong>xml配置方式</strong></td> 
   <td style="width:286px;"><strong>注解API方式</strong></td> 
  </tr> 
  <tr> 
   <td style="width:85px;"><strong>配置方式</strong></td> 
   <td style="width:333px;">导入 dubbo-starter，在配置文件中进行配置，使用@Service暴露服务，使用@Reference引用服务</td> 
   <td style="width:207px;">首先导入dubbo-starter，然后使用 @ImportResource 加载 xml 配置文件</td> 
   <td style="width:286px;">创建统一的dubbo配置文件，将dubbo的每一个组件手动注入到springboot项目中</td> 
  </tr> 
  <tr> 
   <td style="width:85px;"><strong>优点</strong></td> 
   <td style="width:333px;">配置快速方便</td> 
   <td style="width:207px;">支持精确配置</td> 
   <td style="width:286px;">支持精确配置</td> 
  </tr> 
  <tr> 
   <td style="width:85px;"><strong>缺点</strong></td> 
   <td style="width:333px;">不支持精确配置，如针对 method 进行配置</td> 
   <td style="width:207px;">&nbsp;</td> 
   <td style="width:286px;">配置繁琐，不常用</td> 
  </tr> 
 </tbody> 
</table>

# 八、常见的高可用场景 #

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

**Dubbo 与 Zookeeper 的高可用有：**

*  监控中心宕机后不影响使用，只是丢失部分采样数据
 *  数据库宕掉后，注册中心仍能通过缓存提供服务列表查询， 但无法注册新服务
 *  注册中心对等集群，任意一台宕机后，将自动切换到另一台
 *  注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯，即 dubbo 直连
 *  服务提供者无状态，任意一台宕掉后，不影响使用
 *  服务提供者全部宕掉后，服务消费者将无法使用， 并无限次重试等待服务提供者恢复

## 8.1 Zookeeper 宕机与 dubbo 直连 ##

### 8.1.1 本地缓存 ###

当消费者调用过提供者的方法后，消费者会在本地存储提供者的地址以及方法信息，故当 Zookeeper 宕机后消费者依旧可以消费提供者提供的服务

### 8.1.2 dubbo 直连 ###

需要保证 provider 服务正常运行中

修改 consumer 配置，关闭 zookeeper 连接配置

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 8][]

进入管理界面查看提供者的地址信息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 9][]

修改 consumer 的引用

![2020062910274047.png][]

可以正常调用了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 10][]

## 8.2 Dubbo 负载均衡 ##

### 8.2.1 四种负载均衡策略 ###

Dubbo内置了4种负载均衡策略:

*  **RandomLoadBalance：**随机负载均衡。随机的选择一个。是Dubbo的**默认**负载均衡策略。
 *  **RoundRobinLoadBalance：**轮询负载均衡。轮询选择一个。
 *  **LeastActiveLoadBalance：**最少活跃调用数，相同活跃数的随机。活跃数指调用前后计数差。使慢的 Provider 收到更少请求，因为越慢的 Provider 的调用前后计数差会越大。
 *  **ConsistentHashLoadBalance：**一致性哈希负载均衡。相同参数的请求总是落在同一台机器上。

### 8.2.2 随机负载均衡(或基于权重) ###

随机负载均衡即随机选择一个节点进行请求，接下来主要介绍基于权重的随机负载均衡

例如 orderService 是一个消费者，userService 是提供者，根据权重的不同，大致会有1/6的请求来带A服务，3/6的请求会来到B服务，2/6的请求会来到C服务，并不是严格遵守比例，不能保证顺序调用，只能够保证大概一致

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 11][]

### 8.2.3 轮询负载均衡(或基于权重) ###

轮询负载均衡即在所有节点中间循环发送请求，接下来主要介绍基于权重的轮询负载均衡

例如 orderService 是一个消费者，userService 是提供者，根据权重的不同，在一次完整的轮询((100+300+200)/100 = 6次)中，A服务一定只会被轮询到一次，B服务被轮询到3次，C服务轮询到2次

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 12][]

### 8.2.4 最少活跃数负载均衡 ###

最少活跃数通俗来说就是将请求指向处理速度更快的提供者节点，让请求速度更慢的节点收到更少的请求

例如 orderService 是一个消费者，userService 是提供者，根据响应时间的不同，请求会更多地指向A节点，B节点次之，C节点最少

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 13][]

### 8.2.5 一致性Hash负载均衡 ###

一致性Hash是指将调用方法相同、参数相同的请求发送到同一个提供者节点中

例如 orderService 是一个消费者，userService 是提供者，则无论请求数量多少，id为1的请求永远发送到A服务，id为2的请求永远发送到B服务，id为3的请求永远发送到C服务。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 14][]

## 8.3 负载均衡配置 ##

### 8.3.1 设置负载均衡方法 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 15][]

### 8.3.2 设置权重 ###

## 8.4 服务降级 ##

### 8.4.1 概念 ###

服务降级即当服务器压力剧增的情况下，根据实际业务情况及流量，对一些服务和页面有策略的不处理或换种简单的方式处理，从而释放服务器资源以保证核心交易正常运作或高效运作。

我们可以通过服务降级功能临时屏蔽某个出错的非关键业务，并定义降级后的返回策略

## 8.5 集群容错 ##

### 8.5.1 概念和模式 ###

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

**Failfast Cluster(默认)**

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

**Failsafe Cluster**

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

**Failback Cluster**

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

**Forking Cluster**

并行调用多个服务器，只要一个成功即返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。可通过 `forks="2"` 来设置最大并行数。

**Broadcast Cluster**

广播调用所有提供者，逐个调用，任意一台报错则报错 [\[2\]][2]。通常用于通知所有提供者更新缓存或日志等本地资源信息。

### 8.5.2 修改方式 ###

<dubbo:reference cluster="failsafe" />

## 8.5 集群容错结合 Hyxtrix ##

### 8.5.1 概念 ###

Hystrix 旨在通过控制那些访问远程系统、服务和第三方库的节点，从而对延迟和故障提供更强大的容错能力。Hystrix 具备拥有回退机制和断路器功能的线程和信号隔离，请求缓存和请求打包，以及监控和配置等功能

### 8.5.2 使用 ###

**消费者和提供者均引入依赖：**

使用 EditStarters 插件，在 setting -> plugin 中搜索并安装

![20200630102122469.png][]

按住 Alt + Insert

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 16][]

使用默认地址

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 17][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 18][]

自动添加

![20200630102451249.png][]

**修改消费者和提供者的启动类：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 19][]

**提供者方法修改：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 20][]

**消费者方法修改：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 21][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2020062217252313.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200621181319331.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200621183112682.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[http_archive.apache.org_dist_zookeeper_zookeeper-3.4.6]: http://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/
[https_github.com_apache_dubbo-admin]: https://github.com/apache/dubbo-admin
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200622175633819.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/2020062217565673.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[https_github.com_IDLC1_dubboDemos]: https://github.com/IDLC1/dubboDemos
[http_dubbo.apache.org_zh-cn_docs_user_demos_preflight-check.html]: http://dubbo.apache.org/zh-cn/docs/user/demos/preflight-check.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20200624093906393.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20200623175426902.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 7]: https://img-blog.csdnimg.cn/20200623175542378.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[https_blog.csdn.net_qq_42234452_article_details_90906692]: https://blog.csdn.net/qq_42234452/article/details/90906692
[http_dubbo.apache.org_zh-cn_docs_user_demos_multi-versions.html]: http://dubbo.apache.org/zh-cn/docs/user/demos/multi-versions.html
[1]: http://dubbo.apache.org/zh-cn/docs/user/demos/local-stub.html#fn1
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 8]: https://img-blog.csdnimg.cn/20200629102523884.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 9]: https://img-blog.csdnimg.cn/20200629102652426.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[2020062910274047.png]: https://img-blog.csdnimg.cn/2020062910274047.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 10]: https://img-blog.csdnimg.cn/20200629102755234.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 11]: https://img-blog.csdnimg.cn/20200629110438208.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 12]: https://img-blog.csdnimg.cn/20200629112144455.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 13]: https://img-blog.csdnimg.cn/2020062911251817.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 14]: https://img-blog.csdnimg.cn/20200629113353991.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 15]: https://img-blog.csdnimg.cn/20200629170150691.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[2]: http://dubbo.apache.org/zh-cn/docs/user/demos/fault-tolerent-strategy.html#fn2
[20200630102122469.png]: https://img-blog.csdnimg.cn/20200630102122469.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 16]: https://img-blog.csdnimg.cn/20200630102303693.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 17]: https://img-blog.csdnimg.cn/2020063010232074.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 18]: https://img-blog.csdnimg.cn/20200630102418489.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[20200630102451249.png]: https://img-blog.csdnimg.cn/20200630102451249.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 19]: https://img-blog.csdnimg.cn/20200630102622144.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 20]: https://img-blog.csdnimg.cn/20200630103403978.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 21]: https://img-blog.csdnimg.cn/20200630103509837.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx,size_16,color_FFFFFF,t_70