Dubbo+Zookeeper 实现服务远程调用

news2025/1/19 20:40:17

文章目录

  • 一、Dubbo 架构图
  • 二、Zookeeper 注册中心
  • 三、SpringBoot 整合 Dubbo
    • 3.1 添加依赖
    • 3.2 配置服务端
    • 3.3 配置消费端
    • 3.4 启动测试
  • 四、Dubbo-admin 管理中心
    • 4.1 部署服务端
    • 4.2 部署前端
    • 4.3 访问控制台


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

在这里插入图片描述

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

一、Dubbo 架构图

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

在这里插入图片描述
节点角色说明:

  • 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 目录
在这里插入图片描述

配置文件:将 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
@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 注解

@EnableDubbo
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 启动测试

①启动服务端:发现连接成功。
在这里插入图片描述

②启动 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 目录下进入终端执行以下指令:

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

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

③启动成功,会进入这个页面。
在这里插入图片描述

4.3 访问控制台

启动前端工程后,我们会得到访问地址:http://localhost:8081
在这里插入图片描述

服务查询结果:
在这里插入图片描述

回到目录…


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

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Visual Assist X安装失败解决办法

最近重装了VS2017&#xff0c;在重装之前卸载了VA助手&#xff0c;但是等到装好VS再去装VA助手时&#xff0c;总是提示以下错误信息&#xff1a; Visual Assist Installer : An error was reported by Visual Studio VSIXInstaller. See the next window for access to its err…

ElasticJob

官网 :: ElasticJob ElasticJob 是面向互联网生态和海量任务的分布式调度解决方案&#xff0c;由两个相互独立的子项目 ElasticJob-Lite 和 ElasticJob-Cloud 组成。 它通过弹性调度、资源管控、以及作业治理的功能&#xff0c;打造一个适用于互联网场景的分布式调度解决方案&…

如何给厂区做导航地图?智能工厂导航地图解决方案公司

如何给厂区做导航地图&#xff1f;在智慧园区中&#xff0c;基于园区的电子地图地图使用的重要性越来越凸显。但目前在园区信息化应用形式中&#xff0c;广泛缺乏专业电子地图的使用&#xff0c;主要原因是&#xff1a;一是地图系统(GIS)实现繁复&#xff0c;与其他展会业务系统…

GateWay微服务网关的搭建

服务网关 没有服务网关 问题&#xff1a;地址太多|安全性|管理问题 访问商品服务 http://ip地址:9001/goods/findAll 访问广告服务 http://ip地址:9002/brand/findAll 访问用户服务 http://ip地址:9003/user/findAll 在有网关的情况下&#xff0c;我们配置网关端口号为…

Vue2之webpack篇(二)Loader

目录 一、loader处理css 1、css文件的创建 2、安装css-loader 3、配置 4、打包 5、最终效果 二、loader处理图片 1、引入图片 2、安装file-loader 3、配置module 4、webpack打包 三、ES6转ES5 1、介绍 2、安装babel-loader 3、webpack.config.js配置 4、webpack打…

C++数据结构:二叉树

二叉树 每个结点最多只有二棵子树&#xff0c;也就是二叉树中没有度大于2的结点。二叉树的子树有左右之分&#xff0c;严格区分左孩子、右孩子&#xff0c;其次序不能颠倒 二叉树五种基本形态 特殊二叉树 斜树 所有节点都只有左子树的二叉树叫做左斜树&#xff0c;所有节点都…

SAP ABAP 创建后台定时任务job

定时任务的事务码 sm36:创建定时任务 sm37:查看定时任务 JDBG:后台任务debug,在对应的sm37中对应的job页面 t-code输入 创建定时任务SM36 1、名称可以随便起一般都是按自己公司业务情况来&#xff0c;比如我这个就是哪一个报表的定时任务&#xff0c;做的是什么操作&#xf…

Python 全栈系列220 Tornado的服务搭建

说明 想法变的真快 本来是没打算用Tornado的&#xff0c;主要是想节约时间。但是现在看来不用还是不行&#xff1a;目前用gevent flask部署的时候&#xff0c;启动多核的worker似乎存在问题。 另外&#xff0c;有很多内部基础的数据服务&#xff0c;其实并不需要flask的各种组…

如何使用镭速保护云存储数据安全

近年来&#xff0c;随着云计算的发展&#xff0c;远程系统上的数据存储变的越来越重要。云存储是一个以数据存储和管理为核心的云计算系统&#xff0c;给我们提供了一种全新的数据信息存储模式。但是&#xff0c;可以从全球任何地方访问和检索相同的数据。所需要的只是一个简单…

ZooKeeper分布式应用程序协调服务

目录 一.ZooKeeper基本介绍 1.ZooKeeper是什么&#xff1f; 2.ZooKeeper的工作机制 3.ZooKeeper的特点 4.ZooKeeper的数据结构 5.ZooKeeper的应用场景 5.1 统一命名服务 5.2 统一配置管理 5.3 统一集群管理 5.4 服务器动态上下线 5.5 软负载均衡 二.ZooKeeper的选举…

EasyConnect登陆报错:拉起虚拟网卡失败,请确保虚拟网卡已经安装在系统上并处于启用状态,然后再重新登录解决此问题。

目录 项目场景&#xff1a; 问题描述 原因分析&#xff1a; 解决方案&#xff1a; 1. 搜索设备管理器&#xff0c;打开/或者打开此电脑-&#xff08;顶部&#xff09;计算机-属性-设备管理器进入 2. 进入设备管理器&#xff0c;找到网络适配器&#xff0c;双击网络适配器…

【云原生】k8s Service 实现服务发现和负载均衡

文章目录 前言Service 介绍Service 的四种类型及使用方式Service 的定义和使用通过命令创建服务查看创建的服务情况 不指定 Selectors 的服务Headless 服务Service 工作原理及原理图Ingress 讲解集群外部如何访问服务总结 前言 在容器编排系统中&#xff0c;如 Kubernetes&…

Anaconda + TensorFlow Winodws环境安装(Windows Terminal / Visual Studio / VS code)

目录 前言个人环境 Anaconda安装下载安装测试添加到windows terminal TensorFlow环境配置安装测试 搭配Visual Studio 2022搭配VS Code 前言 以前发生的一些事情&#xff0c;让我认识到即便配环境这种事情&#xff0c;最好还是把自己的过程存个档 &#xff0c;这个的安装虽然简…

前端HTML、CSS--11(CSS-8)

目录&#xff1a; CSS3 属性选择器 CSS3 结构伪类选择器 CSS3 伪元素选择器 CSS3 2D转换 CSS3 动画 CSS3 3D转换 浏览器私有前缀 4. 2D转换 转换&#xff08;transform&#xff09;是CSS3中具有颠覆性的特性之一&#xff0c;可以实现元素的位移、旋转、缩放等效果。 转…

技术引领,创邻科技Galaxybase亮相2023数据技术嘉年华

2023年4月7日-8日&#xff0c;由中国DBA联盟&#xff08;ACDU&#xff09;和墨天轮社区联合主办的第十二届『数据技术嘉年华』&#xff08;DTC2023&#xff09;在北京举办。本次大会以“开放融合数智化——引领数据技术发展&#xff0c;释放数据要素价值”为主题&#xff0c;从…

线下活动 | 探索现代服务业的人效提升之路

3月25日&#xff0c;盖雅搞得定系列活动-卓越管理闭门分享会圆满落幕。此次活动主题定为「探索服务业的人效提升之路」&#xff0c;20余位现代服务业企业代表参与了此次活动&#xff0c;共同探讨如何利用数字化工具赋能企业管理&#xff0c;促进人效提升。招商积余人力负责人谢…

仿函数详解

目录 1、函数对象 2、谓词 2.1、一元谓词&#xff08;谓词有一个参数&#xff09; 2.1.1、普通函数提供策略 2.1.2、仿函数&#xff08;上面的函数调用&#xff09;提供策略 2.1.3、一元谓词全部代码 2.1、二元谓词&#xff08;谓词有两个参数&#xff09; ​编辑 3、内…

Ansys Zemax | 如何模拟 LED 及其它复杂光源

概述 在使用非序列时&#xff0c;对照明系统进行精确模拟的第一步总是要正确建立光源模型。OpticStudio 提供了多种精确模拟光源的方法。这篇文章介绍了如何在非序列模式下使用径向光源 (Source Radial), 光源文件 (Source File) 以及通过建立其他复杂几何体&#xff0c;来对le…

Oracle与Mysql求连续天数的数据

问题&#xff1a;最近有开发需求&#xff0c;查询最近一个月连续天数>2的数据项&#xff0c;我这里数据库日期存储的是yyyymmdd&#xff0c;字符串 (可自行根据自身情况修改) 思路&#xff1a;如果可以找到连续日期的开始与结束时间&#xff0c;那么就可以 where 日期 betw…

D. Shortest Cycle(floyd求最小环)

Problem - D - Codeforces 给你n个整数a1,a2,..., ana1,a2,...,an。考虑n个节点的图&#xff0c;其中节点ii, jj (i≠ji≠j)是相连的&#xff0c;当且仅当&#xff0c;aiaiAND aj≠0aj≠0&#xff0c;其中AND表示位数和操作。 请找出该图中最短周期的长度&#xff0c;或确定它…