亲宝软件园·资讯

展开

Apache Dubbo 远程通信

多氯环己烷 人气:0

前言

参考资料：
《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 的架构图

1.3 Spring Cloud 与 Dubbo 的区别

参考：https://segmentfault.com/a/1190000038320266

比较项DubboSpring Cloud
通信协议基于 TCP 协议传输，使用 Netty 配合以Hession序列化完成RPC通信基于 HTTP 协议 + REST 接口调用远程过程的通信
服务调用方式RPCREST API
定位SOA 时代的产物微服务架构时代
关注点服务的重用性及解决信息孤岛问题；服务治理解耦，降低业务之间的耦合度；微服务治理整套方案
模块服务注册中心、服务提供者、服务消费者、管控中心分布式一站式框架
组件DubboSpring Cloud (Netflix)
注册中心以前是 Zookeeper，现在推广 NacosSpring Cloud Eureka
服务监控Dubbo-monitorSpring 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广播通知广播调用所有的服务提供者，任意一个服务报错则表示服务调用失败通常用于通知所有的服务提供者更新缓存或者本地资源信息
@Service(cluster = "failfast") //更改容错方式为快速失败
public class TestServiceImpl implements TestService {
	@Override
	public String test() {
	    ...
	}
}

1.6 Dubbo 的 4 种负载均衡策略

负载均衡策略策略名称说明
Random LoadBalance随机算法可以针对性能较好的服务器设置较大的权重值，权重值越大，随机的概率也会越大
RoundRobin LoadBalance轮询按照公约后的权重设置轮询比例
LeastActive LoadBalance最少活跃调用处理较慢的节点将会收到更少的请求
ConsistentHash LoadBalance一致性Hash相同参数的请求总是发送到同一个服务提供者
@Service(loadbalance = "roundrobin") //更改负载均衡策略为轮询
public class TestServiceImpl implements TestService {
	@Override
	public String test() {
	    ...
	}
}

1.7 主机绑定规则

2. 构建 Dubbo 服务提供方

2.1 构建服务接口模块

<!-- Dubbo -->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo</artifactId>
    <version>${dubbo.version}</version>
</dependency>

在 service 包下新建接口：

public interface TestService {
	String test(String message);
}

执行 mvn install 命令将接口 jar 包安装到本地仓库；

2.2 添加 pom.xml 依赖文件

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

<!-- Dubbo Spring Cloud Starter -->
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
<!-- Sample API 接口声明-->
    <artifactId>spring-cloud-dubbo-sample-api</artifactId>
<!-- Spring Cloud Nacos Service Discovery -->
    <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>

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 -->
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
<!-- Sample API 接口声明-->
    <artifactId>spring-cloud-dubbo-sample-api</artifactId>
<!-- Spring Cloud Nacos Service Discovery -->
    <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>

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 修改业务类

在服务类中使用 @Reference 注解注入 TestService 即可；

@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 服务器

Zookeeper 服务器的下载详情请见笔者的另一篇文章：apache 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() {
    }
}

注意：@Service 注解是 com.alibaba.dubbo.config.annotation.Service 包下的；

5.4 服务消费者

5.4.1 修改 application.yml 配置文件

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

5.4.2 在主程序类上添加注解

5.4.3 编写业务类

这里直接在 controller 接口里直接调用服务提供者提供的 TestService 即可；

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

@Reference 注解可以获得一个远程代理对象；

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

6.1 下载 Nacos 服务器

Nacos 服务器的下载详情请见笔者的另一篇文章：apache zookeeper使用方法实例详解

6.2 工程结构

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

6.3 引入 pom.xml 依赖文件

在 nacos-sample-provider 中添加依赖文件：

<!-- 接口定义类 -->
<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 在主程序类上添加注解

@DubboComponentScan：dubbo 的包扫描注解；

6.6 编写业务类实现

6.2 中定义的接口；

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

6.7 启动测试

启动服务，访问 Nacos 控制台，进入“服务管理” -> “服务列表”，可以看到所有注册在 Nacos 上的服务；

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

这里仅提供服务提供者的示例，服务消费者类似；

7.1 下载 Nacos 服务器

Nacos 服务器的下载详情请见笔者的另一篇文章：apache zookeeper使用方法实例详解

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-nacos-sample-provider 中添加依赖文件：

<!-- 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 依赖 -->
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-starter-dubbo</artifactId>
<!-- api 模块 -->
  <groupId>com.gupaoedu.book.springcloud</groupId>
  <artifactId>spring-cloud-dubbo-sample-api</artifactId>
  <version>1.0-SNAPSHOT</version>
<!-- 基于 Nacos 的服务注册与发现 -->
  <artifactId>spring-cloud-alibaba-nacos-discovery</artifactId>
  <artifactId>spring-cloud-context</artifactId>
  <version>2.1.1.RELEASE</version>

7.4 添加 application.yml 依赖文

件与 Spring Boot 这整合方式的主要区别就在 pom.xml 配置文件和 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 编写业务类实现

7.2 中定义的接口即可；

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

加载全部内容
相关教程
猜你喜欢
用户评论