IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> 带你了解Apache Dubbo -> 正文阅读

[大数据]带你了解Apache Dubbo


一、Dubbo概述

1、什么是RPC?

在了解Dubbo之前,先来认识一下什么是RPC?
RPC全称为remote procedure call,即远程过程调用,比如现在我有两台服务器A和B,分别都部署着一个任务,A服务器上的应用想调用B服务器上的应用提供的方法,由于两个应用不 在一个内存空间,不能直接调用,所以需要通过远程调用来表达调用的语义和传达调用的数据。RPC是一个泛化的概念,严格来说一切远程过程调用手段都属于RPC范畴。其中Dubbo就是基于。

2、Dubbo简述

Apache Dubbo是一款高性能的Java RPC框架。其前身是阿里巴巴公司开源的、轻量级的开源Java RPC 框架,可以和Spring框架无 缝集成,2018年阿里巴巴把这个框架捐献给了apache基金会。
Dubbo提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。

3、Dubbo的架构

下面这个图是Dubbo官方提供:
在这里插入图片描述
名词解释:
Provider:暴露服务的服务提供方
Consumer:调用远程服务的服务消费方
Registry:服务注册与发现的注册中心
Monitor:统计服务的调用次数和调用时间的监控中心
Container:服务运行容器

调用过程
0.服务容器服务启动,加载,运行服务提供者(我这里的服务容器指spring容器)
1.服务提供者在启动时,向注册中心注册自己提供的服务
2.服务消费者在启动时,向注册中心订阅自己所需的服务
3.注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于产连接的方式推送变更数据给消费者。
4.服务消费者,从提供地址列表中,基于软负载均衡算法(默认是随机算法),选一台提供者进行调用,如果调用失败,再选另一台调用。
5.服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中 心。

上面这个图中:
虚线都是异步访问,实线都是同步访问 蓝色虚线:在启动时完成的功能 红色虚线(实线)都是程序运行过 程中执行的功能

上面我们已经知道Dubbo是由那几部分组成,下面一一详细分析

二、服务注册中心Zookeeper

1、zookeeper的介绍

通过前面的Dubbo架构图可以看到,Registry(服务注册中心)在其中起着至关重要的作用。Dubbo官 方推荐使用Zookeeper作为服务注册中心。
Zookeeper 是 Apache Hadoop 的子项目,是一个树型的目录服务,支持变更推送,适合作为 Dubbo 服务的注册中心,工业强度较高,可用于生产环境,并推荐使用 。

Zookeeper树型目录服务:
在这里插入图片描述

流程说明:
1、服务提供者(Provider)启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入自己的
URL 地址/
2、服务消费者(Consumer)启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址/
3、监控中心(Monitor)启动时: 订阅 /dubbo/com.foo.BarService 目录下的所有提供者和消费者URL 地址

2、安装Zookeeper 并启动

下载地址:http://archive.apache.org/dist/zookeeper/
我这里使用的3.4.6 下载完解压之后,因为我们面对的问题是两个服务A和B不是在同一个本地,是在两台不同的服务器里,所以我们要搭建一个虚拟机,来充当我们的Zookeeper服务器,来让服务注册到这个服务中心,然后消费者在来到这个Zookeeper服务器找服务,这有点像个中间人。按如下步骤操作:
在这里插入图片描述

3、Dubbo管理控制台

1、先在晚上找一个dubbo-admin-2.6.0.war 文件和准一个tomcat
我在下面的服务提供方代码链接中有这个文件,其中dubbo-admin-2.6.0.war 我已经存放在tomcat下的webapp
2.修改dubbo-admin-2.6.0.war下的WEB-INF下的dubbo.properties文件,注意dubbo.registry.address对应的值需要对应当前 使用的Zookeeper的ip地址和端口号 :
dubbo.registry.address=zookeeper://192.168.134.129:2181 dubbo.admin.root.password=root dubbo.admin.guest.password=guest在这里插入图片描述

4.重启tomcat
5.操作步骤

这个示例是spring+Dubbo的结合

4、创建服务提供方

服务提供方的代码放到了这个里:服务提供方代码

5、创建服务消费方

服务消费方的代码放到了这个里:服务消费方代码

总结:

我们先是在虚拟机开启zookeeper,并连接本地(如果没有写连接的ip和端口号,默认是连接本地)。在服务提供方这边,先设置web.xml文件,主要是配置配置ContextLoaderListener监听器来部署加载spring配置文件,产生spring容器。在这个容器中,我们进行private提供方服务的部署,那怎么部署呢,先是创建服务接口,然后写服务的实现类。实现类就是该服务的具体服务方法,并且可以在该实体类上通过注解@Transactional 开启事务管理,在类上的@Service注解中,通过protocol设置Dubbo协议(推荐值为dubbo) ,通过interfaceClass = HelloService.class 指定服务的接口类型,解决使用事务管理之后,指定CGLIB代理扫描包的位置,这样才能准确地生成服务代理对象,来给服务消费者调用。
然后再applicationContext-service.xml中,我们主要配置(.当前服务应用名称、连接服务注册中心即Zookeeper的ip和端口号、指定该服务提供方的注册的协议和端口号、扫描指定包(是为了加入@Service注解的类会被发布为dubbo的服务) 、设置事务管理器、开启注解事务管理 )

然后再服务消费方,先要有一个服务提供发的方法的接口类。在他的控制器类中通过@Reference注解 调用helloService接口的远程代理对象进行调用


**一句话总结:提供方通过扫描将服务放进spring容器中,并注册到注册中心,消费者就通过远程代理对象访问服务。**
  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-10-15 11:51:47  更:2021-10-15 11:52:48 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 1:15:18-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码