Dubbo

Dubbo

  • 简介
  • Dubbo的快速入门
    • Dubbo的基本架构
    • 安装DubboAdmin
    • 入门案例
      • Dubbo的最佳实践
  • Dubbo的高级特性
    • 启动检查
    • 多版本
    • 超时与重试
    • 负载均衡
    • SpringCloud整合Dubbo
      • 案例

简介

Dubbo是阿里巴巴公司开源的一个高性能、轻量级的Java RPC框架。
致力于提高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案
官网
在这里插入图片描述


目前Dubbo在企业中有两种开发思路

  • 基于SOA思想
    • 将传统单一应用拆分为Web(消费者)模块和Service(提供者)模块,基于Dubbo通信
  • 辅助SpringCloud架构提升效率
    • Dubbo基于TCP(传输层)协议,效率更高。可以替换Feign,提升高并发压力

Dubbo的快速入门

Dubbo的基本架构

在这里插入图片描述

  • 服务提供者在启动时,向注册中心注册自己提供的服务
  • 消费者在启动时,向注册中心订阅自己所需的服务
  • 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者
  • 服务消费者,从提供者地址列表中,基于负载均衡算法,选择提供者进行调用。
  • 服务消费者和提供者,在内存中累积调用次数和调用时间,定时每分钟发送一次统计数据到监控中心

安装DubboAdmin

DubboAdmin是阿里巴巴管理提供的管理控制台,可以实现服务查询,详细展示,服务测试等功能。皆有DubboAdmin可以更好的帮助开发人员对服务进行管理和监控


DubboAdmin的源代码托管在GitHub上,可以通过命令拉取,修改配置并运行

# 下载代码git clone https://gitcode.net/mirrors/apache/dubbo-admin.git
# 在dubbo-admin-server/src/main/resources/application.properties中指定注册中心
# 构建mvn clean package -D maven.test.skip=true
#启动mvn --projects dubbo-admin-server spring-boot:run
或者cd dubbo-admin-distribution/target; java -jar dubbo-admin-0.1.jar
# 访问http://localhost:8080
# 默认用户名与密码为:root

入门案例

  • 创建数据库

    CREATE DATABASE `dubbo-demo` ;USE `dubbo-demo`;DROP TABLE IF EXISTS `tb_order`;CREATE TABLE `tb_order` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '订单id',`userId` bigint(20) NOT NULL COMMENT '用户id',`name` varchar(100) DEFAULT NULL COMMENT '商品名称',`price` bigint(20) NOT NULL COMMENT '商品价格',`num` int(10) DEFAULT '0' COMMENT '商品数量',PRIMARY KEY (`id`) USING BTREE,UNIQUE KEY `username` (`name`) USING BTREE
    ) ENGINE=InnoDB AUTO_INCREMENT=109 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT;insert  into `tb_order`(`id`,`userId`,`name`,`price`,`num`) values (101,1,'Apple 苹果 iPhone 12 ',699900,1),(102,2,'雅迪 yadea 新国标电动车',209900,1),(103,3,'骆驼(CAMEL)休闲运动鞋女',43900,1),(104,4,'小米10 双模5G 骁龙865',359900,1),(105,5,'OPPO Reno3 Pro 双模5G 视频双防抖',299900,1),(106,6,'美的(Midea) 新能效 冷静星II ',544900,1),(107,2,'西昊/SIHOO 人体工学电脑椅子',79900,1),(108,3,'梵班(FAMDBANN)休闲男鞋',31900,1);DROP TABLE IF EXISTS `tb_user`;CREATE TABLE `tb_user` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`username` varchar(100) DEFAULT NULL COMMENT '收件人',`address` varchar(255) DEFAULT NULL COMMENT '地址',PRIMARY KEY (`id`) USING BTREE,UNIQUE KEY `username` (`username`) USING BTREE
    ) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT;insert  into `tb_user`(`id`,`username`,`address`) values (1,'柳岩','湖南省衡阳市'),(2,'文二狗','陕西省西安市'),(3,'华沉鱼','湖北省十堰市'),(4,'张必沉','天津市'),(5,'郑爽爽','辽宁省沈阳市大东区'),(6,'范兵兵','山东省青岛市');
  • 导入工程


需求:使用Dubbo构建分布构架,完成根据用户id查询用户
在这里插入图片描述


搭建服务提供者user-provider

  • 创建提供者模块并引入依赖

    <dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><!--mybatis--><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId></dependency><!--dubbo的起步依赖--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-nacos</artifactId><version>2.7.8</version></dependency>
    </dependencies>
    
  • 编写引导类

    package com.xiaowu.user;import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;@MapperScan("com.xiaowu.user.mapper")
    @SpringBootApplication
    public class UserProviderApplication {public static void main( String[] args ) {SpringApplication.run(UserProviderApplication.class,args);}
    }
    
  • 将service,Mapper,domain导入到提供者模块中
    在这里插入图片描述

  • 将UserService暴露为Dubbo服务

    //暴露Dubbo服务
    @DubboService
    public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;public User queryById(Long id) {return userMapper.findById(id);}
    }
    
  • application.yml配置

    server:port: 18081
    spring:datasource:url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=falseusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Driverapplication:name: user-provider
    logging:level:com.xiaowu: debugpattern:dateformat: HH:mm:ss:SSS# 配置Dubbo提供者
    dubbo:protocol:name: dubbo   # 协议port: 20881   # dubbo端口registry:address: nacos://127.0.0.1:8848   #注册中心地址scan:base-packages: com.xiaowu.user.service  # dubbo注解的包扫描
    

搭建服务消费者user-consumer

  • 创建user-consumer模块导入依赖

    <dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--dubbo的起步依赖--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-nacos</artifactId><version>2.7.8</version></dependency>
    </dependencies>
    
  • 将Controller,service接口导入到消费者模块中
    在这里插入图片描述

  • 配置引导类

    package com.xiaowu.user;import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
    public class UserConsumerApplication {public static void main( String[] args ) {SpringApplication.run(UserConsumerApplication.class,args);}
    }
    
  • 在Controller中引入dubbo服务

    @Slf4j
    @RestController
    @RequestMapping("/user")
    public class UserController {@DubboReference  //引入dubbo服务private UserService userService;/*** 路径: /user/110* @param id 用户id* @return 用户*/@GetMapping("/{id}")public String queryById( @PathVariable("id") Long id) {return userService.queryById(id);}
    }
    
  • application.yml配置

    server:port: 18080
    spring:application:name: user-consumer# 配置dubbo服务消费者
    dubbo:registry:address: nacos://127.0.0.1:8848
    

Dubbo的最佳实践

将API接口抽取为独立模块,并且把接口有关的domain都放到这个模块中
在这里插入图片描述
在这里插入图片描述

然后引入这个模块的依赖
在这里插入图片描述

Dubbo的高级特性

启动检查

为了保障服务的正常可用,Dubbo缺省会启动时检查依赖的服务是否可用,不可用时会抛出异常
在这里插入图片描述

  • 在正式环境这是很有必要的一项配置,可以保证整个调用链路的平稳运行
  • 在开发时,往往会存在没有提供者的情况。由于启动检查的原因,可能导致开发测试出现问题
  • 可以通过check=false关闭
    在这里插入图片描述

多版本

在正式系统中,为了保证系统可用性和更好的并发性,往往通过集群部署
在这里插入图片描述
Dubbo提供了提供者多版本的支持,平滑处理项目功能升级部署
在这里插入图片描述


具体实现:

  • 编写新的UserServer实现类,作为新版本代码

    //暴露Dubbo服务
    @DubboService(version = "1.0")
    public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;public User queryById( Long id) {return userMapper.findById(id);}
    }
    
  • 在暴露服务时,指定服务版本

    //暴露Dubbo服务
    @DubboService(version = "1.0")
    
  • 消费者引用服务时,指定引用的服务版本

    public class UserController {@DubboReference(version = "1.0")  //引入dubbo服务private UserService userService;}
    

超时与重试

服务消费者在调用服务提供者的时候发生了阻塞、等待的情形,这个时候,服务消费者会一直等待下去。在某个峰值时刻,大量的请求都在同时请求服务消费者,会造成线程的大量堆积,势必会造成雪崩。

  • Dubbo:利用超时机制来解决这个问题(使用timeout属性配置超时时间,默认值1000,单位毫秒)
  • 若超时时间较短,当网络波动时请求就会失败,Dubbo通过重试机制避免此类问题的发生

设置重试机制的方法

  • 在消费者引用Dubbo服务时,加retries参数设置重试机制

    @Slf4j
    @RestController
    @RequestMapping("/user")
    public class UserController {@DubboReference(version = "1.0",retries = 0)  //引入dubbo服务private UserService userService;/*** 路径: /user/110* @param id 用户id* @return 用户*/@GetMapping("/{id}")public User queryById( @PathVariable("id") Long id) {return userService.queryById(id);}
    }
    
  • 在application.yml配置重试机制

    # 配置dubbo服务消费者
    dubbo:registry:address: nacos://127.0.0.1:8848consumer:check: falseretries: 0    # 重试机制(0次)
    

负载均衡

在集群部署时,Dubbo提供了4中负载均衡策略,帮助消费者找到最优提供者并调用

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

更改负载均衡策略,在消费者引用Dubbo时加入 loadbalance 参数

@DubboReference(version = "1.0",retries = 0,loadbalance = "Random")  //引入dubbo服务

SpringCloud整合Dubbo

  • Feign基于Http协议(应用层),在高并发场景下性能不够理想,容易成为性能瓶颈
  • Dubbo框架的通信协议采用TCP协议(数据传输层)
  • Dubbo框架的通信协议采用RPC协议,属于传输层协议
  • Dubbo默认通过Netty构造TCP长连接的方式进行通信,性能较高
  • 使用SpringCloud整合Dubbo,即为强强联合

案例

根据订单id查询订单功能
需求:根据订单id查询订单的同时,把订单所属的用户信息一起返回
在这里插入图片描述


模块分析

  • 使用Dubbo进行服务调用,一般将公共接口独立抽取为模块
  • 消费者引入依赖,引用Dubbo服务
  • 提供者引入依赖,编写接口实现类,暴露服务
    在这里插入图片描述

抽取接口模块

  • 创建dubbo-api模块,引入依赖

    <dependencies><dependency><groupId>com.xiaowu</groupId><artifactId>dubbo-domain</artifactId><version>1.0-SNAPSHOT</version></dependency>
    </dependencies>
    
  • 抽取公共接口
    在这里插入图片描述

改造提供者

  • 引入依赖

    <!--nacos注册中心的依赖-->
    <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <!--springcloud alibaba dubbo依赖   -->
    <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
    <!--dubbo-api-->
    <dependency><groupId>com.xiaowu</groupId><artifactId>dubbo-api</artifactId><version>1.0-SNAPSHOT</version>
    </dependency>
    
  • 编写实现类,暴露Dubbo服务

    @DubboService
    public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;public User queryById(Long id) {return userMapper.findById(id);}
    }
    
  • application.yml配置

    server:port: 8081
    spring:datasource:url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=falseusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Driverapplication:name: user-servicecloud:nacos:discovery:server-addr: localhost:8848
    #配置dubbo,注册中心,暴露的端口和协议,dubbo注解的包扫描
    dubbo:protocol:name: dubboport: 20881registry:address: spring-cloud://localhost   #使用SpringCloud中的注册中心scan:base-packages: com.xiaowu.user.service  #dubbo中包扫描
    logging:level:com.xiaowu: debugpattern:dateformat: HH-mm ss:SSS
    

改造服务消费者

  • 引入依赖

    <!--nacos注册中心的依赖-->
    <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <!--springcloud alibaba dubbo依赖   -->
    <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-dubbo</artifactId>
    </dependency>
    <!--dubbo-api-->
    <dependency><groupId>com.xiaowu</groupId><artifactId>dubbo-api</artifactId><version>1.0-SNAPSHOT</version>
    </dependency>
    
  • 使用@DubboReference引入Dubbo服务,远程调用服务

    @DubboReference
    private UserService userService;
    @Autowired
    private OrderMapper orderMapper;
    public Order queryOrderById(Long orderId) {// 1.根据id查询订单Order order = orderMapper.findById(orderId);// 2.获取订单中的用户IDLong userId = order.getUserId();// 3.根据用户id,调用Dubbo服务查询用户User user = userService.queryById(userId);order.setUser(user);// 4.返回return order;
    }
    
  • application.yml进行配置

    server:port: 8082
    spring:datasource:url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=falseusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Drivercloud:nacos:discovery:server-addr: localhost:8848application:name: order-service# dubbo消费者
    dubbo:registry:address: spring-cloud://localhostlogging:level:com.xiaowu: debugpattern:dateformat: HH:mm:ss:SSS
    

启动测试

  • 查询用户
    在这里插入图片描述
  • 查询订单
    在这里插入图片描述

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

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

相关文章

Jenkins+Docker+Docker-Compose自动部署,SpringCloud架构公共包一个任务配置

前言 Jenkins和docker的安装&#xff0c;随便百度吧&#xff0c;实际场景中我们很多微服务的架构&#xff0c;都是有公共包&#xff0c;肯定是希望一个任务能够把公共包的配置加进去&#xff0c;一并构建&#xff0c;ok&#xff0c;直接上干货。 Jenkins 全局环境安装 pwd e…

DSA之图(4):图的应用

文章目录 0 图的应用1 生成树1.1 无向图的生成树1.2 最小生成树1.2.1 构造最小生成树1.2.2 Prim算法构造最小生成树1.2.3 Kruskal算法构造最小生成树1.2.4 两种算法的比较 1.3 最短路径1.3.1 两点间最短路径1.3.2 某源点到其他各点最短路径1.3.3 Dijkstra1.3.4 Floyd 1.4 拓扑排…

机器学习:Bert and its family

Bert 先用无监督的语料去训练通用模型&#xff0c;然后再针对小任务进行专项训练学习。 ELMoBertERNIEGroverBert&PALS Outline Pre-train Model 首先介绍预训练模型&#xff0c;预训练模型的作用是将一些token表示成一个vector 比如&#xff1a; Word2vecGlove 但是对于…

微服务契约测试框架-Pact

契约测试 契约测试的思想就是将原本的 Consumer 与 Provider 间同步的集成测试&#xff0c;通过契约进行解耦&#xff0c;变成 Consumer 与 Provider 端两个各自独立的、异步的单元测试。 契约测试的优点&#xff1a; 契约测试与单元测试以及其它测试之间没有重复&#xff0c…

Google Earth Engine谷歌地球引擎提取多波段长期反射率数据后绘制折线图并导出为Excel

本文介绍在谷歌地球引擎GEE中&#xff0c;提取多年遥感影像多个不同波段的反射率数据&#xff0c;在GEE内绘制各波段的长时间序列走势曲线图&#xff0c;并将各波段的反射率数据与其对应的成像日期一起导出为.csv文件的方法。 本文是谷歌地球引擎&#xff08;Google Earth Engi…

图为科技T501赋能工业机器人 革新传统工业流程

工业机器人已成为一个国家制造技术与科技水平的重要衡量标准&#xff0c;在2019年&#xff0c;中国工业机器人的组装量与产量均位居了全球首位。 当前&#xff0c;工业机器人被广泛用于电子、物流、化工等多个领域之中&#xff0c;是一种通过电子科技和机械关节制作出来的智能机…

浏览器端代理proxy 解决跨域

一.环境:使用expresshttp-proxy-middleware 直接上代码 // include dependencies const express require( express);//node内置的path模块导入 const path require("path")const { createProxyMiddleware } require( http-proxy-middleware); // 需要代理后端服…

行为型设计模式之策略模式【设计模式系列】

系列文章目录 C技能系列 Linux通信架构系列 C高性能优化编程系列 深入理解软件架构设计系列 高级C并发线程编程 设计模式系列 期待你的关注哦&#xff01;&#xff01;&#xff01; 现在的一切都是为将来的梦想编织翅膀&#xff0c;让梦想在现实中展翅高飞。 Now everythi…

【万字长文】SpringBoot整合SpringSecurity+JWT+Redis完整教程(提供Gitee源码)

前言&#xff1a;最近在学习SpringSecurity的过程中&#xff0c;参考了很多网上的教程&#xff0c;同时也参考了一些目前主流的开源框架&#xff0c;于是结合自己的思路写了一个SpringBoot整合SpringSecurityJWTRedis完整的项目&#xff0c;从0到1写完感觉还是收获到不少的&…

K8s Service网络详解(二)

K8s Service网络详解&#xff08;二&#xff09; Kube Proxy调度模式Kube-proxy IptablesKube-proxy IPVS Service SelectorPod DNS种常见的 DNS 服务Kube-DNSCoreDNSCorefile 配置 DNS 记录DNS 记录 ServiceDNS 记录 PodDNS 配置策略 Pod 的主机名设置优先级 Ingress Kube Pro…

Appium+python自动化(二十五)-获取控件ID(超详解)

简介 在前边的第二十二篇文章里&#xff0c;已经分享了通过获取控件的坐标点来获取点击事件的所需要的点击位置&#xff0c;那么还有没有其他方法来获取控件点击事件所需要的点击位置呢&#xff1f;答案是&#xff1a;Yes&#xff01;因为在不同的大小屏幕的手机上获取控件的坐…

ModStartCMS v6.9.0 后台多标签改进,主题色自动切换修复

ModStart 是一个基于 Laravel 模块化极速开发框架。模块市场拥有丰富的功能应用&#xff0c;支持后台一键快速安装&#xff0c;让开发者能快的实现业务功能开发。 系统完全开源&#xff0c;基于 Apache 2.0 开源协议&#xff0c;免费且不限制商业使用。 功能特性 丰富的模块市…

Redis学习2--使用java操作Redis

1、java操作Redis库的比较 Redis有各种语言的客户端可以来操作redis数据库&#xff0c;其中java语言主要有Jedis与lettuce &#xff0c;Spring Data Redis封装了上边两个客户端&#xff0c;优缺点如下&#xff1a; 2、使用Jedis操作Redis Jedis使用的基本步骤&#xff1a; 引…

企业服务器数据库被360后缀勒索病毒攻击后采取的措施

近期&#xff0c;360后缀勒索病毒的攻击事件频发&#xff0c;造成很多企业的服务器数据库遭受严重损失。360后缀勒索病毒是Beijingcrypt勒索家族中的一种病毒&#xff0c;该病毒的加密形式较为复杂&#xff0c;目前网络上没有解密工具&#xff0c;只有通过专业的技术人员对其进…

原生html—摆脱ps、excel 在线绘制财务表格加水印(html绘制表格js加水印)

文章目录 ⭐前言⭐html标签&#x1f496;table表格的属性&#x1f496;实现财务报表 ⭐结束 ⭐前言 大家好&#xff0c;我是yma16&#xff0c;本文分享原生html——绘制表格报表加水印。 背景&#xff1a;解决没有ps的情况下使用前端html制作表格报表。 html介绍 HTML&#xf…

【Android知识笔记】UI体系(一)

Activity的显示原理 setContentView 首先开发者Activity的onCreate方法中通常调用的setContentView会委托给Window的setContentView方法: 接下来看Window的创建过程: 可见Window的实现类是PhoneWindow,而PhoneWindow是在Activity创建过程中执行attach Context的时候创建的…

Kotlin多平台最佳架构指南

在这篇文章中&#xff0c;我们将对 Kotlin 多平台移动端的最佳架构进行深入探讨。在2023年&#xff0c;作为 Android 开发者&#xff0c;我们会倾向于采用 MVVM 架构&#xff0c;因为它简单、灵活且易于测试。而作为 iOS 开发者&#xff0c;我们可能会选择 MVC、Viper 等架构。…

QT基于TCP协议实现数据传输以及波形绘制

这个玩意我做了两个&#xff0c;一个是安卓app&#xff0c;一个是Windows程序。代码并非全部都是由我从无到有实现&#xff0c;只是实现了我想要的功能。多亏了巨人的肩膀&#xff0c;开源万岁&#xff01;&#xff01;&#xff01; 我把程序放到GitHub上&#xff0c;需要的可…

Vue项目如何生成树形目录结构

文章底部有个人公众号&#xff1a;热爱技术的小郑。主要分享开发知识、有兴趣的可以关注一手。 前言 项目的目录结构清晰、可以帮助我们更快理顺项目的整体构成。在写文档之类的时候也比较方便。生成树形目录的方式有多种&#xff0c;我这里简单介绍其中一种较为简单的实现 过…

学习数学助手Schooltech Math Resource Studio 7.0 Crack

数学资源工作室 数学工作表生成器&#xff1a;快速轻松地创建数学工作表 使用易于使用的数学工作表生成器软件创建可打印的数学练习工作表。通过练习、谜题、问题等提高数学技能。 瞄准学习需求并激励学生 Math Resource Studio 是个性化数学教学的理想软件解决方案&#xff0c…