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

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 【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;
}
相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
XML Dubbo 架构师
由浅入深Dubbo核心源码剖析高阶配置运用1
由浅入深Dubbo核心源码剖析高阶配置运用
92 0
|
7月前
|
XML 监控 Dubbo
Dubbo怎么配置监控中心
**摘要:** 本文介绍了如何配置Dubbo的简单监控中心。首先,通过添加`&lt;dubbo:monitor protocol=&quot;registry&quot; /&gt;`到配置文件启用监控。接着,修改`dubbo.properties`设置Zookeeper地址。启动监控中心,服务提供者和消费者需添加`monitorEnabled=&quot;true&quot;`以开启监控功能。配置完成后,监控中心的Web界面能展示服务状态和性能指标,助力开发者和运维人员实时监控服务健康。
115 0
|
8月前
|
Dubbo Cloud Native 应用服务中间件
【Dubbo3 终极特性】「云原生三中心架构」带你探索 Dubbo3 体系下的配置中心和元数据中心、注册中心的原理及开发实战(中)
【Dubbo3 终极特性】「云原生三中心架构」带你探索 Dubbo3 体系下的配置中心和元数据中心、注册中心的原理及开发实战(中)
271 1
|
负载均衡 Dubbo 算法
由浅入深Dubbo核心源码剖析高阶配置运用2
由浅入深Dubbo核心源码剖析高阶配置运用2
85 0
|
8月前
|
监控 负载均衡 Dubbo
Dubbo快速入门
Dubbo快速入门
|
8月前
|
Docker 容器
在docker中安装dubbo-admin,并且阿里云服务器配置
在docker中安装dubbo-admin,并且阿里云服务器配置
309 1
|
8月前
|
XML 负载均衡 Dubbo
了解Dubbo配置:优先级、重试和容错机制的秘密【五】
了解Dubbo配置:优先级、重试和容错机制的秘密【五】
396 0
|
8月前
|
Dubbo Java 应用服务中间件
Spring Boot + Dubbo + Zookpeer分布式案例
Spring Boot + Dubbo + Zookpeer分布式案例
55 0
|
8月前
|
Dubbo Java 应用服务中间件
微服务框架(三)Dubbo性能调优配置
  此系列文章将会描述Java框架Spring Boot、服务治理框架Dubbo、应用容器引擎Docker,及使用Spring Boot集成Dubbo、Mybatis等开源框架,其中穿插着Spring Boot中日志切面等技术的实现,然后通过gitlab-CI以持续集成为Docker镜像。   本文为服务治理框架Dubbo的特性及泛化实现
|
8月前
|
Dubbo Java 应用服务中间件
从源码全面解析 dubbo 注解配置的来龙去脉
从源码全面解析 dubbo 注解配置的来龙去脉