Dubbo（从入门到掌握）看完这一篇就够了

文章目录

  • 一、 Dubbo概述
    • 1.Dubbo概念
    • 2.Dubbo架构
    • 3.Dubbo快速入门
  • 二、springboot项目整合dubbo
    • 1.创建生产者服务
      • （1）项目路径总览
      • （2）添加项目依赖
      • （3）创建UserService接口，并创建sayHello方法
      • （4）创建UserServiceImpl实现类，并实现sayHello方法
      • （5）配置yaml文件
      • （6）项目pom文件
    • 2.创建消费者服务
      • （1）项目路径总览
      • （2）添加项目依赖
      • （3）创建UserController类，并创建sayHello接口
      • （5）配置yaml文件
      • （6）项目pom文件
    • 3.测试
    • 4.源码压缩包如下
  • 三、dubbo-admin
  • 四、 Dubbo 高级特性
    • 1.序列化
    • 2.地址缓存
    • 3.超时与重试
      • （1）设置超时和重试机制
      • （2）超时和重试代码
    • 4.多版本
      • （1）代码如下
    • 5.负载均衡
      • （1）代码如下
    • 5.集群容错
      • （1）代码如下

一、 Dubbo概述

1.Dubbo概念

  • Dubbo是阿里巴巴公司开源的一个高性能、轻量级的 Java RPC 框架。
  • 致力于提供高性能和透明化的 RPC 远程服务调用方案，以及 SOA 服务治理方案。
  • 官网：http://dubbo.apache.org

2.Dubbo架构

在这里插入图片描述
节点角色说明：

  • Provider：暴露服务的服务提供方
  • Container：服务运行容器
  • Consumer：调用远程服务的服务消费方
  • Registry：服务注册与发现的注册中心
  • Monitor：统计服务的调用次数和调用时间的监控中心

3.Dubbo快速入门

  • 创建服务提供者Provider模块
  • 创建服务消费者Consumer模块
  • 在服务提供者模块编写 UserServiceImpl 提供服务
  • 在服务消费者中的 UserController 远程调用UserServiceImpl 提供的服务
  • 分别启动两个服务，测试。

二、springboot项目整合dubbo

1.创建生产者服务

dubbo-service代表服务生产者

（1）项目路径总览

请添加图片描述

（2）添加项目依赖

<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><version>2.7.4.1</version><type>pom</type><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions></dependency><!-- dubbo 2.7.x引入--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.4.1</version></dependency>

（3）创建UserService接口，并创建sayHello方法

package com.example.service;public interface UserService {public String sayHello();
}

（4）创建UserServiceImpl实现类，并实现sayHello方法

package com.example.service.impl;import com.example.service.UserService;
import org.apache.dubbo.config.annotation.Service;@Service       //导入dubbo的service注解，将这个类提供的方法对外发布，注册到注册中心中
public class UserServiceImpl implements UserService {@Overridepublic String sayHello() {return "hello dubbo !";}
}

（5）配置yaml文件

dubbo:registry:address: zookeeper://127.0.0.1:2181   #自己的zookeeper服务器的IP:默认端口号application:name: dubbo-zookeeper-producer1 #注册进去的名字protocol:name: dubbo     #设置类型port: -1      #因为dubbo的服务器端口号是不能唯一的，所以，设置为-1会帮我们自动改变端口号config-center:timeout: 120000  #超时时间  （毫秒）server:port: 9001

（6）项目pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.11</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example</groupId><artifactId>dubbo-service</artifactId><version>0.0.1-SNAPSHOT</version><name>dubbo-service</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version><elasticsearch.version>7.12.1</elasticsearch.version><zookeeper.version>4.0.0</zookeeper.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web-services</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-test</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><version>2.7.4.1</version><type>pom</type><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions></dependency><!-- dubbo 2.7.x引入--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.4.1</version></dependency></dependencies><build><finalName>${project.artifactId}</finalName><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>1.8</source> <!--指明源码用的Jdk版本--><target>1.8</target> <!--指明打包后的Jdk版本--></configuration></plugin><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-surefire-plugin</artifactId><configuration><testFailureIgnore>true</testFailureIgnore></configuration></plugin></plugins></build></project>

2.创建消费者服务

dubbo-web代表服务消费者

（1）项目路径总览

请添加图片描述

（2）添加项目依赖

        <!--        dubbo-zookeeper--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><version>2.7.4.1</version><type>pom</type><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions></dependency><!-- dubbo 2.7.x引入--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.4.1</version></dependency>

（3）创建UserController类，并创建sayHello接口


import com.example.service.UserService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/user")
public class UserController {@Reference          //dubbo 的 Referenceprivate UserService userService;@RequestMapping("/sayHello")public String sayHello() {return userService.sayHello();}
}

（5）配置yaml文件

dubbo:application:name: dubbo-zookeeper-consumer1protocol:name: dubboport: -1registry:address: zookeeper://127.0.0.1:2181  #默认端口号为2181config-center:timeout: 12000  #超时时间
server:port: 8083

（6）项目pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.11</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example</groupId><artifactId>dubbo-web</artifactId><version>0.0.1-SNAPSHOT</version><name>dubbo-web</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version><elasticsearch.version>7.12.1</elasticsearch.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web-services</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-test</artifactId></dependency><dependency><groupId>com.example</groupId><artifactId>dubbo-service</artifactId><version>0.0.1-SNAPSHOT</version><scope>compile</scope></dependency><!--        dubbo-zookeeper--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><version>2.7.4.1</version><type>pom</type><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions></dependency><!-- dubbo 2.7.x引入--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.4.1</version></dependency></dependencies><build><finalName>${project.artifactId}</finalName><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>1.8</source> <!--指明源码用的Jdk版本--><target>1.8</target> <!--指明打包后的Jdk版本--></configuration></plugin><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-surefire-plugin</artifactId><configuration><testFailureIgnore>true</testFailureIgnore></configuration></plugin></plugins></build></project>

3.测试

  • 先启动zookeeper
    运行zkServer.cmd请添加图片描述
  • 再启动服务生产者
  • 再启动服务消费者
  • 最后访问http://localhost:8083/user/sayHello查看效果
    请添加图片描述

4.源码压缩包如下

https://pan.baidu.com/s/1lJBViy5_ipHYoKoQI3AC6w?pwd=gbui

三、dubbo-admin

  • dubbo-admin 管理平台，是图形化的服务管理页面
  • 从注册中心中获取到所有的提供者 / 消费者进行配置管理
  • 路由规则、动态配置、服务降级、访问控制、权重调整、负载均衡等管理功能
  • dubbo-admin 是一个前后端分离的项目。前端使用vue，后端使用springboot
  • 安装 dubbo-admin 其实就是部署该项目

dubbo-admin其实就是dubbo服务的管理平台，一个可视化工具，可以自行下载

四、 Dubbo 高级特性

1.序列化

  • dubbo 内部已经将序列化和反序列化的过程内部封装了
  • 我们只需要在定义pojo类时实现Serializable接口即可
  • 一般会定义一个公共的pojo模块，让生产者和消费者都依赖该模块。

2.地址缓存

假如注册中心挂了，服务是否可以正常访问？

  • 可以，因为dubbo服务消费者在第一次调用时，会将服务提供方地址缓存到本地，以后在调用则不会访问注册中心。
    当服务提供者地址发生变化时，注册中心会通知服务消费者。
    在这里插入图片描述

3.超时与重试

  • 服务消费者在调用服务提供者的时候发生了阻塞、等待的情形，这个时候，服务消费者会一直等待下去。
  • 在某个峰值时刻，大量的请求都在同时请求服务消费者，会造成线程的大量堆积，势必会造成雪崩。
    请添加图片描述
    解决办法：

（1）设置超时和重试机制

  • dubbo 利用超时机制来解决这个问题，设置一个超时时间，在这个时间段内，无法完成服务访问，则自动断开连接。
  • 使用timeout属性配置超时时间，默认值1000，单位毫秒。
  • 设置了超时时间，在这个时间段内，无法完成服务访问，则自动断开连接。
  • 如果出现网络抖动，则这一次请求就会失败。
  • Dubbo 提供重试机制来避免类似问题的发生。
  • 通过 retries 属性来设置重试次数。默认为 2 次。

（2）超时和重试代码

其实就是在service上加配置属性，

@Service(timeout=3000) @Reference(timeout=3000)
@Service(retries=2) @Reference(retries=2)

请添加图片描述

4.多版本

  • 灰度发布：当出现新功能时，会让一部分用户先使用新功能，用户反馈没问题时，再将所有用户迁移到新功能。
  • dubbo 中使用version 属性来设置和调用同一个接口的不同版本

可以控制服务使用范围

（1）代码如下

其实就是在服务生产者的service注解和服务消费者的Reference注解上加version属性，并确保值相同，才能访问的到。

@Service(version="1")
@Reference(version="1")

请添加图片描述
请添加图片描述

5.负载均衡

负载均衡策略（4种）：

  • Random ：按权重随机，默认值。按权重设置随机概率。
  • RoundRobin ：按权重轮询。
  • LeastActive：最少活跃调用数，相同活跃数的随机。
  • ConsistentHash：一致性 Hash，相同参数的请求总是发到同一提供者。

（1）代码如下

再在生产者的service注解上加loadbalance属性，默认是random随机负载

@Service(loadbalance="random") 
@Reference(loadbalance="random")

请添加图片描述

5.集群容错

集群容错模式：

  • Failover Cluster：失败重试。默认值。当出现失败，重试其它服务器 ，默认重试2次，使用 retries 配置。一般用于读操作
  • Failfast Cluster ：快速失败，只发起一次调用，失败立即报错。通常用于写操作。
  • Failsafe Cluster ：失败安全，出现异常时，直接忽略。返回一个空结果。
  • Failback Cluster ：失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。
  • Forking Cluster ：并行调用多个服务器，只要一个成功即返回。
  • Broadcast Cluster ：广播调用所有提供者，逐个调用，任意一台报错则报错。

（1）代码如下

 @Service(cluster="failfast") @Reference(cluster="failfast")

请添加图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/617221.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Spring Boot统一功能处理（一）

Spring Boot统一功能处理（一）

本篇主要介绍Spring Boot的统一功能处理中的拦截器。 目录 一、拦截器的基本使用 二、拦截器实操 三、浅尝源码 初始化DispatcherServerlet 处理请求&#xff08;doDispatch) 四、适配器模式 一、拦截器的基本使用 在一般的学校或者社区门口&#xff0c;通常会安排几个…
阅读更多...
【Golang学习笔记】从零开始搭建一个Web框架（三）

【Golang学习笔记】从零开始搭建一个Web框架（三）

文章目录 分组控制分组嵌套中间件 前情提示&#xff1a; 【Golang学习笔记】从零开始搭建一个Web框架&#xff08;一&#xff09;-CSDN博客 【Golang学习笔记】从零开始搭建一个Web框架&#xff08;二&#xff09;-CSDN博客 分组控制 分组控制(Group Control)是 Web 框架应提供…
阅读更多...
粒子群优化算法PSO与鹈鹕优化算法（POA）求解无人机三维路径规划（MATLAB代码）

粒子群优化算法PSO与鹈鹕优化算法（POA）求解无人机三维路径规划（MATLAB代码）

一、无人机路径规划模型介绍 二、算法介绍 close all clear clc dbstop if all error warning (off) global model model CreateModel(); % 创建模型 FF1; [Xmin,Xmax,dim,fobj] fun_info(F);%获取函数信息 pop100;%种群大小(可以自己修改) maxgen100;%最大迭代次数(可以自己…
阅读更多...
JVM虚拟机（三）垃圾回收简介、垃圾回收算法、分代回收、垃圾回收器种类、G1垃圾回收器

JVM虚拟机（三）垃圾回收简介、垃圾回收算法、分代回收、垃圾回收器种类、G1垃圾回收器

目录 一、什么是垃圾回收&#xff1f;1.1 什么是垃圾回收&#xff1f;1.2 什么对象能被垃圾回收&#xff1f;1&#xff09;引用计数法2&#xff09;可达性分析算法 二、JVM 垃圾回收算法2.1 标记清除算法2.2 标记整理算法&#xff08;标记压缩算法&#xff09;2.3 复制算法2.4 …
阅读更多...
如何在Linux部署MeterSphere并实现公网访问进行远程测试工作

如何在Linux部署MeterSphere并实现公网访问进行远程测试工作

文章目录 前言1. 安装MeterSphere2. 本地访问MeterSphere3. 安装 cpolar内网穿透软件4. 配置MeterSphere公网访问地址5. 公网远程访问MeterSphere6. 固定MeterSphere公网地址 前言 MeterSphere 是一站式开源持续测试平台, 涵盖测试跟踪、接口测试、UI 测试和性能测试等功能&am…
阅读更多...
「Python」数据分析师需要掌握到什么程度？4条告诉你

「Python」数据分析师需要掌握到什么程度？4条告诉你

前言 最近经常收到小伙伴们的留言&#xff1a;做数据分析要精通Python吗&#xff1f; 今天们就来好好盘一盘这个话题。 0基础想入门的小伙伴&#xff0c;如果你决定学习数据分析&#xff0c;却没有编程经验&#xff0c;那么这篇内容会非常适合你&#xff0c;让你的困惑得以解…
阅读更多...
Singleton 单例

Singleton 单例

意图 保证一类仅有一个实例&#xff0c;并提供一个访问他的全局访问点 结构 其中&#xff1a; Singleton指定一个Instance操作&#xff0c;允许客户访问它的唯一实例&#xff0c;Instance是一个类操作&#xff1b;可能负责创建他自己的唯一实例。 适应性 当类只能有一个实…
阅读更多...
【网络安全】WebPack源码（前端源码）泄露 + jsmap文件还原

【网络安全】WebPack源码（前端源码）泄露 + jsmap文件还原

前言 webpack是一个JavaScript应用程序的静态资源打包器。它构建一个依赖关系图&#xff0c;其中包含应用程序需要的每个模块&#xff0c;然后将所有这些模块打包成一个或多个bundle。大部分Vue等项目应用会使用webpack进行打包&#xff0c;使用webpack打包应用程序会在网站js…
阅读更多...
进程与线程的区别？

进程与线程的区别？

并发和并行 在聊进程和线程的概念之前&#xff0c;首先了解一下操作系统相关概念&#xff0c;大部分操作系统&#xff08;如Windos、Linux&#xff09;的任务调度是采用时间片轮转的抢占式调度方式&#xff0c;也就是一个任务执行一小段时间后强制暂停去执行下一个任务&#x…
阅读更多...
机器学习周记（第三十四周：文献阅读[GNet-LS]）2024.4.8~2024.4.14

机器学习周记（第三十四周：文献阅读[GNet-LS]）2024.4.8~2024.4.14

目录 摘要 ABSTRACT 1 论文信息 1.1 论文标题 1.2 论文摘要 1.3 论文模型 1.3.1 数据处理 1.3.2 GNet-LS 2 相关代码 摘要 本周阅读了一篇时间序列预测论文。论文模型为GNet-LS&#xff0c;主要包含四个模块&#xff1a;粒度划分模块&#xff08;GD&#xff09;&…
阅读更多...
软件需求设计方法学全程实例剖析幻灯片04-系统用例图和用例规约

软件需求设计方法学全程实例剖析幻灯片04-系统用例图和用例规约

pdf文件已上传至本账号CSDN资源&#xff0c;也可以到以下地址下载&#xff1a;http://umlchina.com/training/umlchina_04_req.pdf
阅读更多...
MYSQL08_页的概述、内部结构、文件头、文件尾、最大最小记录、页目录、区段表

MYSQL08_页的概述、内部结构、文件头、文件尾、最大最小记录、页目录、区段表

文章目录 ①. 页的概述、大小②. 页的内部结构③. 第一部分 - 文件头④. 第一部分 - 文件尾⑤. 第二部分 - 空闲、用户记录、最大最小⑥. 第三部分 - 页目录⑦. 第三部分 - 页面头部⑧. 从数据页角度看B树⑨. 区、段和表、碎片区 ①. 页的概述、大小 ①. 数据库的存储结构&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023