Java:分布式RPC框架Apache Dubbo
创始人
2025-05-30 11:27:45
0

目录

  • 一、软件架构的演进过程【了解】
  • 二、Dubbo概述【了解】
    • 1、Dubbo简介
    • 2、Dubb架构
  • 三、服务注册中心Zookeeper
      • 1、 安装
      • 2、 启动&停止
  • 四、Dubbo快速入门
    • 1、服务提供方开发
    • 2、服务消费方开发

一、软件架构的演进过程【了解】

1、单体架构

一个包,包含了应用所有功能的应用程序,我们通常称之为单体应用。
简单理解类比前端,把所有代码写到一个文件里。

2、垂直架构
在这里插入图片描述

按照业务进行切割,形成小的单体项目。
简单理解前端的组件化,但是不同组件仍有重复代码。

3、SOA架构
在这里插入图片描述

将重复功能或模块抽取成组件的形式,对外提供服务,在项目与服务之间使用ESB(企业服务总线)的形式作为通信的桥梁。
简单理解前端的组件化,并且把重复代码【粗略】抽离出来。

4、微服务架构
在这里插入图片描述

和 SOA 架构类似,
微服务架构强调的一个重点是“业务需要彻底的组件化和服务化”。
将系统服务层完全独立出来,抽取为一个一个的微服务。
抽取的粒度更细,遵循单一原则。
简单理解前端的组件化,并且把重复代码【颗粒度更细】抽离出来。

二、Dubbo概述【了解】

1、Dubbo简介

Apache Dubbo是一款高性能的Java RPC框架

什么是RPC?

RPC全称为remote procedure call,即远程过程调用。比如两台服务器A和B,A服务器上部署一个应用,B服务器上部署一个应用,A服务器上的应用想调用B服务器上的应用提供的方法由于两个应用不在一个内存空间,不能直接调用,所以需要通过网络来表达调用的语义和传达调用的数据

Dubbo提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。

2、Dubb架构

在这里插入图片描述
图例说明:

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

调用关系说明:

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

三、服务注册中心Zookeeper

1、 安装

下载地址:http://archive.apache.org/dist/zookeeper/

2、 启动&停止

在这里插入图片描述
需要注意:

Zookeeper在Windows下启动只需要运行zkServer.cmd双击即可(需保证运行环境中正确安装了Java运行环境)

但是在有的时候会出现双击闪退的情况。针对闪退,可按照以下步骤进行解决:
1 、编辑zkServer.cmd文件末尾添加pause 。这样运行出错就不会退出,会提示错误信息,方便找到原因。例如原因如下:
在这里插入图片描述

2、重新双击运行zkServer.cmd
在这里插入图片描述
错误原因 ,找不到zoo.cfg配置文件

3、查看zkEnv.cmd
在这里插入图片描述
4 、增加zoo.cfg文件,如下
在这里插入图片描述
5、 zoo.cfg配置文件介绍

修改dataDir属性值,在上级目录下增加data目录
在这里插入图片描述
6、重新双击zkServer.cmd启动
在这里插入图片描述

四、Dubbo快速入门

Dubbo作为一个RPC框架,其最核心的功能就是要实现跨网络的远程调用。本小节就是要创建两个应用,一个作为服务的提供方,一个作为服务的消费方。通过Dubbo来实现服务消费方远程调用服务提供方的方法。

1、服务提供方开发

开发步骤:

先创建一个dubbodemo的工程。在文件夹下创建提供者和消费者项目。

1、创建maven工程(打包方式为war)dubbodemo_provider,在pom.xml文件中导入如下坐标

war

UTF-8
1.8
1.8
5.0.5.RELEASE


org.springframeworkspring-webmvc${spring.version}

org.springframeworkspring-jdbc${spring.version}

org.springframeworkspring-aspects${spring.version}

org.springframeworkspring-jms${spring.version}

org.springframeworkspring-context-support${spring.version}


com.alibabadubbo2.6.0

org.apache.zookeeperzookeeper3.4.7

com.github.sgroschupfzkclient0.1

javassistjavassist3.12.1.GA

com.alibabafastjson1.2.47



org.apache.maven.pluginsmaven-compiler-plugin2.3.21.81.8org.apache.tomcat.maventomcat7-maven-plugin2.28081/


2、配置web.xml文件

创建 webapp/WEB-INF/web.xml


contextConfigLocationclasspath:applicationContext*.xmlorg.springframework.web.context.ContextLoaderListener

3、创建服务接口

package com.atguigu.service;
public interface HelloService {public String sayHello(String name);
}

4、创建服务实现类

package com.atguigu.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.atguigu.service.HelloService;
@Service
public class HelloServiceImpl implements HelloService {@Overridepublic String sayHello(String name) {return "hello " + name;}
}

注意:服务实现类上使用的 Service 注解是Dubbo提供的,用于对外发布服务

5、在src/main/resources下创建 applicationContext-service.xml




启动服务
在这里插入图片描述

2、服务消费方开发

开发步骤:

1、创建 maven 工程(打包方式为war)dubbodemo_consumerpom.xml 配置和上面服务提供者相同,只需要将 Tomcat 插件的端口号改为8082即可

war

UTF-8
1.8
1.8
5.0.5.RELEASE


org.springframeworkspring-webmvc${spring.version}

org.springframeworkspring-jdbc${spring.version}

org.springframeworkspring-aspects${spring.version}

org.springframeworkspring-jms${spring.version}

org.springframeworkspring-context-support${spring.version}


com.alibabadubbo2.6.0

org.apache.zookeeperzookeeper3.4.7

com.github.sgroschupfzkclient0.1

javassistjavassist3.12.1.GA

com.alibabafastjson1.2.47



org.apache.maven.pluginsmaven-compiler-plugin2.3.21.81.8org.apache.tomcat.maventomcat7-maven-plugin2.28082/


2、配置webapp/WEB-INF/web.xml文件


springmvcorg.springframework.web.servlet.DispatcherServletcontextConfigLocationclasspath:applicationContext-web.xml1springmvc/

3、将服务提供者工程中的HelloService接口复制到当前工程

package com.atguigu.service;
public interface HelloService {public String sayHello(String name);
}

4、编写Controller

package com.atguigu.controller;import com.alibaba.dubbo.config.annotation.Reference;
import com.atguigu.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
@RequestMapping("/demo")
public class HelloController {@Referenceprivate HelloService helloService;@RequestMapping("/hello")@ResponseBodypublic String getName(String name){//远程调用String result = helloService.sayHello(name);System.out.println(result);return result;}
}

注意:Controller中注入HelloService使用的是Dubbo提供的@Reference注解

5、在src/main/resources下创建applicationContext-web.xml




6、启动服务
在这里插入图片描述

7、运行测试

在浏览器输入http://localhost:8082/demo/hello?name=Jack,查看浏览器输出结果

*思考一*:上面的Dubbo入门案例中我们是将HelloService接口从服务提供者工程(dubbodemo_provider)复制到服务消费者工程(dubbodemo_consumer)中,这种做法是否合适?还有没有更好的方式?

答:这种做法显然是不好的,同一个接口被复制了两份,不利于后期维护。更好的方式是单独创建一个maven工程,将此接口创建在这个maven工程中。需要依赖此接口的工程只需要在自己工程的pom.xml文件中引入maven坐标即可。

*思考二*:在服务消费者工程(dubbodemo_consumer)中只是引用了HelloService接口,并没有提供实现类,Dubbo是如何做到远程调用的?

答:Dubbo底层是基于代理技术为HelloService接口创建代理对象,远程调用是通过此代理对象完成的。

*思考三*:上面的Dubbo入门案例中我们使用Zookeeper作为服务注册中心,服务提供者需要将自己的服务信息注册到Zookeeper,服务消费者需要从Zookeeper订阅自己所需要的服务,此时Zookeeper服务就变得非常重要了,那如何防止Zookeeper单点故障呢?

答:Zookeeper其实是支持集群模式的,可以配置Zookeeper集群来达到Zookeeper服务的高可用,防止出现单点故障。

相关内容

热门资讯

linux入门---制作进度条 了解缓冲区 我们首先来看看下面的操作: 我们首先创建了一个文件并在这个文件里面添加了...
C++ 机房预约系统(六):学... 8、 学生模块 8.1 学生子菜单、登录和注销 实现步骤: 在Student.cpp的...
JAVA多线程知识整理 Java多线程基础 线程的创建和启动 继承Thread类来创建并启动 自定义Thread类的子类&#...
【洛谷 P1090】[NOIP... [NOIP2004 提高组] 合并果子 / [USACO06NOV] Fence Repair G ...
国民技术LPUART介绍 低功耗通用异步接收器(LPUART) 简介 低功耗通用异步收发器...
城乡供水一体化平台-助力乡村振... 城乡供水一体化管理系统建设方案 城乡供水一体化管理系统是运用云计算、大数据等信息化手段࿰...
程序的循环结构和random库...   第三个参数就是步长     引入文件时记得指明字符格式,否则读入不了 ...
中国版ChatGPT在哪些方面... 目录 一、中国巨大的市场需求 二、中国企业加速创新 三、中国的人工智能发展 四、企业愿景的推进 五、...
报名开启 | 共赴一场 Flu... 2023 年 1 月 25 日,Flutter Forward 大会在肯尼亚首都内罗毕...
汇编00-MASM 和 Vis... Qt源码解析 索引 汇编逆向--- MASM 和 Visual Studio入门 前提知识ÿ...
【简陋Web应用3】实现人脸比... 文章目录🍉 前情提要🌷 效果演示🥝 实现过程1. u...
前缀和与对数器与二分法 1. 前缀和 假设有一个数组,我们想大量频繁的去访问L到R这个区间的和,...
windows安装JDK步骤 一、 下载JDK安装包 下载地址:https://www.oracle.com/jav...
分治法实现合并排序(归并排序)... 🎊【数据结构与算法】专题正在持续更新中,各种数据结构的创建原理与运用✨...
在linux上安装配置node... 目录前言1,关于nodejs2,配置环境变量3,总结 前言...
Linux学习之端口、网络协议... 端口:设备与外界通讯交流的出口 网络协议:   网络协议是指计算机通信网...
Linux内核进程管理并发同步... 并发同步并发 是指在某一时间段内能够处理多个任务的能力,而 并行 是指同一时间能够处理...
opencv学习-HOG LO... 目录1. HOG(Histogram of Oriented Gradients,方向梯度直方图)1...
EEG微状态的功能意义 导读大脑的瞬时全局功能状态反映在其电场结构上。聚类分析方法一致地提取了四种头表面脑电场结构ÿ...
【Unity 手写PBR】Bu... 写在前面 前期积累: GAMES101作业7提高-实现微表面模型你需要了解的知识 【技...