dubbo和zookeeper的关系

转载前言：网络上很多教程没有描述zookeeper和dubbo到底是什么关系、分别扮演了什么角色等信息，都是说一些似是而非的话，这里终于找到一篇文章，比较生动地描述了注册中心和微服务框架之间的关系，以及他们之间的合作分工。

下面附上我读完之后的理解：

dubbo是一个远程调用服务的分布式框架，可以实现远程通讯、动态配置、地址路由等等功能。
比如在入门demo里的暴露服务，使得远程调用的协议可以使用dobbo协议(dubbo://x.x.x.x)或者其它协议，可以配置zookeeper集群地址，实现软负载均衡并配置均衡方式等。
在不搭配注册中心的时候，它也是可以实现服务端和调用端的通信的，这种方式是点对点通信的，所谓“没有中间商”。但是如果配置服务发布和调用端过多特别是集群的方式提供服务的时候，就会暴露许多的问题：增加节点需要修改配置文件、服务端机器宕机后不能被感知等。

它可以通过集成注册中心，来动态地治理服务发布和服务调用。相当于把服务注册和发布推送的功能分摊给了(zookeeper)注册中心。

原帖地址：https://www.javazhiyin.com/28425.html#m

介绍

微服务是最近比较火的概念，而微服务框架目前主流的有Dubbo和Spring Cloud，两者都是为了解决微服务遇到的各种问题而产生的，即遇到的问题是一样的，但是解决的策略却有所不同，所以这2个框架经常拿来比较。没用过Dubbo的小伙伴也不用担心，其实Dubbo还是比较简单的，看完本文你也能掌握一个大概，重要的不是代码，而是思想。

Dubbo实现服务调用是通过RPC的方式，即客户端和服务端共用一个接口(将接口打成一个jar包，在客户端和服务端引入这个jar包)，客户端面向接口写调用，服务端面向接口写实现，中间的网络通信交给框架去实现，想深入了解的看推荐阅读。原文链接有代码GitHub地址

使用入门

服务提供者

定义服务接口

public interface DemoService {String sayHello(String name);
}

在服务提供方实现接口

public class DemoServiceImpl implements DemoService {@Overridepublic String sayHello(String name) {return "Hello " + name;}
}

用 Spring 配置声明暴露服务

provider.xml（省略了beans标签的各种属性）

<?xml version="1.0" encoding="UTF-8"?>
<beans><!-- 当前项目在整个分布式架构里面的唯一名称，用于计算依赖关系 --><dubbo:application name="helloworld-app"  /><!--dubbo这个服务所要暴露的服务地址所对应的注册中心，N/A为不使用注册中心--><dubbo:registry address="N/A"/><!--当前服务发布所依赖的协议；webserovice、Thrift、Hessain、http--><dubbo:protocol name="dubbo" port="20880"/><!--服务发布的配置，需要暴露的服务接口--><dubbo:service interface="com.st.DemoService"ref="demoService"/><!--bean的定义--><bean id="demoService" class="com.st.DemoServiceImpl"/></beans>

加载 Spring 配置

public class Provider {public static void main(String[] args) throws Exception {ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");context.start();System.in.read(); // 按任意键退出}
}

服务消费者

consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans><!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 --><dubbo:application name="consumer-of-helloworld-app"/><dubbo:registry address="N/A"/><!-- 生成远程服务代理，可以和本地bean一样使用demoService --><dubbo:reference id="demoService" interface="com.st.DemoService"url="dubbo://localhost:20880/com.st.DemoService"/></beans>

加载Spring配置，并调用远程服务

public class Consumer {public static void main(String[] args) throws Exception {ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");context.start();// 获取远程服务代理DemoService demoService = (DemoService)context.getBean("demoService");// 执行远程方法String hello = demoService.sayHello("world");// Hello worldSystem.out.println( hello );}
}

这就是典型的点对点的服务调用。当然我们为了高可用，可以在consumer.xml中配置多个服务提供者，并配置响应的负载均衡策略

配置多个服务调用者在comsumer.xml的标签的url属性中加入多个地址，中间用分号隔开即可配置负载均衡策略在comsumer.xml的标签中增加loadbalance属性即可，值可以为如下四种类型

  1. RoundRobin LoadBalance，随机，按权重设置随机概率。
  2. RoundRobin LoadBalance，轮询，按公约后的权重设置轮询比率。
  3. LeastActive LoadBalance，最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差。
  4. ConsistentHash LoadBalance，一致性 Hash，相同参数的请求总是发到同一提供者。
<dubbo:reference id="demoService" interface="com.st.DemoService"url="dubbo://192.168.11.1:20880/com.st.DemoService;dubbo://192.168.11.2:20880/com.st.DemoService;dubbo://192.168.11.3:20880/com.st.DemoService"loadbalance="roundrobin"/>

现在整体架构是如下图（假设服务消费者为订单服务，服务提供者为用户服务）：

图解Dubbo和ZooKeeper是如何协同工作的？

这样会有什么问题呢？

  1. 当服务提供者增加节点时，需要修改配置文件
  2. 当其中一个服务提供者宕机时，服务消费者不能及时感知到，还会往宕机的服务发送请求

这个时候就得引入注册中心了

注册中心

Dubbo目前支持4种注册中心,（multicast zookeeper redis simple） 推荐使用Zookeeper注册中心，本文就讲一下用zookeeper实现服务注册和发现（敲黑板，又一种zookeeper的用处），大致流程如下

图解Dubbo和ZooKeeper是如何协同工作的？

现在我们来看Dubbo官网对Dubbo的介绍图，有没有和我们上面画的很相似

图解Dubbo和ZooKeeper是如何协同工作的？

节点角色说明

节点角色说明
Provider暴露服务的服务提供方
Consumer调用远程服务的服务消费方
Registry服务注册与发现的注册中心
Monitor统计服务的调用次数和调用时间的监控中心
Container服务运行容器

调用关系说明

  1. 服务容器负责启动（上面例子为Spring容器），加载，运行服务提供者。
  2. 服务提供者在启动时，向注册中心注册自己提供的服务。
  3. 服务消费者在启动时，向注册中心订阅自己所需的服务。
  4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
  5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
  6. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

要使用注册中心，只需要将provider.xml和consumer.xml更改为如下

<!--<dubbo:registry address="N/A"/>-->
<dubbo:registry protocol="zookeeper" address="192.168.11.129:2181"/>

如果zookeeper是一个集群，则多个地址之间用逗号分隔即可

<dubbo:registry protocol="zookeeper" address="192.168.11.129:2181,192.168.11.137:2181,192.168.11.138:2181"/>

把consumer.xml中配置的直连的方式去掉

<!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
<!--<dubbo:reference id="demoService" interface="com.st.DemoService"--><!--url="dubbo://localhost:20880/com.st.DemoService"/>--><dubbo:reference id="demoService" interface="com.st.DemoService"/>

注册信息在zookeeper中如何保存？

启动上面服务后，我们观察zookeeper的根节点多了一个dubbo节点及其他，图示如下

图解Dubbo和ZooKeeper是如何协同工作的？

最后一个节点中192.168.1.104是小编的内网地址，你可以任务和上面配置的localhost一个效果，大家可以想一下我为什么把最后一个节点标成绿色的。没错，最后一个节点是临时节点，而其他节点是持久节点，这样，当服务宕机时，这个节点就会自动消失，不再提供服务，服务消费者也不会再请求。如果部署多个DemoService，则providers下面会有好几个节点，一个节点保存一个DemoService的服务地址

其实一个zookeeper集群能被多个应用公用，如小编Storm集群和Dubbo配置的就是一个zookeeper集群，为什么呢？因为不同的框架会在zookeeper上建不同的节点，互不影响。如dubbo会创建一个/dubbo节点，storm会创建一个/storm节点，如图

图解Dubbo和ZooKeeper是如何协同工作的？

zookeeper相关介绍

Zookeeper 是 Apacahe Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为 Dubbo 服务的注册中心，工业强度较高，可用于生产环境，并推荐使用。

/user-guide/images/zookeeper.jpg

流程说明：

  • 服务提供者启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入自己的 URL 地址
  • 服务消费者启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者 URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址
  • 监控中心启动时: 订阅 /dubbo/com.foo.BarService 目录下的所有提供者和消费者 URL 地址。

支持以下功能：

  • 当提供者出现断电等异常停机时，注册中心能自动删除提供者信息
  • 当注册中心重启时，能自动恢复注册数据，以及订阅请求
  • 当会话过期时，能自动恢复注册数据，以及订阅请求
  • 当设置 <dubbo:registry check="false" /> 时，记录失败注册和订阅请求，后台定时重试
  • 可通过 <dubbo:registry username="admin" password="1234" /> 设置 zookeeper 登录信息
  • 可通过 <dubbo:registry group="dubbo" /> 设置 zookeeper 的根节点，不设置将使用无根树
  • 支持 * 号通配符 <dubbo:reference group="*" version="*" />，可订阅服务的所有分组和所有版本的提供者

Dubbo相关介绍

  1. Dubbo是什么？

    Dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。简单的说，dubbo就是个服务框架，如果没有分布式的需求，其实是不需要用的，只有在分布式的时候，才有dubbo这样的分布式服务框架的需求，并且本质上是个服务调用的东东，说白了就是个远程服务调用的分布式框架（告别Web Service模式中的WSdl，以服务者与消费者的方式在dubbo上注册）
    其核心部分包含:

    1. 远程通讯: 提供对多种基于长连接的NIO框架抽象封装，包括多种线程模型，序列化，以及“请求-响应”模式的信息交换方式。
    2. 集群容错: 提供基于接口方法的透明远程过程调用，包括多协议支持，以及软负载均衡，失败容错，地址路由，动态配置等集群支持。
    3. 自动发现: 基于注册中心目录服务，使服务消费方能动态的查找服务提供方，使地址透明，使服务提供方可以平滑增加或减少机器。
  2. Dubbo能做什么？
    1. 透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。
    2. 软负载均衡及容错机制，可在内网替代F5等硬件负载均衡器，降低成本，减少单点。
    3. 服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。

Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。

转载于:https://www.cnblogs.com/iisme/p/10620125.html

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Flink学习（二）Flink中的时间

Flink学习（二）Flink中的时间

摘自Apache Flink官网 最早的streaming 架构是storm的lambda架构 分为三个layer batch layerserving layerspeed layer一、在streaming中Flink支持的通知时间 Flink官网写了个了解streaming和各种时间的博客 https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-1…
阅读更多...
RSS阅读器使用：ROME，Spring MVC，嵌入式Jetty

RSS阅读器使用：ROME，Spring MVC，嵌入式Jetty

在这篇文章中&#xff0c;我将展示一些创建Spring Web应用程序的准则&#xff0c;使用Jetty以及使用名为ROME的外部库运行RSS来运行它。 一般 我最近创建了一个示例Web应用程序&#xff0c;充当RSS阅读器。 我想检查ROME以阅读RSS。 我还想使用Spring容器和MVC创建最简单的视图…
阅读更多...
HZOJ string

HZOJ string

正解炸了…… 考试的时候想到了正解&#xff0c;非常高兴的打出来了线段树&#xff0c;又调了好长时间&#xff0c;对拍了一下发现除了非常大的点跑的有点慢外其他还行。因为复杂度算着有点高…… 最后正解死于常数太大……旁边的lyl用同样的算法拿了90分我却拿了个暴力的分40……
阅读更多...
Unity3D入门其实很简单

Unity3D入门其实很简单

在上次发布拙作后&#xff0c;有不少童鞋询问本人如何学习Unity3D。本人自知作为一名刚入门的菜鸟&#xff0c;实在没有资格谈论这么高大上的话题&#xff0c;生怕误导了各位。不过思来想去&#xff0c;决定还是写一些自己的经验&#xff0c;如果能给想要入门U3D的您一些启发&a…
阅读更多...
4. HTML表单标签

4. HTML表单标签

表单是网页中最常见的元素&#xff0c;也是用户和我们交互的重要手段&#xff0c;在网站中的登录、注册、信息更新这些功能都是依赖表单实现的。在HTML中对于表单提供了一系列的标签&#xff0c;即输入框、下拉框、按钮、文本域&#xff0c;如下是一个最常见的表单结构内容&…
阅读更多...
为Lucene选择快速唯一标识符（UUID）

为Lucene选择快速唯一标识符（UUID）

大多数使用Apache Lucene的搜索应用程序都会为每个索引文档分配唯一的ID&#xff08;即主键&#xff09;。 尽管Lucene本身不需要这样做&#xff08;它可能不太在乎&#xff01;&#xff09;&#xff0c;但应用程序通常需要它以后通过其外部ID替换&#xff0c;删除或检索该文档…
阅读更多...
ubuntu16.04设置静态ip

ubuntu16.04设置静态ip

最近在课堂上&#xff0c;有很多同学反映在搭建环境的时候&#xff0c;虚拟机ip经常变&#xff0c;那么我们配置好的web服务可能就不能用了。下面讲一下如何在ubuntu上面设置静态ip 1&#xff1a;首先我们确认一下ubuntu的版本 cat /etc/issue 或者sudo lsb_release -a或者unam…
阅读更多...
Maven常用的构建命令

Maven常用的构建命令

Maven常用命令&#xff1a; Maven库&#xff1a; http://repo2.maven.org/maven2/ Maven依赖查询&#xff1a; http://mvnrepository.com/ 一&#xff0c;Maven常用命令&#xff1a; 1. 创建Maven的普通Java项目&#xff1a; mvn archetype:create-DgroupIdpackageName-Dartifa…
阅读更多...
课时85.层叠性（掌握）

课时85.层叠性（掌握）

1.什么是层叠性&#xff1f; 层叠性就是CSS处理冲突的一种能力。 这个字体最终会变为红色 注意点&#xff1a; 层叠性只有在多个选择器选中“同一个标签”,然后又设置了“相同的属性”&#xff0c;才会发生层叠性。 CSS全称&#xff1a;Cascading StyleSheet 层叠样式表&am…
阅读更多...
SetProcessWorkingSetSize减少内存占用

SetProcessWorkingSetSize减少内存占用

系统启动起来以后&#xff0c;内存占用越来越大&#xff0c;使用析构函数、GC.Collect什么的也不见效果&#xff0c;后来查了好久&#xff0c;找到了个办法&#xff0c;就是使用 SetProcessWorkingSetSize函数。这个函数是Windows API 函数。下面是使用的方法&#xff1a;[Syst…
阅读更多...
Spring Boot 与消息 （JMS、AMQP、RabbitMQ）

Spring Boot 与消息 （JMS、AMQP、RabbitMQ）

RabbitMQ教程 - 鸟哥的专栏 - CSDN博客 一、概述 大多应用中&#xff0c;可通过消息服务中间件来提升系统异步通信、扩展解耦能力消息服务中两个重要概念&#xff1a;消息代理&#xff08;message broker)和目的地&#xff08;destination) 当消息发送者发送消息以后&#xff0…
阅读更多...
JavaOne 2014 –有关提交的一些初步分析

JavaOne 2014 –有关提交的一些初步分析

这些天时间不多了。 并行发生的事情如此之多&#xff0c;当然&#xff0c;最重要的Java会议就是一切。 JavaOne 2014已经关闭了CfP门&#xff0c;投票正在进行中。 程序委员会几乎没有什么可以谈论的&#xff0c;但是去年跳过了这种分析之后&#xff0c;现在是我该寻求许可的时…
阅读更多...
【译】XNA Shader 程序设计（二）

【译】XNA Shader 程序设计（二）

XNA Shader 程序设计 教程2 - 漫反射 大家好&#xff0c;今天我们将在教程一的基础上继续学习&#xff0c;在光照算式中加上漫反射光。 漫反射光 环境光计算等式为&#xff1a; I Aintensity * Acolor 漫反射基于这个等式&#xff0c;添加了一道有方向的光线&#xff1a; I A…
阅读更多...
A股滚动净利润增速最高排名

A股滚动净利润增速最高排名

最近2年&#xff08;共8个季度&#xff09;的滚动净利润都在增长&#xff0c;且平均增速超过10%。 计算举例&#xff1a;滚动净利润增速 ((2018Q1 到 2018Q4的净利润之和) / (2017Q4 到 2018Q3的净利润之和) -1) * 100%。 预测下季度&#xff1a;依据以往的增速&#xff0c;进…
阅读更多...
Java 8 Friday：让我们弃用那些旧版库

Java 8 Friday：让我们弃用那些旧版库

在Data Geekery &#xff0c;我们喜欢Java。 而且&#xff0c;由于我们真的很喜欢jOOQ的流畅的API和查询DSL &#xff0c;我们对Java 8将为我们的生态系统带来什么感到非常兴奋。 Java 8星期五 每个星期五&#xff0c;我们都会向您展示一些不错的教程风格的Java 8新功能&#…
阅读更多...
Educational Codeforces Round 10

Educational Codeforces Round 10

652A - Gabriel and Caterpillar 20171128 按题意模拟即可 #include<stdlib.h> #include<stdio.h> #include<math.h> #include<cstring> #include<iostream> #include<algorithm> using namespace std; int h1,h2,a,b,ans1; int main()…
阅读更多...
内存不足：杀死进程或牺牲孩子

内存不足：杀死进程或牺牲孩子

现在是早上6点。 我清醒地总结了导致我太早醒来的电话的事件序列。 这些故事开始时&#xff0c;我的电话警报响了。 困倦而脾气暴躁的我检查了电话&#xff0c;看我是否真的疯了以至于无法在凌晨5点设置唤醒警报。 不&#xff0c;这是我们的监视系统&#xff0c;表明Plumbr服务…
阅读更多...
将Array、Dictionary等集合类的序列化和反序列化

将Array、Dictionary等集合类的序列化和反序列化

Objective-C的集合类序列化到文件中或者从文件中反序列化其实很简单&#xff0c;请看下面的示例代码&#xff1a; NSArray *array [NSArray arrayWithObjects:"Hefeweizen", "IPA", "Pilsner", "Stout", nil];NSDictionary *dictiona…
阅读更多...
职场交流：一位软件工程师的7年总结

职场交流：一位软件工程师的7年总结

2009年05月13日15:06　　来源&#xff1a;1、分享第一条经验&#xff1a;“学历代表过去、能力代表现在、学习力代表未来。”其实这是一个来自国外教育领域的一个研究结果。相信工作过几年、十几年的朋友 对这个道理有些体会吧。但我相信这一点也很重要&#xff1a;“重要的道理…
阅读更多...
JavaFX 8u20天的未来过去（始终在最前面）

JavaFX 8u20天的未来过去（始终在最前面）

自从我发布有关JavaFX的主题以来已经有很长时间了。 因此&#xff0c;如果您仍在追随&#xff0c;那就太棒了&#xff01; 介绍 在这篇博客文章中&#xff0c;我想写一篇关于从JavaFX 8 update 20开始的非常酷的功能的博客&#xff0c;该功能使您的应用程序始终位于其他应用程…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023