其他分享
首页 > 其他分享> > 微服务架构 | 12.1 使用 Apache Dubbo 实现远程通信

微服务架构 | 12.1 使用 Apache Dubbo 实现远程通信

作者：互联网

目录

前言

参考资料：
《Spring Microservices in Action》
《Spring Cloud Alibaba 微服务原理与实战》
《B站 尚硅谷 SpringCloud 框架开发教程 周阳》

Apache Dubbo 是一个分布式服务框架，主要实现多个系统之间的高性能、透明化调用；
Dubbo 相关内容笔者之前写过一篇入门笔记：Dubbo快速上手笔记 - 环境与配置。入门笔记强调的是 Dubbo 的一些基本特性，以与 Zookeeper 的整合。因此这里将重点放在 Dubbo 与 Spring Cloud 的联系、区别以及整合；

1. Dubbo 基础知识

1.1 Dubbo 是什么

1.2 Dubbo 的架构图

Dubbo 基于消费端的自动服务发现能力

1.3 Spring Cloud 与 Dubbo 的区别

比较项 Dubbo Spring Cloud
通信协议 基于 TCP 协议传输，使用 Netty 配合以Hession序列化完成RPC通信 基于 HTTP 协议 + REST 接口调用远程过程的通信
服务调用方式 RPC REST API
定位 SOA 时代的产物 微服务架构时代
关注点 服务的重用性及解决信息孤岛问题；服务治理 解耦，降低业务之间的耦合度；微服务治理整套方案
模块 服务注册中心、服务提供者、服务消费者、管控中心 分布式一站式框架
组件 Dubbo Spring Cloud (Netflix)
注册中心 以前是 Zookeeper，现在推广 Nacos Spring Cloud Eureka
服务监控 Dubbo-monitor Spring Boot Admin
熔断器 6种容错模式 Spring Cloud Hystrix
负载均衡 4 种负载均衡策略 Spring Cloud Ribbon
服务降级 Mock 机制 Hystrix 的 @HystrixCommand 注解
网关 无 Spring Cloud Zuul
配置 无 Spring Cloud Config
服务跟踪 无 Spring Cloud Sleuth
数据流 无 Spring Cloud Stream
批量任务 无 Spring Cloud Task
消息总线 无 Spring Cloud Bus

1.4 Dubbo 的特点

1.5 Dubbo 的 6 种容错模式

容错模式 模式名称 说明 适用场景
Failover Cluster 【默认】失败自动切换 当服务调用失败后，会切换到集群中的其他机器进行重试，默认重试次数为2，通过属性 retries=2 可以修改次数 通常用于读操作（查），因为事务型操作会带来数据重复问题
Failfast Cluster 快速失败 当服务调用失败后，立即报错，也就是只发起一次调用 通常用于一些幂等的写操作（增删改），比如新增数据；以避免在结果不确定的情况下导致数据重复插入的问题
Failsafe Cluster 失败安全 出现异常时，直接忽略异常 使用 Failover Cluster(retries="0")，应对（增删改）操作
Failback Cluster 失败后自动回复 服务调用出现异常时，在后台记录这条失败的请求定时重发 适合用于消息通知操作，保证这个请求一定发送成功
Forking Cluster 并行提交 并行调用集群中的多个服务，只要其中一个成功就返回。可以通过forks=2来设置最大并行数
Broadcast Cluster 广播通知 广播调用所有的服务提供者，任意一个服务报错则表示服务调用失败 通常用于通知所有的服务提供者更新缓存或者本地资源信息

1.6 Dubbo 的 4 种负载均衡策略

负载均衡策略 策略名称 说明
Random LoadBalance 随机算法 可以针对性能较好的服务器设置较大的权重值，权重值越大，随机的概率也会越大
RoundRobin LoadBalance 轮询 按照公约后的权重设置轮询比例
LeastActive LoadBalance 最少活跃调用 处理较慢的节点将会收到更少的请求
ConsistentHash LoadBalance 一致性Hash 相同参数的请求总是发送到同一个服务提供者

1.7 主机绑定规则


2. 构建 Dubbo 服务提供方

2.1 构建服务接口模块

2.2 添加 pom.xml 依赖文件

<!-- Spring Cloud 核心包-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter</artifactId>
</dependency>

<!-- Dubbo Spring Cloud Starter -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

<!-- Sample API 接口声明-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-dubbo-sample-api</artifactId>
</dependency>

<!-- Spring Cloud Nacos Service Discovery -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>

2.3 修改 application.yml 配置文件

spring:
  application:
    name: spring-cloud-dubbo-provider
  cloud:
    zookeeper:
      discovery:
        register: true  #表示该服务要注册进注册中心
      connect-string: localhost:2181  #zookeeper 服务器位置
dubbo:     
  protocol:
    name: dubbo
    port: 20880

2.4 在主程序类上添加注解

2.5 实现 2.1 定义的接口

@Service
public class TestServiceImpl implements TestService {
    @Value("${dubbo.application.name}")
    private String serviceName;
    
	@Override
	public String test(String message) {
		return serviceName;
	}
}

3. 构建 Dubbo 服务消费方

3.1 添加 pom.xml 依赖文件

<!-- Spring Cloud 核心包-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter</artifactId>
</dependency>

<!-- Dubbo Spring Cloud Starter -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

<!-- Sample API 接口声明-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-dubbo-sample-api</artifactId>
</dependency>

<!-- Spring Cloud Nacos Service Discovery -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
</dependency>

3.2 修改 application.yml 配置文件

spring:
  application:
    name: spring-cloud-dubbo-consumer
  cloud:
    zookeeper:
      discovery:
        register: false #表示该服务不要注册进注册中心
      connect-string: localhost:2181  
dubbo:     
  cloud:
    subscribed-services: spring-cloud-dubbo-provider  #表示服务调用者订阅的服务提供方的应用名称列表。默认值为“*”，不推荐使用默认值

3.3 修改业务类

@RestController
public class TestController{
    @Reference 
    private TestService testService;
    
    @GetMapping("/message")
    public String testController(){
        return testService.test("message");
}

4. 在消费者端使用 Mock 配置实现服务降级

4.1 为接口实现一种服务降级方法

public class MockTestService implements TestService {
	@Override
	public String test(String message) {
		return "当前无法访问";
	}
}

4.2 给 @Reference 注解增加 mock 参数

@RestController
public class TestController{
    @Reference(mock = "com.dlhjw.springcloud.mock.MockTestService", cluster="failfast")
    private TestService testService;
    
    @GetMapping("/message")
    public String testController(){
        return testService.test("message");
}

5. Dubbo 使用 Zookeeper 作为注册中心（Spring Boot）

5.1 下载 Zookeeper 服务器

5.2 引入 pom.xml 依赖文件

<!-- Zookeeper 相关依赖 -->
<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.5.3-beta</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>4.0.1</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>4.0.1</version>
</dependency>

<!-- Dubbo 相关依赖 -->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.5</version>
</dependency>

<!-- Spring Boot 依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>

5.3 服务提供者

5.3.1 修改 application.yml 配置文件

spring:
  application:
    name: springboot-dubbo-demo 
dubbo:
  #服务提供方的信息
  application:
    name: springboot-provider      
  protocol:
    name: dubbo
    port: 20880
  registry:
    address: zookeeper://localhost:2181  #zookeeper地址
  #scan:
    #base-packages: com.dlhjw.dubbo.service.impl  #指定 Dubbo 服务实现类的扫描基准包，作用等同于 主程序类上的 @DubboComponentScan

5.3.2 在主程序类上添加注解

5.3.3 编写业务类

public interface TestService {
    void testDubbo();
}

@Service(version = "1.0.0",timeout = 3000)
public class TestServiceImpl implements TestService{
    @Override
    public void testDubbo() {
    }
}

5.4 服务消费者

5.4.1 修改 application.yml 配置文件

dubbo:
  #服务消费方的信息
  application:
    name: springboot-consumer 
  registry:
    #zookeeper地址
    address: zookeeper://localhost:2181

5.4.2 在主程序类上添加注解

5.4.3 编写业务类

@Reference(version = "1.0.0",timeout = 300)
private TestService testService;

6. Dubbo 使用 Nacos 作为注册中心（Spring Boot）

6.1 下载 Nacos 服务器

6.2 工程结构

public interface IHelloService{
    String sayHello(String name);
}

6.3 引入 pom.xml 依赖文件

<!-- 接口定义类 -->
<dependency>
  <groupId>com.gupaoedu.book.nacos</groupId>
  <version>1.0-SNAPSHOT</version>
  <artifactId>nacos-sample-api</artifactId>
</dependency>
<!-- Nacos 的 starter 组件 -->
<dependency>
  <groupId>com.alibaba.boot</groupId>
  <artifactId>nacos-discovery-spring-boot-starter</artifactId>
  <version>0.2.4</version>
  <exclusions>
    <exclusion>
      <groupId>com.alibaba.spring</groupId>
      <artifactId>spring-context-support</artifactId>
    </exclusion>
  </exclusions>
</dependency>
<!-- Dubbo 的 starter 组件 -->
<dependency>
  <groupId>org.apache.dubbo</groupId>
  <artifactId>dubbo-spring-boot-starter</artifactId>
  <version>2.7.5</version>
</dependency>

6.4 修改 application.yml 配置文件

dubbo:
  application:
    name: spring-boot-dubbo-nacos-sample 
  registry:
    address: nacos://127.0.0.1:8848  #基于 Nacos 协议
  protocol: 
    name: dubbo
    port: 20880

6.5 在主程序类上添加注解

6.6 编写业务类

@Service 
public class HelloServiceImpl implements IHelloService{
    @Override 
    public String sayHello(String name){
        return "He1lo World:"+name;
    }
}

6.7 启动测试


7. Dubbo 使用 Nacos 作为注册中心（Spring Cloud）

7.1 下载 Nacos 服务器

7.2 工程结构

public interface IHelloService{
    String sayHello(String name);
}

7.3 添加 pom.xml 依赖

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-dependencies</artifactId>
  <version>Greenwich.SR2</version>
  <type>pom</type>
  <scope>import</scope>
</dependency>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-dependencies</artifactId>
  <version>2.1.11.RELEASE</version>
  <type>pom</type>
  <scope>import</scope>
</dependency>
<dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  <version>2.1.1.RELEASE</version>
  <type>pom</type>
  <scope>import</scope>
</dependency>

<!-- Spring Cloud 核心包 -->
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter</artifactId>
  <exclusions>
    <exclusion>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-context</artifactId>
    </exclusion>
  </exclusions>
</dependency>

<!-- Spring Cloud 的 Dubbo 依赖 -->
<dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

<!-- api 模块 -->
<dependency>
  <groupId>com.gupaoedu.book.springcloud</groupId>
  <artifactId>spring-cloud-dubbo-sample-api</artifactId>
  <version>1.0-SNAPSHOT</version>
</dependency>

<!-- 基于 Nacos 的服务注册与发现 -->
<dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-alibaba-nacos-discovery</artifactId>
  <exclusions>
    <exclusion>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-context</artifactId>
    </exclusion>
  </exclusions>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-context</artifactId>
  <version>2.1.1.RELEASE</version>
</dependency>

7.4 添加 application.yml 依赖文件

spring: 
  application: 
    name: spring-cloud-nacos-sample 
  cloud: 
    nacos: 
      discovery:
        server-addr: 127.0.0.1:8848  #Nacos 服务注册中心地址

dubbo: 
  scan: 
    base-packages: com.gupaoedu.book.nacos.bootstrap  #功能等同于 @DubboComponentScan   
  protocol: 
    name: dubbo
    port: 20880
  registry:
    address: spring-cloud://localhost  #将服务挂载到 Spring Cloud 注册中心

7.5 主程序类上无需额外注解

7.6 编写业务类

@Service 
public class HelloServiceImpl implements IHelloService{
    @Override 
    public String sayHello(String name){
        return "He1lo World:"+name;
    }
}

最后

新人制作，如有错误，欢迎指出，感激不尽！
欢迎关注公众号，会分享一些更日常的东西！
如需转载，请标注出处！

标签：Dubbo,服务,dubbo,spring,12.1,Spring,Apache,cloud
来源： https://www.cnblogs.com/dlhjw/p/15824937.html