文章目录
提示:以下是本篇文章正文内容,Java 系列学习将会持续更新
官方文档:https://cn.dubbo.apache.org/zh-cn/#td-block-1
一、Dubbo 架构图
- Dubbo 是阿里巴巴公司开源的一个高性能、轻量级的 Java RPC 框架。
- 致力于提供高性能和透明化的 RPC 远程服务调用方案,以及 SOA 服务治理方案。
- 三个核心功能:
基于接口的远程调用
、容错和负载均衡
、服务的自动注册与发现
。Dubbo 框架广泛的在阿里巴巴内部使用,以及京东、当当、去哪儿、考拉等都在使用。
节点角色说明:
- Provider:暴露服务的服务提供方。
- Consumer:调用远程服务的服务消费方。
- Registry:服务注册与发现的注册中心。
- Monitor:统计服务的调用次调和调用时间的监控中心。
- Container:服务运行容器。
核心流程
- 首先服务提供方,将自己的服务放在一个容器中,然后 start 启动该项目。
- 启动之后,将服务注册到 Registry 注册中心,相当于告诉注册中心提供方已经提供好服务可供调用了。
- 消费者向注册中心申请订阅这个服务,之后由注册中心查看服务提供方的服务是否注册,如果注册了就
notify
通知消费者。 - 这个时候消费者就可以
invoke
调用提供方提供的服务了,这个服务调用属于RPC远程服务调用,归属于Dubbo管理。 - 整个服务调用过程中,Monitor监视器会监控服务调用的一些信息,比如调用次数count、调用时间。
二、Zookeeper 注册中心
ZooKeeper 是一个开放源码的分布式应用程序协调服务,是 Google 的 Chubby 一个开源的实现,是 Hadoop 和 Hbase 的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。
官方下载地址:Apache Downloads(Zookeeper 是用 Java 编写的,所以需要先有 JDK)
参考文章:ZooKeeper单机与集群搭建
windows 下的安装与配置:
①下载并解压
apache-zookeeper-3.8.0-bin.tar.gz
②在解压好的目录下,创建 data 目录和 log 目录
③配置文件:将 conf 目录下的 zoo_sample.cfg 文件复制一份,并重命名为
zoo.cfg
,修改内容:
clientPort=2181
admin.serverPort=8888
dataDir=D:\\apache-zookeeper-3.8.0-bin\\data
dataLogDir=D:\\apache-zookeeper-3.8.0-bin\\log
**注意:此处的路径一定要使用双斜杠
\\
**
④在 bin 目录下,启动 zookeeper
zkServer.cmd:启动服务端后,客户端就可以连接上了,服务也能注册到 zookeeper 中了。
zkCli.cmd:启动客户端后,就可以查看 zookeeper 中的节点信息了,客户端基础命令使用。
三、SpringBoot 整合 Dubbo
官方教程:https://cn.dubbo.apache.org/zh-cn/overview/mannual/java-sdk/quick-start/spring-boot
官方是将一个完整的服务分为三个模块,比如图书服务可分为:API(
提供 BookService 接口
)、服务端(
提供API的实现类 BookServiceImpl
)、消费端(
BookServer,真正的图书服务模块
)。
我们还是以之前的 图书借阅系统 为例进行学习,但不会这么麻烦,主要展示
Dubbo+Zookeeper
实现服务远程调用。
3.1 添加依赖
在父工程中添加 Dubbo + Zookeeper 的依赖管理:
<dependencyManagement><dependencies><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.10</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><version>2.7.10</version><type>pom</type></dependency></dependencies></dependencyManagement>
3.2 配置服务端
我们将 bookService 和 userService 作为服务端,所以下面的操作在这两个模块上都要进行一次。
①添加依赖
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><type>pom</type><!--排除SLF4J多种实现的冲突: logback-classic 和 slf4j-log4j12--><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions></dependency>
②启动类添加
@EnableDubbo
注解
@SpringBootApplication@EnableDubbopublicclassBookApplication{publicstaticvoidmain(String[] args){
SpringApplication.run(BookApplication.class, args);}}
③yml 配置文件:配置 Dubbo 和 注册中心
dubbo:application:name: book-provider
registry:#注册中心address: zookeeper://127.0.0.1:2181protocol:#协议,不同模块的端口不能一致name: dubbo
port:20880
④暴露服务:将对外提供的服务实现类用
@DubboService
注解修饰
@Service@DubboServicepublicclassBookServiceImplimplementsBookService{@Resourceprivate BookMapper bookMapper;@Overridepublic Book getBookById(int bid){return bookMapper.getBookById(bid);}}
3.3 配置消费端
我们将 borrowService 作为消费端。
①添加依赖,还需要依赖两个服务端模块
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><type>pom</type><!--排除SLF4J多种实现的冲突: logback-classic 和 slf4j-log4j12--><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions></dependency><dependency><groupId>com.wangshaoyu</groupId><artifactId>book-service</artifactId><version>0.0.1-SNAPSHOT</version></dependency><dependency><groupId>com.wangshaoyu</groupId><artifactId>user-service</artifactId><version>0.0.1-SNAPSHOT</version></dependency>
②消费端的启动类不需要添加
@EnableDubbo
注解
@SpringBootApplicationpublicclassBorrowApplication{publicstaticvoidmain(String[] args){
SpringApplication.run(BorrowApplication.class, args);}}
③yml 配置文件:配置 Dubbo 和 注册中心
dubbo:application:name: book-provider
registry:#注册中心address: zookeeper://127.0.0.1:2181protocol:#协议,不同模块的端口不能一致name: dubbo
port:20882
④调用服务:使用
@DubboReference
来注入远程的服务类
@ServicepublicclassBorrowServiceImplimplementsBorrowService{@Resourceprivate BorrowMapper borrowMapper;@DubboReferenceprivate UserService userService;@DubboReferenceprivate BookService bookService;@Overridepublic UserBorrowView getBorrowViewByUid(int uid){
List<Borrow> borrowList = borrowMapper.getBorrowsByUid(uid);
User user = userService.getUserById(uid);
List<Book> bookList = borrowList
.stream().map(b -> bookService.getBookById(b.getBid())).collect(Collectors.toList());returnnewUserBorrowView(user, bookList);}}
3.4 启动测试
①启动服务端:发现连接成功。
②启动 zookeeper 客户端:可以通过指令查看节点了。
四、Dubbo-admin 管理中心
- Admin 主进程,包括服务发现元数据管理、可视化控制台、安全认证策略管控、其他定制化服务治理能力等组件。
- 强依赖组件,包括 Mysql 数据库、注册/配置/元数据中心 (可以是 Kubernetes、Nacos、Zookeeper 等)。
- 可选依赖组件,包括 Prometheus、Grafana、Zipkin 等。
官方部署教程:https://cn.dubbo.apache.org/zh-cn/overview/reference/admin/architecture
我们先下载官方源码,我的云盘里有 dubbo-admin.zip
https://github.com/apache/dubbo-admin.git
解压可以看到里面有这两个文件夹,因为 Dubbo-Admin 是前后端分离的两个工程项目。
4.1 部署服务端
①修改配置文件:application.properties,先根据自己注册中心的信息修改
admin.registry.address=zookeeper://127.0.0.1:2181
admin.config-center=zookeeper://127.0.0.1:2181
admin.metadata-report.address=zookeeper://127.0.0.1:2181
admin.root.user.name=root
admin.root.user.password=root
②开始打包,如果已经有了 target 则先删除。 在 dubbo-admin-server 目录下进入终端,执行以下指令。
mvn clean compile package
打包成功后,就是这样的画面。。。打包时出错,可参考文章:mvn 无法识别解决方案
最终,我们会在 target 下看到 jar 包
③启动服务器
方法一:我们可以在 target 目录下进入终端,然后执行以下指令启动服务器:
java -jar dubbo-admin-server-0.2.0-SNAPSHOT.jar
方法二:我们可以放到 IDEA 中管理,便于频繁的启动和关闭。
注意:不要修改 dubbo-admin-server 的端口,它默认是 8080,修改后前端就连接不上了。
4.2 部署前端
①先下载安装 node.js,参考文章:安装 nodejs 和 npm 教程
npm info vue
报错参考文章:npm安装报错
②安装依赖并启动,在 dubbo-admin-ui 目录下进入终端执行以下指令:
# 安装依赖,仅需执行依次npminstall# 启动指令npm run dev
可参考文章:解决npm install 安装慢!!!
③启动成功,会进入这个页面。
4.3 访问控制台
启动前端工程后,我们会得到访问地址:
http://localhost:8081
服务查询结果:
总结:
提示:这里对文章进行总结:
本文是对Dubbo的入门学习,先通过官方架构图了解了启动流程,又安装了zookeeper注册中心,随之学习了SpringBoot整合Dubbo,实现了服务间的远程调用,最后安装了Dubbo-Admin管理服务,并且访问了管理页面。之后的学习内容将持续更新!!!
版权归原作者 一只咸鱼。。 所有, 如有侵权,请联系我们删除。