【Dubbo】快速入门案例以及配置详情

本文涉及的产品
RDS MySQL DuckDB 分析主实例,基础系列 4核8GB
RDS MySQL DuckDB 分析主实例,集群系列 4核8GB
RDS AI 助手,专业版
简介: 【Dubbo】快速入门案例以及配置详情

1、Dubbo的前世今生


2011年10月27日,阿里巴巴开源了自己的SOA服务化治理方案的核心框架Dubbo,服务治理和SOA的设计理念开始逐渐在国内软件行业中落地,并被广泛应用。

  • 早期版本的dubbo遵循SOA的思想,是面向服务架构的重要组件。
  • 如今版本的Dubbo作为Spring Cloud的二进制通信方案来发挥Dubbo的性能优势

2、Dubbo的快速入门


2.1、Dubbo的基本架构


image.png

节点角色说明:

节点 角色说明
Provider 暴露服务的服务提供方。
Consumer 调用远程服务的服务消费方。
Registry 服务注册与发现的注册中心。
Monitor 统计服务的调用次数和调用时间的监控中心。

调用关系说明:

服务容器负责启动,加载,运行服务提供者。


服务提供者在启动时,向注册中心注册自己提供的服务。


服务消费者在启动时,向注册中心订阅自己所需的服务。


注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。


服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。


服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。

2.2、Nacos


Nacos是阿里巴巴的产品,是一个集服务发现,配置管理的平台,在国内受欢迎程度较高。

image.png

image.png

2、解压到没有中文和特殊字符的目录

3、进入bin目录,执行启动命令

#进入bin目录

cd bin

#启动

startup.cmd -m standalone


4、浏览器查看:http://127.0.0.1:8848/nacos

2.3、管理后台


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

#1、下载代码:

git clone https://github.com/apache/dubbo-admin.git

#2、在 dubbo-admin-server/src/main/resources/application.properties中指定注册中心地址

#3、构建

mvn clean package -D maven.test.skip=true

#4、启动

mvn --projects dubbo-admin-server spring-boot:run

#或者

cd dubbo-admin-distribution/target; java -jar dubbo-admin-0.1.jar

#5、访问 http://localhost:8080

2.4、入门案例


需求:使用Dubbo构建分布式架构,完成根据用户id查询用户

image.png

2.4.1、服务提供者


搭建环境

(1)创建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>(2)编写引导类packagecn.itcast.user;
importorg.mybatis.spring.annotation.MapperScan;
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
@MapperScan("cn.itcast.user.mapper")
@SpringBootApplicationpublicclassUserProviderApplication {
publicstaticvoidmain(String[] args) {
SpringApplication.run(UserProviderApplication.class, args);
    }
}

代码实现

(1)UserServiceImpl

packagecn.itcast.user.service;
importcn.itcast.user.api.UserService;
importcn.itcast.user.domain.User;
importcn.itcast.user.mapper.UserMapper;
importorg.apache.dubbo.config.annotation.DubboService;
importorg.springframework.beans.factory.annotation.Autowired;
@DubboServicepublicclassUserServiceImplimplementsUserService {
@AutowiredprivateUserMapperuserMapper;
//根据id查询用户名称publicStringqueryUsername(Longid) {
returnuserMapper.findById(id).getUsername();
    }
}

配置文件

server:
port: 18081spring:
datasource:
url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=falseusername: rootpassword: rootdriver-class-name: com.mysql.jdbc.Driverapplication:
name: user-providerlogging:
level:
cn.itcast: debugpattern:
dateformat: HH:mm:ss:SSSdubbo:
protocol:
name: dubboport: 20881registry:
address: nacos://127.0.0.1:8848scan:
base-packages: cn.itcast.user.service

2.4.2、服务消费者


搭建环境

(1)创建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>

(2)配置引导类

packagecn.itcast.user;
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplicationpublicclassUserConsumerApplication {
publicstaticvoidmain(String[] args) {
SpringApplication.run(UserConsumerApplication.class, args);
    }
}

代码实现

packagecn.itcast.user.controller;
importcn.itcast.user.api.UserService;
importcn.itcast.user.domain.User;
importlombok.extern.slf4j.Slf4j;
importorg.apache.dubbo.config.annotation.DubboReference;
importorg.springframework.web.bind.annotation.GetMapping;
importorg.springframework.web.bind.annotation.PathVariable;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;
@Slf4j@RestController@RequestMapping("/user")
publicclassUserController {
//引用远程服务@DubboReferenceprivateUserServiceuserService;
@GetMapping("/username/1")
publicStringfindUserName(@PathVariable("id") Longid) {
returnuserService.queryUsername(id);
    }
}

配置文件

server:
port: 18080spring:
application:
name: user-consumerlogging:
level:
cn.itcast: debugpattern:
dateformat: HH:mm:ss:SSSdubbo:
registry:
address: nacos://127.0.0.1:8848

2.5、代码优化


将接口抽取为独立模块,并且把接口有关的domain都放到这个模块中

(1)创建user-api模块引入依赖

(2)将UserService接口和User对象导入user-api模块下

(3)User对象实现序列化接口

packagecn.itcast.user.domain;
importlombok.Data;
importjava.io.Serializable;
@DatapublicclassUserimplementsSerializable {
privateLongid;
privateStringusername;
privateStringaddress;
}
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
相关文章
|
XML Dubbo 架构师
由浅入深Dubbo核心源码剖析高阶配置运用1
由浅入深Dubbo核心源码剖析高阶配置运用
199 0
|
负载均衡 Dubbo 算法
由浅入深Dubbo核心源码剖析高阶配置运用2
由浅入深Dubbo核心源码剖析高阶配置运用2
184 0
|
XML 监控 Dubbo
Dubbo怎么配置监控中心
**摘要:** 本文介绍了如何配置Dubbo的简单监控中心。首先,通过添加`&lt;dubbo:monitor protocol=&quot;registry&quot; /&gt;`到配置文件启用监控。接着,修改`dubbo.properties`设置Zookeeper地址。启动监控中心,服务提供者和消费者需添加`monitorEnabled=&quot;true&quot;`以开启监控功能。配置完成后,监控中心的Web界面能展示服务状态和性能指标,助力开发者和运维人员实时监控服务健康。
384 0
|
Dubbo Cloud Native 应用服务中间件
【Dubbo3 终极特性】「云原生三中心架构」带你探索 Dubbo3 体系下的配置中心和元数据中心、注册中心的原理及开发实战(中)
【Dubbo3 终极特性】「云原生三中心架构」带你探索 Dubbo3 体系下的配置中心和元数据中心、注册中心的原理及开发实战(中)
775 1
|
Docker 容器
在docker中安装dubbo-admin,并且阿里云服务器配置
在docker中安装dubbo-admin,并且阿里云服务器配置
559 1
|
监控 负载均衡 Dubbo
Dubbo快速入门
Dubbo快速入门
172 0
|
Dubbo Java 应用服务中间件
微服务框架(三)Dubbo性能调优配置
  此系列文章将会描述Java框架Spring Boot、服务治理框架Dubbo、应用容器引擎Docker,及使用Spring Boot集成Dubbo、Mybatis等开源框架,其中穿插着Spring Boot中日志切面等技术的实现,然后通过gitlab-CI以持续集成为Docker镜像。   本文为服务治理框架Dubbo的特性及泛化实现
|
缓存 Dubbo Java
Dubbo配置注册中心设置application的name使用驼峰命名法可能存在的隐藏启动异常问题
Dubbo配置注册中心设置application的name使用驼峰命名法可能存在的隐藏启动异常问题
264 1
|
XML 负载均衡 Dubbo
了解Dubbo配置:优先级、重试和容错机制的秘密【五】
了解Dubbo配置:优先级、重试和容错机制的秘密【五】
912 0
|
Dubbo Java 应用服务中间件
Spring Boot + Dubbo + Zookpeer分布式案例
Spring Boot + Dubbo + Zookpeer分布式案例
136 0

热门文章

最新文章