深入理解Dubbo-1.初识Dubbo

  • 👏作者简介：大家好，我是爱吃芝士的土豆倪，24届校招生Java选手，很高兴认识大家
  • 📕系列专栏：Spring源码、JUC源码、Kafka原理、分布式技术原理
  • 🔥如果感觉博主的文章还不错的话，请👍三连支持👍一下博主哦
  • 🍂博主正在努力完成2023计划中：源码溯源，一探究竟
  • 📝联系方式：nhs19990716，加我进群，大家一起学习，一起进步，一起对抗互联网寒冬👀

文章目录

  • Dubbo
    • 为什么用Dubbo
    • Dubbo架构
    • Dubbo的使用
      • 服务端
      • 消费端
  • Dubbo Spring Cloud
    • 定义服务接口
    • 实现服务
    • 配置dubbo服务发布
    • 构建服务消费者
  • Dubbo Spring Boot
    • 创建项目结构
    • 添加jar包依赖
    • 添加服务以及发布
    • 编写服务引用代码

Dubbo

为什么用Dubbo

它是一个RPC框架，提供了对远程通信的支持。其本身是一个服务治理框架，能够提供服务的监控（如果我们的服务大规模集群后，我们需要一些服务来监控服务的调用链路，监控每个服务的吞吐量，这样就能够及时做到服务性能提升和响应）、服务注册发现（在服务与服务通信之间，去管理服务的一个组件）、服务的通信、服务容错（通信过程中怎么实现容错）、服务的负载均衡。

类似于京东的 jsf框架。

那为什么每个公司要开发自己的框架呢？是因为即便是开源的技术也好，它能够满足大部分的业务场景，但是对于每个公司来说可能存在一些定制化的需求，或者说做一些开源的支持，所以会有一些架构组去专门开发这样的组件，提供给我们这样使用。

Dubbo 最早是阿里内部分布式服务治理的框架，后面对外开源，然后后面的很多公司都沿着阿里的生态线去发展，在2014年dubbo就停止维护了，在2017年阿里重启了维护，在18年集成到了springcloud团队，集成是为了大家使用springcloud这套标准去提供服务治理这套完整的解决方案，让大家在使用这项技术的时候，成本更低，使用起来更加容易。

所以SpringCloud Alibaba 说的是基于阿里开源的技术，按照springcloud这套标准去进行集成，然后提供的一系列解决方法，包括 nacos、sentinel、rocketmq、dubbo等。

Dubbo架构

在这里插入图片描述

其提供了客户端和服务端在分布式情况下的通信，服务启动的时候，把服务地址注册到注册中心上，消费者监听注册中心上的地址的变化，发起调用，每次调用，会有监视的模块，去监控每次调用请求的耗时等等关系。

Dubbo的使用

服务端

dubbo-server-sample

----dubbo-server

public class LoginServiceImpl implements ILoginService{

    @Override
    public String login(String username, String password) {
        //写业务逻辑
        if(username.equals("admin")&&password.equals("admin")){
            return "SUCCESS";
        }
        return "FAILED";
    }
}

----dubbo-server-api

public interface ILoginService {

    String login(String username,String password);
}

如果想让另一个进行也能访问到 login 方法，那么首先需要将 dubbo-server 上的服务发布出去。

		<dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.8</version>
        </dependency>

配置 application.xml

<dubbo:application name="dubbo-server"/> <!-- 声明服务对外的名字-->

<dubbo:protocol name="dubbo" port="20880"/>  <!-- 表示当前要以什么协议发布出去 -->

<dubbo:registry address="N/A"/>  <!-- 配置注册中心 当前配置为不需要注册到 注册中心-->

<dubbo:service interface="com.gupaoedu.dubbo.server.ILoginService" ref="loginService"/>

<bean id="loginService" class="com.gupaoedu.dubbo.server.LoginServiceImpl"/>
<!-- dubbo的发布,表示要将那个服务发布出去-->

启动

import org.apache.dubbo.container.Main;


public class App {
    public static void main( String[] args ){
        Main.main(args);
    }
}

发布服务之后，会提供一个url地址

dubbo://192.168.1.104:20880/com.gupaoedu.dubbo.server.ILoginService

消费端

dubbo-client-sample

 <dubbo:application name="dubbo-server"/>
    <!--不需要注册到服务注册中心-->
    <dubbo:registry address="N/A"/>

    <dubbo:reference id="loginService"
                     interface="com.gupaoedu.dubbo.server.ILoginService"
                     url="dubbo://192.168.1.104:20880/com.gupaoedu.dubbo.server.ILoginService"/>

// 引入dubbo-server-api

public static void main( String[] args )
    {
        ILoginService loginService=null;
        ApplicationContext context=new
                ClassPathXmlApplicationContext
                ("classpath:META-INF/spring/application.xml");
        loginService=context.getBean(ILoginService.class);
        System.out.println(loginService.login("admin","admin"));
    }

此时就能够完成一次通信了。

虽然上述案例跑通了，但是可以看到，必须在 dubbo:reference 里配置 了 url才能完成通信，实际上根据前面说的Dubbo的架构图来看，其生产者 和 消费者都是通过注册中心通信的。

<dubbo:registry address="zookeeper://192.168.216.128:1281" timeout="10000"/>

<dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.8</version>
        </dependency>

当生产者消费者都配置了注册中心的时候，此时消费者的dubbo:reference 就不需要配置url了，就能够完成通信了。

Dubbo Spring Cloud

创建一个项目

创建一个spring-cloud-dubbo-example的maven工程

分别添加三个模块

  • spring-cloud-dubbo-sample-api
  • spring-cloud-dubbo-sample-provider
  • spring-cloud-dubbo-sample-consumer

其中后面两个模块都是spring boot的应用。

修改 spring-cloud-dubbo-sample-provider 这个模块中。

  • 将dependencyManagement部分的依赖移动到parent pom.xml
  • 修改spring-cloud-dubbo-sample-provider中的pom.xml,增加parent模块的依赖
<parent>
	<groupId>com.gupaoedu.dubbo</groupId>
	<artifactId>spring-cloud-dubbo-example</artifactId>
	<version>1.0-SNAPSHOT</version>
</parent>
  • 添加maven依赖
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
	<groupId>com.gupaoedu.dubbo</groupId>
	<version>1.0-SNAPSHOT</version>
	<artifactId>spring-cloud-dubbo-sample-api</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

定义服务接口

在spring-boot-dubbo-sample-api模块中，定义接口

public interface IHelloService {
	String sayHello();
}

实现服务

在spring-boot-dubbo-sample-provider中，实现IHelloService接口

public class HelloServiceImpl implements IHelloService{
	@Override
	public String sayHello() {
		return "Hello GuPao";
	}
}

添加 @EnableDiscoveryClient 注解

@EnableDiscoveryClient
@SpringBootApplication
public class SpringCloudDubboSampleProviderApplication {
	public static void main(String[] args) {
		SpringApplication.run(SpringCloudDubboSampleProviderApplication.class,args);
	}
}

配置dubbo服务发布

  • 在服务实现类中添加 @Service 注解
@Service
public class HelloServiceImpl implements IHelloService{
	@Override
	public String sayHello() {
		return "Hello GuPao";
	}
}
  • 配置dubbo提供方信息
# dubbo 服务扫描基础包路径
dubbo.scan.base-packages=com.gupaoedu.dubbo.springclouddubbosampleprovider

dubbo.protocol.id=dubbo
# Dubbo 服务暴露的协议配置，其中子属性 name 为协议名称，port 为协议端口（ -1 表示自增端
口，从 20880 开始）
dubbo.protocol.name=dubbo 
# 使用的是dubbo协议
dubbo.protocol.port=-1

spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848

dubbo.scan.base-packages : 指定 Dubbo 服务实现类的扫描基准包

dubbo.protocol : Dubbo 服务暴露的协议配置，其中子属性 name 为协议名称， port 为协议端口（ -1 表示自增端口，从 20880 开始）

spring.cloud.nacos.discovery : Nacos 服务发现与注册配置，其中子属性 server-addr指定 Nacos 服务器主机和端口

构建服务消费者

  • 添加jar包依赖
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-actuator</artifactId>
</dependency>
<dependency>
	<groupId>com.gupaoedu.dubbo</groupId>
	<version>1.0-SNAPSHOT</version>
	<artifactId>spring-cloud-dubbo-sample-api</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-web</artifactId>
</dependency>
  • 添加配置文件
spring.application.name=spring-cloud-dubbo-sample-consumer
dubbo.application.name=spring-cloud-dubbo-sample-consumer

dubbo.cloud.subscribed-services=spring-cloud-dubbo-sample-provider
spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848

除应用名称 spring.application.name 存在差异外， spring-cloud-dubbo-client-sample 新增了属性 dubbo.cloud.subscribed-services 的设置。并且该值为服务提供方应用 “springcloud-dubbo-sample-provider”。它的主要作用是服务消费方订阅服务提供方的应用名称的列表，若需订阅多应用，使用 “,” 分割。
不推荐使用默认值为 “*”，它将订阅所有应用。

  • 编写测试代码
@RestController
@EnableDiscoveryClient
@SpringBootApplication
public class SpringCloudDubboSampleConsumerApplication {
	public static void main(String[] args) {
		SpringApplication.run(SpringCloudDubboSampleConsumerApplication.class,args);
	}
	
	@Reference
	IHelloService helloService;
	
	@GetMapping("/say")
	public String say(){
		return helloService.sayHello();
	}
}

Dubbo Spring Boot

基于spring boot集成Dubbo方式

dubbo集成到spring boot中有一个好处，就是它可以继承spring boot本身的特性

  • 自动装配（注解驱动、自动装配）
  • production-ready（安全机制、健康检测、外部化配置）

创建项目结构

创建基础的项目结构

spring-boot-dubbo-example [maven]

  • spring-boot-dubbo-sample-api [maven]
  • spring-boot-dubbo-sample-provider [spring boot]
  • spring-boot-dubbo-sample-consumerp [spring-boot]

添加jar包依赖

从2.7开始，dubbo的版本和dubbo-spring-boot的版本是保持一致的，所以大家不用再去担心版本的问题。

<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-spring-boot-starter</artifactId>
	<version>2.7.7</version>
</dependency>
<dependency>
	<groupId>com.alibaba.nacos</groupId>
	<artifactId>nacos-client</artifactId>
	<version>1.2.1</version>
</dependency>

添加服务以及发布

@DubboService
public class SayHelloServiceImpl implements ISayHelloService{
	@Override
	public String sayHello() {
		return "Hello GuPaoEdu.com";
	}
}

spring.application.name=spring-boot-dubbo-sample-provider

dubbo.registry.address=nacos://192.168.216.128:8848
dubbo.scan.basepackages=com.gupaoedu.springboot.dubbo.springbootdubbosampleprovider.service

dubbo.protocol.name=dubbo
dubbo.protocol.port=-1

编写服务引用代码

添加jar包依赖

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
	<groupId>com.gupaoedu.com</groupId>
	<version>1.0-SNAPSHOT</version>
	<artifactId>spring-boot-dubbo-sample-api</artifactId>
</dependency>
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-spring-boot-starter</artifactId>
	<version>2.7.7</version>
</dependency>
<dependency>
	<groupId>com.alibaba.nacos</groupId>
	<artifactId>nacos-client</artifactId>
	<version>1.2.1</version>
</dependency>

添加web测试类

@DubboReference
ISayHelloService sayHelloService;

@GetMapping("/get")
public String get(){
	return sayHelloService.sayHello();
}

dubbo.registry.address=nacos://192.168.216.128:8848

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

12.7作业

12.7作业

1. #include "mywidget.h"MyWidget::MyWidget(QWidget *parent): QWidget(parent) {//***********窗口相关设置***********//设置窗体大小this->resize(540,410);this->setFixedSize(540,410);//取消菜单栏this->setWindowFlag(Qt::FramelessWindowHint);/…
阅读更多...
【数据库】基于时间戳的并发访问控制，乐观模式，时间戳替代形式及存在的问题，与封锁模式的对比

【数据库】基于时间戳的并发访问控制，乐观模式，时间戳替代形式及存在的问题，与封锁模式的对比

使用时间戳的并发控制 ​专栏内容&#xff1a; 手写数据库toadb 本专栏主要介绍如何从零开发&#xff0c;开发的步骤&#xff0c;以及开发过程中的涉及的原理&#xff0c;遇到的问题等&#xff0c;让大家能跟上并且可以一起开发&#xff0c;让每个需要的人成为参与者。 本专栏会…
阅读更多...
MySQL之binlog文件过多处理方法

MySQL之binlog文件过多处理方法

背景 MySQL由于大量读写&#xff0c;导致binlog文件特别的多。从而导致服务器disk空间不足问题。 先备份binlog文件 tar -zcvf mysql.tar.gz mysql/data/mysql-bin.00* 修改MySQL配置 binlog过期时间 show variables like expire_logs_days; 这里 0 表示 永不过期 如果为 n…
阅读更多...
LeedCode刷题---双指针问题(二)

LeedCode刷题---双指针问题(二)

顾得泉&#xff1a;个人主页 个人专栏&#xff1a;《Linux操作系统》 《C/C》 《LeedCode刷题》 键盘敲烂&#xff0c;年薪百万&#xff01; 一、盛水最多的容器 题目链接&#xff1a;盛最多水的容器 题目描述 给定一个长度为 n 的整数数组 height 。有 n 条垂线&#xf…
阅读更多...
Nacos下载、启动与使用的保姆级教程！

Nacos下载、启动与使用的保姆级教程！

nacos下载及启动 nacos下载 首先打开nacos官方仓库链接。Nacos发布版本仓库。 点击Tags按钮找到nacos的历史发布的所有版本&#xff0c;点击download。 然后选择需要的下载即可。 后缀为.tar.gz为linux系统上运行的压缩包 后缀为.zip为windows系统上运行的压缩包 zip格式的…
阅读更多...
vivado时序方法检查5

vivado时序方法检查5

TIMING-14 &#xff1a; 时钟树上的 LUT 在时钟树上发现 LUT <cell_name> 。不建议在时钟路径上包含 LUT 单元。 描述 时钟路径上的 LUT 可能导致偏差过大 &#xff0c; 因为时钟必须在穿过互连结构的常规布线资源上进行布线。除偏差过大外 &#xff0c; 这些路径更…
阅读更多...
[论文阅读]BEVFusion

[论文阅读]BEVFusion

BEVFusion BEVFusion: A Simple and Robust LiDAR-Camera Fusion Framework BEVFusion&#xff1a;简单而强大的激光雷达相机融合框架 论文网址&#xff1a;BEVFusion 论文代码&#xff1a;BEVFusion 简读论文 论文背景&#xff1a;激光雷达和摄像头是自动驾驶系统中常用的两…
阅读更多...
SRC挖掘漏洞XSS

SRC挖掘漏洞XSS

Markdown是一种轻量级标记语言&#xff0c;创始人为约翰格鲁伯&#xff08;John Gruber&#xff09;。它允许人们使用易读易写的纯文本格式编写文档&#xff0c;然后转换成有效的 XHTML&#xff08;或者HTML&#xff09;文档。这种语言吸收了很多在电子邮件中已有的纯文本标记的…
阅读更多...
App自动化测试持续集成效率提高50%

App自动化测试持续集成效率提高50%

持续集成是一种开发实践&#xff0c;它倡导团队成员需要频繁的集成他们的工作&#xff0c;每次集成都通过自动化构建&#xff08;包括编译、构建、自动化测试&#xff09;来验证&#xff0c;从而尽快地发现集成中的错误。让正在开发的软件始终处于可工作状态&#xff0c;让产品…
阅读更多...
C++STL的string类(一)

C++STL的string类(一)

文章目录 前言C语言的字符串 stringstring类的常用接口string类的常见构造string (const string& str);string (const string& str, size_t pos, size_t len npos); capacitysize和lengthreserveresizeresize可以删除数据 modify尾插插入字符插入字符串 inserterasere…
阅读更多...
模电笔记。。。。

模电笔记。。。。

模电 2.8 蜂鸣器 按照蜂鸣器驱动方式分为有源蜂鸣器和无源蜂鸣器 有源的有自己的震荡电路&#xff0c;无源的要写代码控制。 里面有个线圈&#xff0c;相当于电感&#xff0c;储能&#xff0c;通直隔交。 蜂鸣器的参数&#xff1a;额定电压&#xff0c;工作电压&#xff0…
阅读更多...
深入理解mysql的explain命令

深入理解mysql的explain命令

1 基础 全网最全 | MySQL EXPLAIN 完全解读 1.1 MySQL中EXPLAIN命令提供的字段包括&#xff1a; id&#xff1a;查询的标识符。select_type&#xff1a;查询的类型&#xff08;如SIMPLE, PRIMARY, SUBQUERY等&#xff09;。table&#xff1a;查询的是哪个表。partitions&…
阅读更多...
【算法每日一练]-结构优化（保姆级教程 篇4 树状数组，线段树，分块模板篇）

【算法每日一练]-结构优化（保姆级教程 篇4 树状数组，线段树，分块模板篇）

除了基础的前缀和&#xff0c;后面还有树状数组&#xff0c;线段树&#xff0c;分块的结构优化。 目录 分块 分块算法步骤&#xff1a; 树状数组 树状数组步骤&#xff1a; 线段树点更新 点更新步骤&#xff1a; 线段树区间更新 区间更新步骤&#xff1a; 分块 分块算…
阅读更多...
【wvp】测试记录

【wvp】测试记录

ffmpeg 这是个莫名其妙的报错&#xff0c;通过排查&#xff0c;应该是zlm哪个进程引起的 会议室的性能 网络IO也就20M
阅读更多...
业绩超预期,股价却暴跌,MongoDB股票还值得投资吗?

业绩超预期,股价却暴跌,MongoDB股票还值得投资吗?

来源&#xff1a;猛兽财经 作者&#xff1a;猛兽财经 尽管MongoDB(MDB)本季度的财报超出了预期&#xff0c;并提高了全年预期&#xff0c;但它的股价在财报发布后还是出现了暴跌。 MongoDB截至2023年10月31日的第三财季&#xff0c;收入同比增长了30%&#xff0c;达到了4.329亿…
阅读更多...
各大电商平台商品详情API调用(API接口)、淘宝API、京东API、拼多多API、1688API文档案例演示

各大电商平台商品详情API调用(API接口)、淘宝API、京东API、拼多多API、1688API文档案例演示

电商API接口的作用主要表现在以下几个方面&#xff1a; 数据支持&#xff1a;通过开放API接口&#xff0c;其他软件、应用、网站等可以访问电商平台的数据库和功能&#xff0c;利用这些数据提供更丰富的功能和更好的服务。例如&#xff0c;API接口可以收集用户的购物记录、搜索…
阅读更多...
第二十一章总结。。

第二十一章总结。。

计算机网络实现了堕胎计算机间的互联&#xff0c;使得它们彼此之间能够进行数据交流。网络应用程序就是再已连接的不同计算机上运行的程序&#xff0c;这些程序借助于网络协议&#xff0c;相互之间可以交换数据&#xff0c;编写网络应用程序前&#xff0c;首先必须明确网络协议…
阅读更多...
状态机的练习：按键控制led灯

状态机的练习：按键控制led灯

设计思路&#xff1a; 三个按键控制led输出。 三个按键经过滤波(消抖)&#xff0c;产生三个按键标志信号。 三个led数据的产生模块&#xff08;流水&#xff0c;跑马&#xff0c;闪烁模块&#xff09;&#xff0c;分别产生led信号。 这六路信号&#xff08;三路按键信号&am…
阅读更多...
4种常见的限流算法

4种常见的限流算法

限流算法 1、固定窗口 含义&#xff1a; 在一个固定长度的时间窗口内限制请求数量&#xff0c;每来一个请求&#xff0c;请求次数加一&#xff0c;如果请求数量超过最大限制&#xff0c;就拒绝该请求 优点&#xff1a; 实现简单&#xff0c;容易理解。 缺点&#xff1a; ①限流…
阅读更多...
Ngxin实现301重定向映射

Ngxin实现301重定向映射

要实现将abc.love域名映射到http://baidu.com网站&#xff0c;并进行重定向&#xff0c;你需要在Nginx的配置文件中添加一个新的server块&#xff0c;如下所示&#xff1a; server {listen 80;server_name abc.com; #替换成自己的域名&#xff0c;记得要映射到这台服务器&…
阅读更多...
最新文章

Copyright @ 2022~2023