当前位置: 首页 > news >正文

Dubbo 如何使用 Zookeeper 作为注册中心:原理、优势与实现详解

Dubbo 是一个高性能的 Java 分布式服务框架,而 Zookeeper 常被用作 Dubbo 的服务注册中心。Zookeeper 提供了分布式一致性和协调服务,Dubbo 通过 Zookeeper 实现服务注册与发现功能,确保在分布式环境下服务实例的动态管理和可靠发现。

下面是 Dubbo 使用 Zookeeper 作为注册中心 的工作原理及实现过程。

1. Dubbo 与 Zookeeper 的工作原理

1.1 Zookeeper 作为注册中心的角色

在 Dubbo 中,Zookeeper 充当服务注册中心,负责管理服务提供者和消费者的信息。Zookeeper 通过维护一棵 层次化的节点树 来保存服务的注册信息,并且 Dubbo 可以通过 监听节点的变化 来实现服务发现和负载均衡。

  • 服务提供者:Dubbo 的服务提供者在启动时会将自身服务的地址、接口等信息注册到 Zookeeper 中,作为节点存储在 Zookeeper 的树结构中。
  • 服务消费者:服务消费者在启动时向 Zookeeper 查询已注册的服务,并通过订阅机制监听服务的变化,确保当服务提供者的状态(上线、下线等)发生变化时,消费者能够动态调整调用的服务实例。
  • 服务发现:消费者通过 Zookeeper 监听服务提供者的节点变化,动态更新可用的服务地址。Zookeeper 确保消费者始终能找到可用的服务。

1.2 节点结构及目录设计

Zookeeper 通过树形目录来存储服务信息。Dubbo 在 Zookeeper 中的节点大致分为三个层次:

  1. 服务根目录:存储服务的名称信息。每个服务对应一个唯一的节点,所有提供该服务的服务提供者会在此节点下注册。

    • 例如,/dubbo/com.example.UserService
  2. 提供者(providers):服务提供者会在此目录下注册节点,节点的内容是服务提供者的地址和配置信息。

    • 例如,/dubbo/com.example.UserService/providers
  3. 消费者(consumers):服务消费者会在此目录下注册节点,节点内容为消费者的地址和配置信息。

    • 例如,/dubbo/com.example.UserService/consumers

此外,Dubbo 还可以在 configurators 目录下存储服务的动态配置,routers 目录下存储路由规则等。

1.3 服务注册

当 Dubbo 的服务提供者启动时,它会向 Zookeeper 注册自身服务,具体流程如下:

  1. 建立与 Zookeeper 的连接:服务提供者通过 Zookeeper 客户端(如 Curator)连接到 Zookeeper 集群。

  2. 在 Zookeeper 中创建节点:服务提供者根据服务名称(如 com.example.UserService)在 /dubbo 根目录下的 providers 目录下创建一个 临时节点,节点内容包含服务提供者的地址(IP、端口)和其他配置信息。

  3. 服务注册完成:Zookeeper 会将这些节点保存在其目录树中,服务消费者可以通过查询该目录来发现服务。

1.4 服务发现

Dubbo 的服务消费者通过以下步骤来发现服务提供者:

  1. 消费者查询服务提供者信息:服务消费者启动时,Dubbo 会向 Zookeeper 注册中心发起查询请求,获取 /dubbo/com.example.UserService/providers 目录下的所有服务提供者地址。

  2. 订阅服务提供者的节点:消费者会订阅这些服务提供者的节点变化,一旦有服务提供者上线或下线,Zookeeper 会通知消费者更新其本地缓存。

  3. 动态调整服务调用:消费者根据最新的服务提供者信息,动态选择一个可用的服务进行调用。如果某个服务提供者下线,消费者会自动更新其服务列表。

1.5 负载均衡与故障恢复

Dubbo 通过与 Zookeeper 集成实现了负载均衡和故障恢复:

  • 负载均衡:当多个服务提供者注册到 Zookeeper 时,消费者会根据负载均衡策略(如随机、轮询、最少活跃调用等)选择一个服务提供者进行调用。Dubbo 内置了多种负载均衡策略,消费者可以根据不同场景选择合适的策略。

  • 故障恢复:如果某个服务提供者由于故障下线,Zookeeper 会通过节点的删除通知消费者,消费者会自动从列表中剔除该服务实例,并重新选择其他可用的服务提供者。


2. Dubbo 与 Zookeeper 集成的具体配置示例

以下是 Dubbo 使用 Zookeeper 作为注册中心的一个简单配置示例:

2.1 服务提供者配置

<dubbo:application name="user-service-provider" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<dubbo:protocol name="dubbo" port="20880" /><!-- 定义服务提供者 -->
<dubbo:service interface="com.example.UserService" ref="userServiceImpl" />
<bean id="userServiceImpl" class="com.example.UserServiceImpl" />
  • <dubbo:registry>:指定了注册中心为 Zookeeper,并设置其地址为 127.0.0.1:2181
  • <dubbo:service>:定义服务的接口 UserService,并指定实现类 userServiceImpl

2.2 服务消费者配置

<dubbo:application name="user-service-consumer" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<dubbo:reference id="userService" interface="com.example.UserService" />
  • <dubbo:reference>:定义服务消费者,指向 Zookeeper 注册中心查询 UserService 接口的服务实例。

2.3 Zookeeper 的目录结构

Zookeeper 中的目录结构如下:

/dubbo└── /com.example.UserService├── /providers│   └── dubbo://192.168.0.1:20880/com.example.UserService?version=1.0.0└── /consumers└── consumer://192.168.0.2/com.example.UserService?version=1.0.0
  • /providers:存放服务提供者的信息,包括服务地址、端口、版本等。
  • /consumers:存放服务消费者的信息。

3. Dubbo 使用 Zookeeper 作为注册中心的优势与劣势

3.1 优势

  1. 高可用与强一致性:Zookeeper 通过 ZAB 协议 保证了强一致性和高可用性,确保服务注册和发现的高可靠性。

  2. 实时性:Zookeeper 的 订阅机制 能够实时通知消费者服务的上线和下线情况,使得消费者能快速响应服务的变化,保持服务的动态发现。

  3. 分布式协调能力:Zookeeper 作为分布式协调系统,能够很好地管理服务注册中心的状态变化,适合大规模分布式系统。

  4. 服务动态性:Zookeeper 允许 Dubbo 服务的动态注册和下线,消费者能够实时感知服务实例的变化,适合频繁更新的微服务架构。

3.2 劣势

  1. 写入性能较低:Zookeeper 由于其强一致性要求,写操作性能相对较弱,尤其在大量服务注册时,Zookeeper 的性能可能成为瓶颈。

  2. 没有内置的负载均衡:Zookeeper 本身不提供负载均衡功能,Dubbo 需要额外实现负载均衡策略。这增加了系统的复杂性。

  3. 节点数量限制:Zookeeper 的节点结构不适合管理大量的瞬时数据,过多的节点可能导致 Zookeeper 负载过高,不适合超大规模的服务实例注册。

  4. 依赖 Zookeeper 的稳定性:如果 Zookeeper 集群出现故障,服务的注册与发现将受到影响,虽然 Dubbo 有一定的容错机制,但仍可能导致短暂的不可用。


4. 总结

通过将 Zookeeper 作为 Dubbo 的注册中心,Dubbo 能够实现服务的动态注册、发现和状态管理。Zookeeper 的强一致性和实时通知机制为 Dubbo 的分布式服务提供了可靠的基础设施,确保了服务的高可用性。然而,由于 Zookeeper 在写入性能和负载能力上的限制,适合中小规模分布式系统。对于大规模的分布式服务,可能需要额外优化 Zookeeper 的集群配置,或者结合其他工具进行扩展。

Dubbo 与 Zookeeper

的结合是传统分布式服务架构中的经典搭配,适合需要高一致性、强动态服务管理的场景。

相关文章:

Dubbo 如何使用 Zookeeper 作为注册中心:原理、优势与实现详解

Dubbo 是一个高性能的 Java 分布式服务框架&#xff0c;而 Zookeeper 常被用作 Dubbo 的服务注册中心。Zookeeper 提供了分布式一致性和协调服务&#xff0c;Dubbo 通过 Zookeeper 实现服务注册与发现功能&#xff0c;确保在分布式环境下服务实例的动态管理和可靠发现。 下面是…...

Linux:进程间通信之命名管道

Linux&#xff1a;进程间通信-CSDN博客 我们说匿名管道只能用于父子进程这样的关系通信&#xff0c;那么陌生进程怎么通信&#xff1f; 我们之前说父子进程能通信的最关键的地方就在于子进程复制了一份父进程的files_struct&#xff0c;从而通过文件的inode映射同一份文件来通…...

UE4_后期处理七—仿红外线成像效果

效果图展示&#xff1a; 参考文档&#xff1a;https://dev.epicgames.com/documentation/zh-cn/unreal-engine/using-fresnel-in-your-unreal-engine-materials?application_version5.4 二、所用知识点扩充 在创建电影或过场动画时&#xff0c;你常常需要想办法更好地突显角…...

静态路由和默认路由(实验)

目录 一、实验设备和环境 1、实验设备 2、实验环境 &#xff08;1&#xff09;实验拓扑图 &#xff08;2&#xff09;实验命令列表 二、实验记录 1、直连路由与路由表查看 步骤1:建立物理连接并运行超级终端。 步骤2:在路由器上查看路由表。 2、静态路由配置 步骤1:配…...

TCP: Textual-based Class-aware Prompt tuning for Visual-Language Model

文章汇总 存在的问题 原文&#xff1a;具有图像特定知识的图像条件提示符号在提升类嵌入分布方面的能力较差。 个人理解&#xff1a;单纯把"a photo of {class}"这种提示模版作为输入是不利于text encoder学习的 动机 在可学习的提示和每一类的文本知识之间建立…...

2024年软考网络工程师中级题库

1【考生回忆版】以下不属于5G网络优点的是&#xff08;A) A.传输过程中消耗的资源少&#xff0c;对设备的电池更友好 B.支持大规模物联网&#xff0c;能够连接大量低功耗设备&#xff0c;提供更高效的管理 C.引入了网络切片技术&#xff0c;允许将物理网络划分为多个虚拟网络…...

CSS的盒子模型(Box Model)

所有HTML元素都可以看作盒子&#xff0c;在CSS中盒子模型是用来设计和布局的&#xff0c;CSS盒子模型本质上是一个盒子&#xff0c;分装周围的HTML元素包括&#xff1a;外边距&#xff0c;边框&#xff0c;内边距和实际内容。 Margin&#xff08;外边距&#xff09; 清除边框…...

用OpenSSL搭建PKI证书体系

1 创建PKI结构目录 mkdir 07_PKI cd 07_PKI mkdir 01_RootCA 02_SubCA 03_Client2 创建根CA cd 01_RootCA mkdir key csr cert newcerts touch index.txt index.txt.attr echo 01 > serial2.1 创建根CA密钥对 2.1.1 生成 长度为2048 bit 的RSA私钥。 cd key openssl gen…...

scp 命令:在两台主机间远程传输文件

一、命令简介 ​scp​ 命令使用 SSH ​加密的方式在本地主机和远程主机之间复制文件。 ‍ 二、命令参数 格式 scp [选项] 发送方主机和目录 接收方主机和目录注意&#xff1a;左边是发送方&#xff0c;右边是接收方。固定格式。 示例 #示例1 scp ~/test.txt soulio172.1…...

家用迷你洗衣机哪款质量高?五大热销高分单品强势来袭

迷你内衣洗衣机一般是为婴儿宝宝&#xff0c;或者一些有特殊需要的用户而设计使用的&#xff0c;宝宝衣物换洗频繁&#xff0c;而且对卫生方面的除菌要求高&#xff0c;而为避免交叉感染&#xff0c;所以一般不适合和大人的衣物放在一起洗&#xff0c;因此对于有宝宝的家庭来说…...

rpm 命令:RedHat底层包管理器

一、命令简介 ​rpm​ 是 Red Hat Package Manager 的缩写&#xff0c;是 Red Hat、CentOS、Fedora 等基于 Red Hat 的 Linux 发行版中用于管理和安装软件包的工具。它能够安装、卸载、升级、查询和验证软件包。 相关命令&#xff1a; rpm 是基础&#xff0c;提供了底层的软…...

Xilinx 使用DDS实现本振混频上下变频

文章目录 一、什么是混频&#xff1f;二、为什么要进行混频&#xff1f;三、Matlab实现混频操作四、FPGA实现混频上下变频操作4.1 例化IP4.2 仿真验证 一、什么是混频&#xff1f; 混频&#xff08;Mixing&#xff09;是信号处理中的一个核心概念&#xff0c;混频的本质是将两个…...

ClickHouse-Kafka Engine 正确的使用方式

Kafka 是大数据领域非常流行的一款分布式消息中间件&#xff0c;是实时计算中必不可少的一环&#xff0c;同时一款 OLAP 系统能否对接 Kafka 也算是考量是否具备流批一体的衡量指标之一。ClickHouse 的 Kafka 表引擎能够直接与 Kafka 系统对接&#xff0c;进而订阅 Kafka 中的 …...

PTA L1-071 前世档案

L1-071 前世档案&#xff08;20分&#xff09; 网络世界中时常会遇到这类滑稽的算命小程序&#xff0c;实现原理很简单&#xff0c;随便设计几个问题&#xff0c;根据玩家对每个问题的回答选择一条判断树中的路径&#xff08;如下图所示&#xff09;&#xff0c;结论就是路径终…...

解决mac下 Android Studio gradle 下载很慢,如何手动配置

抓住人生中的一分一秒&#xff0c;胜过虚度中的一月一年! 小做个动图开篇引题 前言 平时我们clone git 上项目&#xff0c;项目对应gradle版本本地没有&#xff0c;ide编译会自动下载&#xff0c;但是超级慢可能还下载失败&#xff0c;下面讲解下此问题如 如下图所示&#xff…...

第三篇 第17章 工程计量与支付

第三篇 工程计价 第17章 工程计量与支付 17.1 工程计量 17.1.1 工程计量的原则 承包人完成合同工程且应予计量的工程数量确定计量周期可以月为单位,也可以按其他时间节点、工程形象进度分段计量因承包人原因造成的超出合同工程范围施工或返工的工程量、发包人不予计量 17.1…...

[半导体检测-1]:半导体检测概述

前言&#xff1a; 半导体检测是半导体产业链中不可或缺的一环&#xff0c;它贯穿于产品生产制造流程的始终&#xff0c;对于提高产线良率、提升产品竞争实力具有关键作用。以下是对半导体检测的详细概述&#xff1a; 一、什么是半导体检测 半导体检测是指运用专业技术手段&a…...

公共字段自动填充

问题分析 总会有些公共字段&#xff0c;例如创建时间和创建人 实现思路 对mapper定义注解&#xff0c;使用切面思想来判断是不是更新和新增操作对于指定的操作来更新公共字段 自定义操作类型 package com.sky.enumeration;/*** 数据库操作类型*/ public enum OperationType {/*…...

超详细 Git 教程:二十篇博客,三万字干货

Git 是最流行的版本管理工具&#xff0c;可以说是任何程序员都应该掌握的工具。 当然&#xff0c;其他人也可以学习它用来进行版本控制 为此&#xff0c;我将之前学习 Git 时的笔记整理了下&#xff08;预计有二十篇&#xff09;&#xff0c;作为博客发出来&#xff0c;希望能帮…...

“出参”和“入参”的命名由来

有些开发者会用“入参”和“出参”来描述函数、方法或接口的参数和返回值。尽管我们基本都知道“入参”就是方法的参数&#xff0c;“出参”就是返回值。但是对于一些起步就是JAVA的开发者来说&#xff0c;可能并不清楚这两个名词的由来。这篇文章就来分享一下关于“入参”和“…...

Redis相关知识总结(缓存雪崩,缓存穿透,缓存击穿,Redis实现分布式锁,如何保持数据库和缓存一致)

文章目录 1.什么是Redis&#xff1f;2.为什么要使用redis作为mysql的缓存&#xff1f;3.什么是缓存雪崩、缓存穿透、缓存击穿&#xff1f;3.1缓存雪崩3.1.1 大量缓存同时过期3.1.2 Redis宕机 3.2 缓存击穿3.3 缓存穿透3.4 总结 4. 数据库和缓存如何保持一致性5. Redis实现分布式…...

高频面试之3Zookeeper

高频面试之3Zookeeper 文章目录 高频面试之3Zookeeper3.1 常用命令3.2 选举机制3.3 Zookeeper符合法则中哪两个&#xff1f;3.4 Zookeeper脑裂3.5 Zookeeper用来干嘛了 3.1 常用命令 ls、get、create、delete、deleteall3.2 选举机制 半数机制&#xff08;过半机制&#xff0…...

【AI学习】三、AI算法中的向量

在人工智能&#xff08;AI&#xff09;算法中&#xff0c;向量&#xff08;Vector&#xff09;是一种将现实世界中的数据&#xff08;如图像、文本、音频等&#xff09;转化为计算机可处理的数值型特征表示的工具。它是连接人类认知&#xff08;如语义、视觉特征&#xff09;与…...

EtherNet/IP转DeviceNet协议网关详解

一&#xff0c;设备主要功能 疆鸿智能JH-DVN-EIP本产品是自主研发的一款EtherNet/IP从站功能的通讯网关。该产品主要功能是连接DeviceNet总线和EtherNet/IP网络&#xff0c;本网关连接到EtherNet/IP总线中做为从站使用&#xff0c;连接到DeviceNet总线中做为从站使用。 在自动…...

自然语言处理——Transformer

自然语言处理——Transformer 自注意力机制多头注意力机制Transformer 虽然循环神经网络可以对具有序列特性的数据非常有效&#xff0c;它能挖掘数据中的时序信息以及语义信息&#xff0c;但是它有一个很大的缺陷——很难并行化。 我们可以考虑用CNN来替代RNN&#xff0c;但是…...

html css js网页制作成品——HTML+CSS榴莲商城网页设计(4页)附源码

目录 一、&#x1f468;‍&#x1f393;网站题目 二、✍️网站描述 三、&#x1f4da;网站介绍 四、&#x1f310;网站效果 五、&#x1fa93; 代码实现 &#x1f9f1;HTML 六、&#x1f947; 如何让学习不再盲目 七、&#x1f381;更多干货 一、&#x1f468;‍&#x1f…...

基于TurtleBot3在Gazebo地图实现机器人远程控制

1. TurtleBot3环境配置 # 下载TurtleBot3核心包 mkdir -p ~/catkin_ws/src cd ~/catkin_ws/src git clone -b noetic-devel https://github.com/ROBOTIS-GIT/turtlebot3.git git clone -b noetic https://github.com/ROBOTIS-GIT/turtlebot3_msgs.git git clone -b noetic-dev…...

推荐 github 项目:GeminiImageApp(图片生成方向,可以做一定的素材)

推荐 github 项目:GeminiImageApp(图片生成方向&#xff0c;可以做一定的素材) 这个项目能干嘛? 使用 gemini 2.0 的 api 和 google 其他的 api 来做衍生处理 简化和优化了文生图和图生图的行为(我的最主要) 并且有一些目标检测和切割(我用不到) 视频和 imagefx 因为没 a…...

Git 3天2K星标:Datawhale 的 Happy-LLM 项目介绍(附教程)

引言 在人工智能飞速发展的今天&#xff0c;大语言模型&#xff08;Large Language Models, LLMs&#xff09;已成为技术领域的焦点。从智能写作到代码生成&#xff0c;LLM 的应用场景不断扩展&#xff0c;深刻改变了我们的工作和生活方式。然而&#xff0c;理解这些模型的内部…...

uniapp 字符包含的相关方法

在uniapp中&#xff0c;如果你想检查一个字符串是否包含另一个子字符串&#xff0c;你可以使用JavaScript中的includes()方法或者indexOf()方法。这两种方法都可以达到目的&#xff0c;但它们在处理方式和返回值上有所不同。 使用includes()方法 includes()方法用于判断一个字…...