1. dubbo 配置

1.1. 配置原则

image.png

  • JVM 启动 -D 参数优先，这样可以使用户在部署和启动时进行参数重写，比如在启动时需改变协议的端口。
  • XML(包括 application.properties) 次之，如果在 XML 中有配置，则 dubbo.properties 中的相应配置项无效。
  • Properties 最后，相当于缺省值，只有 XML 没有配置时，dubbo.properties 的相应配置项才会生效，通常用于共享公共配置，比如应用名。

配置启动时检查
image.png


1.2. 重试次数

失败自动切换，当出现失败，重试其它服务器，但重试会带来更长延迟。可通过 retries=”2” 来设置重试次数(不含第一次)。

重试次数配置如下：

或

或

在幂等的方法上可以设置超时次数。

1.3. 超时时间

由于网络或服务端不可靠，会导致调用出现一种不确定的中间状态（超时）。为了避免超时导致客户端资源（线程）挂起耗尽，必须设置超时时间。

1、Dubbo消费端

全局超时配置

指定接口以及特定方法超时配置

2、Dubbo服务端

全局超时配置

指定接口以及特定方法超时配置

1.4. 配置原则

dubbo 推荐在 Provider 上尽量多配置 Consumer 端属性：

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

配置的覆盖规则：
1) 方法级配置别优于接口级别，即小Scope优先 (精确优先)
2) Consumer端配置 优于 Provider配置 优于 全局配置，（当级别一直时）
3) 最后是Dubbo Hard Code的配置值（见配置文档）

image.png

1.5 多版本

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

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

  • 在低压力时间段，先升级一半提供者为新版本
  • 再将所有消费者升级为新版本
  • 然后将剩下的一半提供者升级为新版本
  • 从而实现灰度发布 ```shell 老版本服务提供者配置：

新版本服务提供者配置：

老版本服务消费者配置：

新版本服务消费者配置：

如果不需要区分版本，可以按照以下的方式配置：

  2. <a name="WSRXR"></a>
  3. ### 1.6 本地存根
  4.     远程服务后，客户端通常只剩下接口，而实现全在服务器端，但提供方有些时候想在客户端也执行部分逻辑，比如：做 ThreadLocal 缓存，提前验证参数，调用失败后伪造容错数据等等，此时就需要在 API 中带上 Stub，客户端生成 Proxy 实例，会把 Proxy 通过构造函数传给 Stub [](http://dubbo.apache.org/zh-cn/docs/user/demos/local-stub.html#fn1)，然后把 Stub 暴露给用户，Stub 可以决定要不要去调 Proxy。<br />![image.png](https://cdn.nlark.com/yuque/0/2020/png/144841/1581243897557-58ac098a-fa8e-4194-b5be-0e4aa47c10e3.png#align=left&display=inline&height=273&name=image.png&originHeight=546&originWidth=1358&size=562971&status=done&style=none&width=679)
  6. **在 spring 配置文件中按以下方式配置：**
  8. ```xml
  9. <dubbo:service interface="com.foo.BarService" stub="true" />
  10. 或
  11. <dubbo:service interface="com.foo.BarService" stub="com.foo.BarServiceStub" />

提供 Stub 的实现 ：

  1. package com.foo;
  2. public class BarServiceStub implements BarService {
  3.     private final BarService barService;
  5.     // 构造函数传入真正的远程代理对象
  6.     public BarServiceStub(BarService barService){
  7.         this.barService = barService;
  8.     }
  10.     public String sayHello(String name) {
  11.         // 此代码在客户端执行, 你可以在客户端做ThreadLocal本地缓存，或预先验证参数是否合法，等等
  12.         try {
  13.             return barService.sayHello(name);
  14.         } catch (Exception e) {
  15.             // 你可以容错，可以做任何AOP拦截事项
  16.             return "容错数据";
  17.         }
  18.     }
  19. }

1.7 springboot 与 dubbo 整合的三种方式


1. 导入dubbo-starter，在application.properties配置属性，使用@Service【暴露服务】使用@Reference【引用服务】

  1. //开启基于注解的dubbo功能
  2. @EnableDubbo
  3. @SpringBootApplication
  4. public class BootUserServiceProviderApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(BootUserServiceProviderApplication.class, args);
  7.     }
  8. }
  1. 保留 dubbo xml 配置文件，导入dubbo-starter，使用@ImportResource导入dubbo的配置文件即可(注释掉 @Service 和 @Reference注解 )
  1. @ImportResource(locations="classpath:provider.xml")
  2. @SpringBootApplication
  3. public class BootUserServiceProviderApplication {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(BootUserServiceProviderApplication.class, args);
  6.     }
  7. }
  1. 使用注解API的方式：将每一个组件手动创建到容器中,让dubbo来扫描其他的组件
  1. //开启基于注解的dubbo功能
  2. @EnableDubbo(scanBasePackages="com.atguigu.gmall")
  3. //开启服务容错
  4. @EnableHystrix
  5. @SpringBootApplication
  6. public class BootUserServiceProviderApplication {
  7.     public static void main(String[] args) {
  8.         SpringApplication.run(BootUserServiceProviderApplication.class, args);
  9.     }
  10. }
  1. @Configuration
  2. public class MyDubboConfig {
  4.     @Bean
  5.     public ApplicationConfig applicationConfig() {
  6.         ApplicationConfig applicationConfig = new ApplicationConfig();
  7.         applicationConfig.setName("boot-user-service-provider");
  8.         return applicationConfig;
  9.     }
  11.     //<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
  12.     @Bean
  13.     public RegistryConfig registryConfig() {
  14.         RegistryConfig registryConfig = new RegistryConfig();
  15.         registryConfig.setProtocol("zookeeper");
  16.         registryConfig.setAddress("127.0.0.1:2181");
  17.         return registryConfig;
  18.     }
  20.     //<dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
  21.     @Bean
  22.     public ProtocolConfig protocolConfig() {
  23.         ProtocolConfig protocolConfig = new ProtocolConfig();
  24.         protocolConfig.setName("dubbo");
  25.         protocolConfig.setPort(20882);
  26.         return protocolConfig;
  27.     }
  28.     /**
  29.      *<dubbo:service interface="com.atguigu.gmall.service.UserService"
  30.         ref="userServiceImpl01" timeout="1000" version="1.0.0">
  31.         <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
  32.     </dubbo:service>
  33.      */
  34.     @Bean
  35.     public ServiceConfig<UserService> userServiceConfig(UserService userService){
  36.         ServiceConfig<UserService> serviceConfig = new ServiceConfig<>();
  37.         serviceConfig.setInterface(UserService.class);
  38.         serviceConfig.setRef(userService);
  39.         serviceConfig.setVersion("1.0.0");
  41.         //配置每一个method的信息
  42.         MethodConfig methodConfig = new MethodConfig();
  43.         methodConfig.setName("getUserAddressList");
  44.         methodConfig.setTimeout(1000);
  46.         //将method的设置关联到service配置中
  47.         List<MethodConfig> methods = new ArrayList<>();
  48.         methods.add(methodConfig);
  49.         serviceConfig.setMethods(methods);
  51.         //ProviderConfig
  52.         //MonitorConfig
  54.         return serviceConfig;
  55.     }
  56. }

2. 高可用

2.1 zookeeper宕机与dubbo直连

现象：zookeeper注册中心宕机，还可以消费dubbo暴露的服务。

原因：**健壮性

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

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

dubbo 直连
image.png
**

2.2 集群下dubbo负载均衡配置

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

1.Random LoadBalance（默认）

随机，按权重设置随机概率。
在一个截面上碰撞的概率高，但调用量越大分布越均匀，而且按概率使用权重后也比较均匀，有利于动态调整提供者权重。
image.png

2. RoundRobin LoadBalance
轮循，按公约后的权重设置轮循比率。

存在慢的提供者累积请求的问题，比如：第二台机器很慢，但没挂，当请求调到第二台时就卡在那，久而久之，所有请求都卡在调到第二台上。
image.png

3. LeastActive LoadBalance**
最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差。
使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。
image.png

4. ConsistentHash LoadBalance
一致性 Hash，相同参数的请求总是发到同一提供者。
当某一台提供者挂时，原本发往该提供者的请求，基于虚拟节点，平摊到其它提供者，不会引起剧烈变动。算法参见：http://en.wikipedia.org/wiki/Consistent_hashing

缺省只对第一个参数 Hash，如果要修改，请配置 <dubbo:parameter key="hash.arguments" value="0,1" />

缺省用 160 份虚拟节点，如果要修改请配置 <dubbo:parameter key="hash.nodes" value="320" />
image.png

image.png

设置负载均衡机制
image.png
**调整权重
image.png
**

3. 整合 hystrix，服务熔断与降级处理

3.1 服务降级

什么是服务降级？

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

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

向注册中心写入动态配置覆盖规则：

  1. RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getAdaptiveExtension();
  2. Registry registry = registryFactory.getRegistry(URL.valueOf("zookeeper://10.20.153.10:2181"));
  3. registry.register(URL.valueOf("override://0.0.0.0/com.foo.BarService?category=configurators&dynamic=false&application=foo&mock=force:return+null"));

其中：

  • mock=force:return+null 表示消费方对该服务的方法调用都直接返回 null 值，不发起远程调用。用来屏蔽不重要服务不可用时对调用方的影响。【对应页面的「屏蔽」】
  • 还可以改为 mock=fail:return+null 表示消费方对该服务的方法调用在失败后，再返回 null 值，不抛异常。用来容忍不重要服务不稳定时对调用方的影响。【对应页面的「容错」】

image.png

3.2 集群容错

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

集群容错模式
**Failover Cluster**

失败自动切换，当出现失败，重试其它服务器。通常用于读操作，但重试会带来更长延迟。可通过 retries=”2” 来设置重试次数(不含第一次)。

重试次数配置如下：

  1. <dubbo:service retries="2" />
  2. 或
  3. <dubbo:reference retries="2" />
  4. 或
  5. <dubbo:reference>
  6.     <dubbo:method name="findFoo" retries="2" />
  7. </dubbo:reference>

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

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

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

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

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

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

  1. <dubbo:service cluster="failsafe" />
  2. 或
  3. <dubbo:reference cluster="failsafe" />

3.3 整合 hystrix

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

**_1、配置spring-cloud-starter-netflix-hystrix**
消费者和提供者都需要：
spring boot官方提供了对hystrix的集成，直接在pom.xml里加入依赖：

  1. <dependency>
  2.     <groupId>org.springframework.cloud</groupId>
  3.     <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  4.     <version>1.4.4.RELEASE</version>
  5. </dependency>

然后在 Application 类上增加@EnableHystrix来启用 hystrix starter：

  1. @SpringBootApplication
  2. @EnableHystrix
  3. public class ProviderApplication {}

2、配置Provider端
在Dubbo的Provider上增加 @HystrixCommand 配置，这样子调用就会经过 Hystrix 代理。

  1. @Service(version = "1.0.0")
  2. public class HelloServiceImpl implements HelloService {
  3.     @HystrixCommand(commandProperties = {
  4.      @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),
  5.      @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000") })
  6.     @Override
  7.     public String sayHello(String name) {
  8.         // System.out.println("async provider received: " + name);
  9.         // return "annotation: hello, " + name;
  10.         throw new RuntimeException("Exception to show hystrix enabled.");
  11.     }
  12. }

3、配置Consumer端
对于 Consumer 端，则可以增加一层 method 调用，并在 method 上配置 @HystrixCommand。当调用出错时，会走到fallbackMethod = "reliable"的调用里。

  1. @Reference(version = "1.0.0")
  2. private HelloService demoService;
  4. @HystrixCommand(fallbackMethod = "reliable")
  5. public String doSayHello(String name) {
  6.     return demoService.sayHello(name);
  7. }
  8. public String reliable(String name) {
  9.     return "hystrix fallback value";
  10. }

4. dubbo 原理

4.1 RPC 原理

image.png
一次完整的RPC调用流程（同步调用，异步另说）如下：

1）服务消费方（client）调用以本地调用方式调用服务；
2）client stub接收到调用后负责将方法、参数等组装成能够进行网络传输的消息体；
3）client stub找到服务地址，并将消息发送到服务端；
4）server stub收到消息后进行解码；
5）server stub根据解码结果调用本地的服务；
6）本地服务执行并将结果返回给server stub；
7）server stub将返回结果打包成消息并发送至消费方；
8）client stub接收到消息，并进行解码；
9）服务消费方得到最终结果。

RPC框架的目标就是要 2~8 这些步骤都封装起来，这些细节对用户来说是透明的，不可见的。


4.2 netty通信原理

Netty 是一个异步事件驱动的网络应用程序框架， 用于快速开发可维护的高性能协议服务器和客户端。它极大地简化并简化了TCP和UDP套接字服务器等网络编程。

BIO：(Blocking IO)
image.png
**NIO (Non-Blocking IO)
image.png

Selector 一般称 为选择器 ，也可以翻译为 多路复用器，
Connect（连接就绪）、Accept（接受就绪）、Read（读就绪）、Write（写就绪）

Netty基本原理：
image.png

4.3 dubbo 原理

dubbo原理 - 框架设计

image.png

  • config 配置层：对外配置接口，以 ServiceConfig, ReferenceConfig 为中心，可以直接初始化配置类，也可以通过 spring 解析配置生成配置类
  • proxy 服务代理层：服务接口透明代理，生成服务的客户端 Stub 和服务器端 Skeleton, 以 ServiceProxy 为中心，扩展接口为 ProxyFactory
  • registry 注册中心层：封装服务地址的注册与发现，以服务 URL 为中心，扩展接口为 RegistryFactory, Registry, RegistryService
  • cluster 路由层：封装多个提供者的路由及负载均衡，并桥接注册中心，以 Invoker 为中心，扩展接口为 Cluster, Directory, Router, LoadBalance
  • monitor 监控层：RPC 调用次数和调用时间监控，以 Statistics 为中心，扩展接口为 MonitorFactory, Monitor, MonitorService
  • protocol 远程调用层：封装 RPC 调用，以 Invocation, Result 为中心，扩展接口为 Protocol, Invoker, Exporter
  • exchange 信息交换层：封装请求响应模式，同步转异步，以 Request, Response 为中心，扩展接口为 Exchanger, ExchangeChannel, ExchangeClient, ExchangeServer
  • transport 网络传输层：抽象 mina 和 netty 为统一接口，以 Message 为中心，扩展接口为 Channel, Transporter, Client, Server, Codec
  • serialize 数据序列化层：可复用的一些工具，扩展接口为 Serialization, ObjectInput, ObjectOutput, ThreadPool

dubbo原理 - 启动解析、加载配置信息

image.png
image.png

BeanDefinitionParser 是 spring 的 Bean定义解析器，用来解析标签，在 dubbo 中的实现是：DubboBeanDefinitionParser，即 dubbo 的标签解析器。

dubbo原理 - 服务暴露

image.png

dubbo原理 - 服务引用

image.png


dubbo原理 - 服务调用

image.png