Dubbo+Zookeeper 实现服务远程调用

这篇具有很好参考价值的文章主要介绍了Dubbo+Zookeeper 实现服务远程调用。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。


提示:以下是本篇文章正文内容,Java 系列学习将会持续更新

Dubbo+Zookeeper 实现服务远程调用

官方文档:https://cn.dubbo.apache.org/zh-cn/#td-block-1

一、Dubbo 架构图

  • Dubbo 是阿里巴巴公司开源的一个高性能、轻量级的 Java RPC 框架。
  • 致力于提供高性能和透明化的 RPC 远程服务调用方案,以及 SOA 服务治理方案。
  • 三个核心功能:基于接口的远程调用容错和负载均衡服务的自动注册与发现 。Dubbo 框架广泛的在阿里巴巴内部使用,以及京东、当当、去哪儿、考拉等都在使用。

Dubbo+Zookeeper 实现服务远程调用
节点角色说明:

  • Provider:暴露服务的服务提供方。
  • Consumer:调用远程服务的服务消费方。
  • Registry:服务注册与发现的注册中心。
  • Monitor:统计服务的调用次调和调用时间的监控中心。
  • Container:服务运行容器。

核心流程

  1. 首先服务提供方,将自己的服务放在一个容器中,然后 start 启动该项目。
  2. 启动之后,将服务注册到 Registry 注册中心,相当于告诉注册中心提供方已经提供好服务可供调用了。
  3. 消费者向注册中心申请订阅这个服务,之后由注册中心查看服务提供方的服务是否注册,如果注册了就 notify 通知消费者。
  4. 这个时候消费者就可以 invoke 调用提供方提供的服务了,这个服务调用属于RPC远程服务调用,归属于Dubbo管理。
  5. 整个服务调用过程中,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 目录
Dubbo+Zookeeper 实现服务远程调用

配置文件:将 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
Dubbo+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 实现服务远程调用

我们还是以之前的 图书借阅系统 为例进行学习,但不会这么麻烦,主要展示 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
@EnableDubbo
public class BookApplication {
    public static void main(String[] args) {
        SpringApplication.run(BookApplication.class, args);
    }
}

③yml 配置文件:配置 Dubbo 和 注册中心

dubbo:
  application:
    name: book-provider
  registry: #注册中心
    address: zookeeper://127.0.0.1:2181
  protocol: #协议,不同模块的端口不能一致
    name: dubbo
    port: 20880

④暴露服务:将对外提供的服务实现类用 @DubboService 注解修饰

@Service
@DubboService
public class BookServiceImpl implements BookService {

    @Resource
    private BookMapper bookMapper;

    @Override
    public 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 注解

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

③yml 配置文件:配置 Dubbo 和 注册中心

dubbo:
  application:
    name: book-provider
  registry: #注册中心
    address: zookeeper://127.0.0.1:2181
  protocol: #协议,不同模块的端口不能一致
    name: dubbo
    port: 20882

④调用服务:使用 @DubboReference 来注入远程的服务类

@Service
public class BorrowServiceImpl implements BorrowService {
    @Resource
    private BorrowMapper borrowMapper;

    @DubboReference
    private UserService userService;

    @DubboReference
    private BookService bookService;

    @Override
    public 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());
        return new UserBorrowView(user, bookList);
    }
}

回到目录…

3.4 启动测试

①启动服务端:发现连接成功。
Dubbo+Zookeeper 实现服务远程调用

②启动 zookeeper 客户端:可以通过指令查看节点了。
Dubbo+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 是前后端分离的两个工程项目。
Dubbo+Zookeeper 实现服务远程调用

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 无法识别解决方案
Dubbo+Zookeeper 实现服务远程调用
最终,我们会在 target 下看到 jar 包
Dubbo+Zookeeper 实现服务远程调用

③启动服务器

方法一:我们可以在 target 目录下进入终端,然后执行以下指令启动服务器:

java -jar dubbo-admin-server-0.2.0-SNAPSHOT.jar

方法二:我们可以放到 IDEA 中管理,便于频繁的启动和关闭。
Dubbo+Zookeeper 实现服务远程调用

注意:不要修改 dubbo-admin-server 的端口,它默认是 8080,修改后前端就连接不上了。

回到目录…

4.2 部署前端

①先下载安装 node.js,参考文章:安装 nodejs 和 npm 教程
Dubbo+Zookeeper 实现服务远程调用
npm info vue 报错参考文章:npm安装报错

②安装依赖并启动,在 dubbo-admin-ui 目录下进入终端执行以下指令:

# 安装依赖,仅需执行依次
npm install
# 启动指令
npm run dev

可参考文章:解决npm install 安装慢!!!

③启动成功,会进入这个页面。
Dubbo+Zookeeper 实现服务远程调用

4.3 访问控制台

启动前端工程后,我们会得到访问地址:http://localhost:8081
Dubbo+Zookeeper 实现服务远程调用

服务查询结果:
Dubbo+Zookeeper 实现服务远程调用

回到目录…


总结:
提示:这里对文章进行总结:
本文是对Dubbo的入门学习,先通过官方架构图了解了启动流程,又安装了zookeeper注册中心,随之学习了SpringBoot整合Dubbo,实现了服务间的远程调用,最后安装了Dubbo-Admin管理服务,并且访问了管理页面。之后的学习内容将持续更新!!!
文章来源地址https://www.toymoban.com/news/detail-418647.html

到了这里,关于Dubbo+Zookeeper 实现服务远程调用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 启动Dubbo项目注册Zookeeper时提示zookeeper not connected异常原理解析

    原创/朱季谦 遇到一个很诡异的问题,我在启动多个配置相同zookeeper的Dubbo项目时,其他项目都是正常启动,唯独有一个项目在启动过程中,Dubbo注册zookeeper协议时,竟然出现了这样的异常提示—— 我愣了一下,原以为是zookeeper集群挂了,然后检查了一下,都正常啊,奇怪的是

    2024年02月04日
    浏览(45)
  • Spring Cloud Alibaba【OpenFeign实现服务降级、Dubbo实现服务生产者、 Dubbo消费者调用接口 】(三)

    目录 服务调用_OpenFeign实现服务降级 服务调用_Dubbo实现服务生产者 

    2024年02月17日
    浏览(49)
  • 微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用

    🏷️ 个人主页 :鼠鼠我捏,要死了捏的主页  🏷️ 系列专栏 :Golang全栈-专栏 🏷️ 个人学习笔记,若有缺误,欢迎评论区指正   前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站AI学习网站。 目录 前言 快速上手

    2024年02月19日
    浏览(37)
  • Springboot3.X整合Dubbo3.XSpringCloudAlibaba微服务 2022.0 + Springboot3.X 集成 Dubbo实现对外调用http内部调用RPC

    近期自己新开了一套SpringCloud Alibaba微服务项目,接口使用了对外HTTP,内部RPC的设计,具体点说就是外部用户或客户端通过Nginx访问到Gateway网关再分发到各个服务,内部各个服务之间统一使用Dubbo RPC进行通信。下面是Springboot3.x集成Dubbo的分享: 1. 需要的关键依赖 2. 启动程序入

    2024年02月15日
    浏览(37)
  • 关于Apache Dubbo反序列化漏洞(CVE-2023-23638)的预警提示与对应的Zookeeper版本

            公司在升级dubbo过程中因 zookeeper版本不匹配,导致服务注册和调用出现异常 一、漏洞详情 Apache Dubbo是一款高性能、轻量级的开源Java服务框架。 Apache官方发布安全公告,修复了Apache Dubbo中的一个反序列化漏洞(CVE-2023-23638)。由于Apache Dubbo安全检查存在缺陷,导致可

    2024年02月15日
    浏览(39)
  • 服务框架Dubbo和ZooKeeper

    本篇为动物园之旅~ dubbo看作动物园的动物,那么zookeeper就是动物园 如果有人想去动物园看小老虎,那么动物园中有小老虎才能看到,否则看不到~ 关系:dubbo与 zookeeper的关系 Dubbo建议使用Zookeeper作为服务的注册中心 大型互联网项目的架构目标 传统项目和互联网项目 大型互联

    2024年02月03日
    浏览(44)
  • Alibaba spring cloud Dubbo使用(基于Zookeeper或者基于Nacos+泛化调用完整代码一键启动)

    Dubbo!用更优雅的方式来实现RPC调用吧 - 掘金 项目结构: 仅仅是提供服务的接口: pom: DubboServerApplication: HelloServiceImpl实现dubbo服务: 配置文件application.yaml: zookeeper是我的一台云服务器,zookeeper需要先部署好。 pom文件与Server相似: DubboClientApplication: RpcService: 通过Reference注

    2024年04月14日
    浏览(49)
  • zookeeper 查询注册的 dubbo 服务

    1. 连接zookeeper 服务端 使用bin 目录下zk客户端连接服务器, ./zkCli.sh -server  127.0.0.1:2181 2. 查询Dubbo 服务 # 查询所有服务 ls /dubbo   # 查询指定服务调用 ls /dubbo/服务名(接口地址)/consumers   # 查询指定服务调用 ls /dubbo/服务名(接口地址)/providers 3. 返回值实例 返回值查看不是很明显

    2024年02月10日
    浏览(46)
  • Dubbo 指定调用固定ip+port dubbo调用指定服务 dubbo调用不随机 dubbo自定义调用服务 dubbo点对点通信 dubbo指定ip

    1. 在写分布式im时nami-im: 分布式im, 集群 zookeeper netty kafka nacos rpc主要为gate(长连接服务) logic (业务) lsb (负载均衡)store(存储) - Gitee.com,需要指定某一长连接服务调用,其他博客得都调不通,写的有问题。要不就是通过xml进行配置,本文主要是以代码形式,调用前 配

    2024年02月15日
    浏览(43)
  • Dubbo远程调用在IDEA无法打断点怎么破

     以下是如何在IDEA中在Dubbo的分布式环境中设置远程调试的步骤: 1、首先,你需要在启动提供者服务时,加入一些JVM参数以开启调试服务。这些参数应该在你的启动脚本或者命令中。以下是一个常见的示例: 这行命令开启了调试,并设置了远程调试端口为5005。你可以根据你

    2024年02月08日
    浏览(33)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包