栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

dubbo从入门到实战

dubbo从入门到实战

这里写自定义目录标题
  • 分布式基础理论
    • 应用架构及发展演变

分布式基础理论

Dubbo是用于分布式系统的框架所以我们要先了解什么是分布式
分布式系统是若干独立 计算机的集合,这些计算机对于用户来说就像单个相关系统。

老式系统(单一应用架构)就是把一个系统,统一放到一个服务器当中然后每一个服务器上放一个系统,如果说要更新代码的话,每一个服务器上的系统都要重新去部署十分的麻烦。

而分布式系统就是将一个完整的系统拆分成多个不同的服务,然后在将每一个服务单独的放到一个服务器当中。

应用架构及发展演变

**ORM
单一应用架构:**一个项目装到一个服务器当中,也可以运行多个服务器每一个服务器当中都装一个项目。
缺点:1.如果要添加某一个功能的话就要把一个项目重新打包,在分别部署到每一个服务器当中去。2.如果后期项目越来越大的话单台服务器跑一个项目压力会很大的。会不利于维护,开发和程序的性能。

**MVC
垂直应用架构:**将应用切割成几个互不相干的小应用,在将每个小应用独立放到一个服务器上,如果哪一个应用的访问数量多就多加几台服务器

分布式服务架构

RPC简介
分布式应用架构(远程过程调用):当垂直应用越来越多,应用之间交互不可避免,将核心业务抽取出来,作为独立的服务,逐渐形成稳定的服务中心,使前端应用能更快速的响应多变的市场需求。

什么叫RPC

  1. RPC [ Remote Procedure Call]是指远程过程调用,是一种进程问通信方式,他是一种技术的思想,而不是规范。它允许程序调用另一个地址空间(通常是共享网络的另一台机器上)的过程或函数,而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数,本质上编写的调用代码基本相同。
  2. RPC(Remote Procedure Call)—远程过程调用,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。也就是说两台服务器A,B,一个应用部署在A服务器上,想要调用B服务器上应用提供的方法,由于不在一个内存空间,不能直接调用,需要通过网络来表达调用的语义和传达调用的数据。
    RPC工作原理
    1. Client像调用本地服务似的调用远程服务;
    2. Client stub接收到调用后,将方法、参数序列化
    3. 客户端通过sockets将消息发送到服务端
    4. Server stub 收到消息后进行解码(将消息对象反序列化)
    5. Server stub 根据解码结果调用本地的服务
    6. 本地服务执行(对于服务端来说是本地执行)并将结果返回给Server stub
    7. Server stub将返回结果打包成消息(将结果消息对象序列化)
    8. 服务端通过sockets将消息发送到客户端
    9. Client stub接收到结果消息,并进行解码(将结果消息发序列化)
    10. 客户端得到最终结果。

RPC 调用分以下两种:
**同步调用:**客户方等待调用执行完成并返回结果。
**异步调用:**客户方调用后不用等待执行结果返回,但依然可以通过回调通知等方式获取返回结果。若客户方不关心调用返回结果,则变成单向异步调用,单向调用不用返回结果。

RPC步骤解析

SOA
流动计算架构:在分布式应用架构的基础上增加了一个调度、治理中心基于访问压力实时管理集群容量、提高集群的利用率,用于提高机器利用率的 资源调度和治理中心(SOA) 是关键 (不浪费计算机资源)

Dubbo 是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,服务自动注册和发现。分布式系统是将一个系统拆分为多个不同的服务

Dubbo特性一览

dubbo设计架构

该图来自Dubbo官网,描述了服务注册中心、服务提供方、服务消费方、服务监控中心之间的调用关系。

服务提供者(Provider):暴露服务的服务提供方,服务提供者在启动时,向注册中心注册自己提供的服务。
服务消费者(Consumer): 调用远程服务的服务消费方,服务消费者在启动时,向注册中心订阅自己所需的服务,服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
注册中心(Registry):注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
监控中心(Monitor):服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。

Dubbo的特性
(1)服务注册中心

相比Hessian类RPC框架,Dubbo有自己的服务中心, 写好的服务可以注册到服务中心, 客户端从服务中心寻找服务,然后再到相应的服务提供者机器获取服务。通过服务中心可以实现集群、负载均衡、高可用(容错) 等重要功能。
服务中心一般使用zookeeper实现,也有redis和其他一些方式。以使用zookeeper作为服务中心为例,服务提供者启动后会在zookeeper的/dubbo节点下创建提供的服务节点,包含服务提供者ip、port等信息。服务提供者关闭时会从zookeeper中移除对应的服务。
服务使用者会从注册中心zookeeper中寻找服务,同一个服务可能会有多个提供者,Dubbo会帮我们找到合适的服务提供者,也就是针对服务提供者的负载均衡。
(2)负载均衡

当同一个服务有多个提供者在提供服务时,客户端如何正确的选择提供者实 现负载均衡呢?dubbo也给我们提供了几种方案:
random 随机选提供者,并可以给提供者设置权重
roundrobin 轮询选择提供者
leastactive 最少活跃调用数,相同活跃数的随机,活跃数:指调用前后计数差。使慢的提供者收到更少请求,因为越慢的提供者的调用前后计数差会越大。
consistenthash 一致性hash,相同参数的请求发到同一台机器上。
(3)简化测试,允许直连提供者
在开发阶段为了方便测试,通常系统客户端能指定调用某个服务提供者,那么可以在引用服务时加一个url参数去指定服务提供者。 配置如下:

 

(4)服务版本,服务分组
在Dubbo配置文件中可以通过制定版本实现连接制定提供者,也就是通过服务版本可以控制服务的不兼容升级;当同一个服务有多种实现时,可以使用服务分组进行区分。

dubbo环境搭建 ZooKeeper注册中心
搭建zookeeper注册中心环境
Dubbo官方文档: http://dubbo.apache.org/en-us/docs/user/quick-start.html
在zookeeper官网下载zookeeper
http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.14/

在bin文件下,启动zkServer.cmd会有报错,处理需要在condif文件中将zoo_sample.cfg文件复制一份,将名字改为zoo.cfg。
在zookeeper的文件夹下创建data文件夹,打开zoo.cfg,修改datadir,将dataDir数据保存为我们自定义的文件中(此步骤可省略)

配置完毕后,我们再次在conf下启动zkServer.cmd,这次可以成功启动

继续运行zkCli.cmd,可以连接到zookeeper的服务器。

此时,我们zookeeper的注册中心及环境以及搭建完毕。

zookeeper监控中心的配置
1、下载dubbo-admin

dubbo-admin下载地址 :https://github.com/apache/dubbo-admin/tree/master

2、解压后进入目录修改指定zookeeper地址
进入如下地址:dubbo-admin-masterdubbo-adminsrcmainresourcesapplication.properties"
将zookeeper的监控中心的地址配置为本地端口

#注册中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181


配置完毕后,我们在dubo-zookeeperdubbo-admin-masterdubbo-admin文件夹下cmd打包测试下。

mvn clean package

在target文件中打包完成的jar包

cmd命令 java -jar dubbo-admin-0.0.1-SNAPSHOT.jar 运行打包好的jar包
启动成功后,可以看到一个7001的端口

此时我们的zookeeper的服务都为启动状态,在浏览器中访问 localhost:7001,访问到注册中心,输入账号密码root。

此时,我们zookeeper监控中心的配置完成。注意,要访问到监控中心,一定要启动zookeeper注册中心的启动类

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/355061.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号