博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
简述Dubbo
阅读量:5867 次
发布时间:2019-06-19

本文共 7683 字,大约阅读时间需要 25 分钟。

  目前处于实习期间,白天工作,网上自主学习。最近没事逛了一下当前招聘网上的招聘要求,其中dubbo这个关键字出现的比较多,因此花了点时间学习了一番,在这写写自己的理解。

 说起Dubbo,得先聊聊RPC,如果说互联网架构师互联网行业标配,那么RPC技术是分布式架构的基石

一、什么是RPC

  RPC是指RPC协议:定义了rpc实现的规范,核心过程包括了客户端和服务端的通讯协议,寻址,数据序列化/反序列化,http,dubbo-rpc都属于rpc的一种协议

  RPC框架:对上述核心过程进行了封装,不需要开发人员自己去定义协议,实现序列化的细节工作,这样的组件成为RPC框架。

  常见RPC框架有thrift、GRpc、dubbo、motan

  其中:客户端如果想调用服务端

  通讯协议:TCP/UDP

  寻址:程序需要通过异性方式,才能知道服务端的IP+PORT号

  序列化:数据在网络中传输需要一定的格式

二、架构历史

      随着网络时代更新换代,其中所涉及的技术也是随着时间日益变化,当然这也包含我们做项目时所利用到的框架。

      1、单一架构。刚开始时,我们采用的是单一架构,这也是刚入门的小伙伴所钟爱的架构,其项目中所涉及到的内容都统一部署在一起,无需要分层的思想。当然此仅仅局限于简单的增删改查 。

    2、垂直架构。当数据访问比较大时,简单的单一架构已经远远无法满足需求,垂直架构将应用拆分成互不相干的应用,以此来提高效率,这大大的增加前端页面开发的效率,减少机器的负担。

      3、MVC架构。当项目数据较多时,维护成本也就增大,MVC模式就尤其显得格外重要。MVC即model、view、controller,其将功能的各部分划分出来,同种功能放在同一包下。

      4、分布式架构。垂直应用越来越多时,各个应用之间的交互不可避免。此时将核心业务抽取出来,形成独立的服务,利用分布式缓存技术调用控制层来调用这些业务逻辑,以达到代码重构。这就是所谓的SOA(面向服务架构)思想。如下订单可以将其抽取出来,以达到服务共享。

三、什么是Dubbo

      按我的理解,Dubbo是一个分布式框架,他出现的目的是为了提高性能和透明化的RPC远程服务调用方案,SOA服务治理方案。其本质是一个服务调用,一个远程调用的分布式框架。其核心部分包含为:

      1、远程通讯:提供多种基于长连接的NIO框架抽象封装。

      2、集群容错:提供基于接口方法的透明远程调用,包含软负载均衡、失败容错、地址路由、动态配置等集群支持。

      3、自动发现:基于注册中心目录服务,使服务消费方能动态查找服务提供方。

  Dubbo局限

 dubbo适合小数据量大并发的服务调用,以及消费者机器远大于生产者机器数的情况,不适合传输大数据量的服务比如文件、视频等,除非请求量很低

 

四、dubbo框架流程图

 

  dubbo流程图分为四大角色,依次为生产者,消费者,注册中心以及监控中心。

  生成者:提供服务,即提供方法接口。

  注册中心:生产者将每个服务的功能的注册到注册中心,每次有新服务的更新都会注册到注册中心,往其添加一个节点。其用Zk:(zookeeper,像树)作为注册中心,除此之外还可以用redis做,但是不推荐。

  消费者:消费者与注册中心相连接,称之为订阅。一旦有新的服务,注册中心就会将结果返回通知消费者(zookeeper当中有一个事件通知,一旦节点有变化,就会通知客户端),消费者一旦收到,就notify可以进行调用消费者中的服务(即调用接口)。

      监控中心:做消费记录,如监控消费者有没有订阅成功,以及有没有记录日志等。至于为什么redis也能作为注册中心,是因为他里面也有一个watch监控。

五、就负载均衡而言,关于nginx和dubbo的区别

  dubbo的负载均衡已经是服务层面的了,和nginx的负载均衡还在http请求层面完全不同。至于二者哪个优秀,当然没办法直接比较。

涉及到负载均衡就涉及到你的业务,根据业务来选择才是最适合的。
dubbo具备了server注册,发现、路由、负载均衡的功能,在所有实现了这些功能的服务治理组件中,个人觉得dubbo还是略微笨重了,因为它本身是按照j2EE范畴所制定的中规中矩的服务治理框架。
  dubbo在服务发现这个地方做的更像一个dns,一个消费者需要知道哪里有这么一个服务,dubbo告诉他,然后他自己去调用。
nginx在具备了以上功能,还有两个最主要的功能是,1,维持尽可能多的连接。2,把每个连接的具体服务需求pass到真正的worker上。
但是这两个功能,dubbo做不到第一个。
所以,结合你自己的业务来选择用什么,nginxdubbo在使用上说白了就是一个先后的关系而已。

总结:

nginx是横在用户的浏览器和自家的服务器之间。

dubbo是横在自家的服务器和自家的服务器之间啊,是利用zookeeper的持久节点来保存信息。

六、快速入门

  需要建立三个maven工程,分别为接口、消费者和生产者

  1、先构建接口和生产者项目,并将接口的依赖注入到生产者pom文件(打开interface接口pom文件,将其依赖信息写进providerpom文件)

  

  相关依赖代码

com.itmayie.du
Member-interface
0.0.1-SNAPSHOT
com.alibaba
dubbo
2.5.6
com.github.sgroschupf
zkclient
0.1

  2、会员接口提供定义接口方法

  

//会员服务 提供接口public interface UserService {    //使用用户UserID查询用户信息    public String getUser(int id);}

  3、生产者提供实现类

public class UserServiceImpl implements UserService{    public String getUser(int id) {        System.out.println("会员服务接受订单服务ID"+id);        if(id==1){            return "yiling";        }        if(id==2){            return "jiaxianseng";        }        return "未找到...";    }}

  4、生产者编写spring配置文件,用于注入dubbo和zookeeper和实现类,暴露自己服务

  5、启动zookeeper

[oracle@bogon bin]$ pwd/usr/java/zookeeper-3.4.12/bin[oracle@bogon bin]$ ./zkServer.sh startZooKeeper JMX enabled by defaultUsing config: /usr/java/zookeeper-3.4.12/bin/../conf/zoo.cfgStarting zookeeper ... already running as process 3579.[oracle@bogon bin]$ ./zkCli.sh[zk: localhost:2181(CONNECTED) 7] ls /[zookeeper]

  6、测试连接zookeeper

//加载配置文件        ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("provider.xml");        applicationContext.start();        System.out.println("会员服务启动成功");        //保证服务一直启动,按任意键可以停止        System.in.read();

  如果此时在开启的zookeeper客户端根节点看到新生成的节点说明连接成功

  控制台:

log4j:WARN No appenders could be found for logger (org.springframework.core.env.StandardEnvironment).log4j:WARN Please initialize the log4j system properly.会员服务启动成功

  zookeeper:

[zk: localhost:2181(CONNECTED) 8] ls /[dubbo, zookeeper][zk: localhost:2181(CONNECTED) 9] ls2 /dubbo[com.dubbo.service.UserService]

  7、编写消费者

  1) pom文件引入接口、dubbo、zookeepre依赖

Member-Interface
Member-Interface
0.0.1-SNAPSHOT
com.alibaba
dubbo
2.5.6
com.github.sgroschupf
zkclient
0.1

  2) 编写消费者spring配置文件,接收生成者方法

  3) 编写调用测试类

public class OrderService {    public static void main(String[] args) {        ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext("consumer.xml");        applicationContext.start();        System.out.println("订单服务启动成功..");        UserService userService=(UserService) applicationContext.getBean("userService");        System.out.println("订单服务调用会员服务开始");        String result=userService.getUser(1);        System.out.println("订单服务调用会员服务结束..result"+result);        System.in.read();            }}

  注意:测试时要开启zookeeper,先启动生产者,再开启消费者,顺序不能错

  显示结果:

  消费者控制台:

log4j:WARN No appenders could be found for logger (org.springframework.core.env.StandardEnvironment).log4j:WARN Please initialize the log4j system properly.会员服务启动成功会员接受订单,ID号为1

  消费者控制台:

log4j:WARN No appenders could be found for logger (org.springframework.core.env.StandardEnvironment).log4j:WARN Please initialize the log4j system properly.订单服务启动结果是yiling

七、关于dubbo所支持的协议

  Dubbo协议、rmi协议、hession协议、http协议

八、关于dubbo-admin平台

  dubbo-admin平台是用来管理duddo的客户端,是一个可视化的dubbo平台界面,在其平台下,你可以调制各种参数。以下为dubbo-admin使用。

  1、下载dubbo-admin

  官网:

  2、将dubbo-admin.war进行解压,将解压的内容放在tomcat下的webapp目录中的ROOT目录(先清空原ROOT下的文件),这里我是放在的linux环境下的tomcat下

[root@bogon ROOT]# pwd/usr/java/tomcat/tomcat/webapps/ROOT[root@bogon ROOT]# ll总用量 20-rw-r--r--. 1 root root  101 3月  31 2015 crossdomain.xmldrwxr-xr-x. 2 root root   54 6月   4 18:42 css-rw-r--r--. 1 root root 1406 3月  31 2015 favicon.icodrwxr-xr-x. 2 root root 4096 6月   4 18:42 imagesdrwxr-xr-x. 2 root root 4096 6月   4 18:42 jsdrwxr-xr-x. 4 root root   51 6月   4 18:42 META-INFdrwxr-xr-x. 2 root root   65 6月   4 18:41 SpryAssetsdrwxr-xr-x. 8 root root 4096 6月   4 18:41 WEB-INF

  3、启动tomcat

[root@bogon bin]# ./startup.sh

  4、输入域名(平常访问tomcat)即可进入dubbo-admin界面

  

  注意用户名和密码是根据dubbo.properties

[root@bogon ROOT]# cd WEB-INF/[root@bogon WEB-INF]# tail -n 5 dubbo.propertiesdubbo.registry.address=zookeeper://127.0.0.1:2181dubbo.admin.root.password=rootdubbo.admin.guest.password=guest

  官方界面如下:

  

九、关于Dubbo集群

模拟两台提供相同服务的接口(集群),可以解决高并发的问题

步骤:

  1. 先更改生产者dubbo的端口号为29014,然后启动生产者
  2. 再更改生产者dubbo的端口号为29015,然后启动生产者
  3. 此时集群环境已经搭建好了,在dubbo控制平台中的服务治理中的提供者中可以看到两个ip地址

 十、关于dubbo的负载均衡 

1、什么是负载均衡:

  负载平衡也称负载共享,是指对系统中的负载情况进行动态调整,以尽量消除或减少系统中各节点负载不均衡的现象。具体实现方法是将过载节点上的任务转移到其他轻载节点上,尽可能实现系统各节点的负载平衡,从而提高系统的吞吐量。负载共享有利于统筹管理分布式系统中的各种资源,便于利用共享信息及其服务机制扩大系统的处理能力。

2、当出现集群的情况下,消费者是怎样实现那台主机的选择呢?
如同nginx一样,dubbo也有负载均衡的策略

  在集群负载均衡时,Dubbo提供了多种均衡策略,缺省为random随机调用。

存在慢的提供者累积请求问题,比如:第二台机器很慢,但没挂,当请求调到第二台时就卡在那,久而久之,所有请求都卡在调到第二台上

解决办法 :结合权重,把第二台机(性能低的)的权重设置低一点

做法
1) 为接口创建负载均衡策略
在服务治理中选择负载均衡

2) 这里我们选择的是随机,也就是消费者会随机选择服务端口,当然可以控制生产者的权重问题来更改获取几率。

十一、关于dubbo容错

当一个节点发生错误时,消费者会采取什么办法?

 Dubbo中自带负载均衡容错,即当一个节点发生错误(如20914节点关闭),由原来连接到20914节点的消费者会自动更改别的节点。 

十二、当所有集群节点的dubbo服务都挂了,即发生了错误,消费者会怎么办?

duboo通过keeopalived脚本监听服务器,如果服务停止掉,自动帮你重启,如果一直重启失败了,发送报警邮箱。

 

 

 

 

 

 

 

 

 

 

 

 

 

  

 

 

   

 

转载于:https://www.cnblogs.com/cailijia52o/p/8023640.html

你可能感兴趣的文章
javascript正则表达式对象方法 compile() exec() test()的比较
查看>>
SQL面试题
查看>>
Android开发之集成新浪微博SDK
查看>>
企业为什么需要上网行为管理
查看>>
字符串反转的5种方法
查看>>
MPLS *** option C
查看>>
嵌入式Linux C语言(二)——指针
查看>>
Java基础学习总结(8)——super关键字
查看>>
listview当选中某一个item时设置背景色其他的不变
查看>>
Eclipse Indigo 3.7 中文字体偏小解决方案: Consolas 微软雅黑混合字体!
查看>>
Hive 0.11 升级踩坑记——HiveServer2的imperson问题
查看>>
Maven学习总结(七)——eclipse中使用Maven创建Web项目
查看>>
Spring MVC常用注解说明
查看>>
CetOS(RHEL) 5.3下网卡绑定设置指南
查看>>
在Javascript中闭包(Closure)
查看>>
omap_hwmod: rtc: doesn't have mpu register target
查看>>
Linux执行ls,会引起哪些系统调用
查看>>
Linux 32位系统支持4G以上内存
查看>>
记录一些有用的代码技巧,不定期更新
查看>>
打造全民健康平台 加速实现智慧医疗
查看>>