Dubbo——初识RPC、Dubbo框架、使用直连方式实现Dubbo

article/2025/11/7 19:24:55

文章目录：

1.RPC & 软件架构

1.1 单一应用架构

1.2 分布式微服务架构

1.3 RPC

2.Dubbo概述

2.1基本架构

2.2 dubbo支持的协议

3.直连方式实现dubbo

3.1 服务提供者的创建

3.2 服务消费者的创建

3.3 启动测试！！！

1.RPC & 软件架构

1.1 单一应用架构

当网站流量很小时，应用规模小时，只需一个应用，将所有功能都部署在一起，以减少部署服务器数量和成本。此时，用于简化增删改查工作量的数据访问框架(ORM) 是关键。数据库的处理时间影响应用的性能。

这种结构的应用适合小型系统，小型网站，或者企业的内部系统，用户较少，请求量不大，对请求的处理时间没有太高的要求。 将所有功能都部署到一个服务器，简单易用。开发项目的难度低。
缺点：
        1、性能扩展比较困难
        2、不利于多人同时开发
        3、不利于升级维护
        4、整个系统的空间占用比较大

1.2 分布式微服务架构

分布式系统是若干独立计算机（服务器）的集合，这些计算机对于用户来说就像单个相关系统，分布式系统（distributed system ）是建立在网络之上的服务器端一种结构。分布式系统中的计算机可以使用不同的操作系统，可以运行不同应用程序提供服务，将服务分散部署到多个计算机服务器上。
当应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的 分布式服务框架 (RPC) 是关键。分布式系统将服务作为独立的应用，实现服务共享和重用。

 

1.3 RPC

RPC 【 Remote Procedure Call 】是指远程过程调用，是一种进程间通信方式，是一种技术思想，而不是规范。它允许程序调用另一个地址空间（网络的另一台机器上）的过程或函数，而不用开发人员显式编码这个调用的细节。调用本地方法和调用远程方法一样。

 

RPC 调用过程：通讯是基于 TCP或 UDP协议；序列化方式（xml/json/二进制）
  1. 调用方 client 要使用右侧 server 的功能（方法），发起对方法的调用
  2. client stub 是 RPC 中定义的存根，看做是 client 的助手。stub 把要调用的方法参数进行序列化，方法名称和其他数据包装起来。
  3. 通过网络 socket(网络通信的技术)，把方法调用的细节内容发送给右侧的 server
  4. server 端通过 socket 接收请求的方法名称、参数等数据，传给 stub。
  5. server 端接到的数据由 serverstub(server 的助手)处理，调用 server 的真正方法，处理业务
  6. server 方法处理完业务，把处理的结果对象（Object）交给了助手，助手把 Object 进行序列化，对象转为二进制数据。
  7. server 助手二进制数据交给网络处理程序
  8. 通过网络将二进制数据，发送给 client。
  9. client 接数据，交给 client 助手。
  10. client 助手，接收数据通过反序列化为 java 对象（Object），作为远程方法调用结果。

2.Dubbo概述

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源 Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

Dubbo 是一个分布式服务框架，致力于提供高性能和透明化的 RPC 远程服务调用方案、 服务治理方案。

官网：Apache Dubbo

2.1基本架构

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

2.2 dubbo支持的协议

支持多种协议：dubbo , hessian , rmi , http, webservice , thrift , memcached , redis。

dubbo 官方推荐使用 dubbo 协议。dubbo 协议默认端口 20880

使用 dubbo 协议，spring 配置文件加入：<dubbo:protocol name="dubbo" port="20880" />

3.直连方式实现dubbo

点对点的直连项目:消费者直接访问服务提供者，没有注册中心。消费者必须指定服务提供者的访问地址（url）。

消费者直接通过 url 地址访问固定的服务提供者。这个 url 地址是不变的。

3.1 服务提供者的创建

1.创建一个maven web工程:服务的提供者，添加需要的依赖
2.创建一个实体bean查询的结果（必须实现序列化）
3.提供一个服务接口:xxxx
4.实现这个服务接口:xxxxImpl
5.配置dubbo服务提供者的核心配置文件
   a.声明dubbo服务提供者的名称:保证唯一
   b.声明dubbo使用的协议和端口号
   c.暴露服务,使用直连方式
6.添加监听器，读取配置文件信息

代码如下：👇👇👇（代码顺序对应上面的序号）

    <dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.2.5.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>5.2.5.RELEASE</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.6.2</version></dependency>
package com.szh.dubbo.model;import java.io.Serializable;/****/
public class User implements Serializable {private Integer id;private String name;private Integer age;//getter and setter
}

package com.szh.dubbo.service;import com.szh.dubbo.model.User;/****/
public interface UserService {User queryUserById(Integer id);
}

package com.szh.dubbo.service.impl;import com.szh.dubbo.model.User;
import com.szh.dubbo.service.UserService;/****/
public class UserServiceImpl implements UserService {@Overridepublic User queryUserById(Integer id) {User user=new User();user.setId(id);user.setName("张起灵");user.setAge(21);return user;}
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd"><!-- 声明dubbo服务提供者的名称：保证唯一性 --><dubbo:application name="001-link-userservice-provider"/><!-- 设置dubbo使用的协议和端口号 --><dubbo:protocol name="dubbo" port="20880"/><!-- 暴露服务接口 --><dubbo:service interface="com.szh.dubbo.service.UserService" ref="a" registry="N/A"/><!-- 将业务接口的实现类加载到Spring容器中 --><bean id="a" class="com.szh.dubbo.service.impl.UserServiceImpl"/></beans>
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"version="4.0"><!-- 读取dubbo配置文件信息 --><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:dubbo-userservice-provider.xml</param-value></context-param><!-- 配置Spring的监听器 --><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener>
</web-app>

3.2 服务消费者的创建

1.创建一个maven web工程:服务的消费者
2.配置pom文件:添加需要的依赖(spring,dubbo)
3.编写controller
4.设置dubbo的核心配置文件()
5.配置中央调度器(就是一个servlet:DispatcherServlet)

代码如下：（代码顺序对应上面的序号）

服务提供者接口中的方法要给消费者使用，消费者项目需要知道接口名称和接口中的方法名称、参数等。这些信息服务提供者才知道。需要把服务提供者接口对应工程的 class 文件打包为 jar 。

服务接口项目的类文件打包为 jar， 安装到 maven 仓库，仓库中的提供者 jar 可以被消费者使用。

使用 idea 的 maven 生命周期中的 install 命令进行打包（打包的时候将pom文件中的 <packaging>war</packaging> 内容注释掉，因为在服务消费者的pom文件中进行依赖项的导入是一个jar包）。也就是下面pom文件中的最后一个依赖项。

    <dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.2.5.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>5.2.5.RELEASE</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.6.2</version></dependency><dependency><groupId>com.szh.dubbo</groupId><artifactId>001-link-userservice-provider</artifactId><version>1.0.0</version></dependency>
package com.szh.dubbo.controller;import com.szh.dubbo.model.User;
import com.szh.dubbo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;/****/
@Controller
public class UserController {@Autowiredprivate UserService userService;@RequestMapping(value = "/user")public String userDetail(Integer id, Model model) {User user=userService.queryUserById(id);model.addAttribute("user",user);return "userDetail";}
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd"><!-- 声明服务消费者名称：保证唯一性 --><dubbo:application name="002-link-consumer"/><!-- 引用远程接口服务 --><dubbo:reference interface="com.szh.dubbo.service.UserService"id="userService"url="dubbo://localhost:20880"registry="N/A"/></beans>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xmlns:mvc="http://www.springframework.org/schema/mvc"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc https://www.springframework.org/schema/mvc/spring-mvc.xsd"><!-- 组件扫描器，扫描controller包下的注解 --><context:component-scan base-package="com.szh.dubbo.controller"/><!-- 开启SpringMVC注解驱动 --><mvc:annotation-driven/><!-- 配置视图解析器 --><bean class="org.springframework.web.servlet.view.InternalResourceViewResolver"><property name="prefix" value="/"/><property name="suffix" value=".jsp"/></bean></beans>
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"version="4.0"><!-- 配置SpringMVC的中央调度器，读取Spring、Dubbo配置文件信息 --><servlet><servlet-name>DispatcherServlet</servlet-name><servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class><init-param><param-name>contextConfigLocation</param-name><param-value>classpath:applicationContext.xml,classpath:dubbo-consumer.xml</param-value></init-param></servlet><servlet-mapping><servlet-name>DispatcherServlet</servlet-name><url-pattern>/</url-pattern></servlet-mapping></web-app>
<%@ page contentType="text/html;charset=utf-8" language="java" %>
<html>
<head><title>$</title>
</head>
<body><h1>用户详情</h1><div>用户编号：${user.id}</div><div>用户姓名：${user.name}</div>
</body>
</html>

3.3 启动测试！！！

上面两步，我们已经创建好了服务提供者和服务消费者，下面分别为这两个maven web工程配置各自的tomcat服务器。

配置信息如下：👇👇👇（均不设置上下文根）

配置好Tomcat之后，我们就可以启动测试了，这里需要注意的是：一定要先启动第一个maven web工程（服务提供者）的tomcat服务器；启动成功后，再启动第二个maven web工程的（服务消费者）tomcat服务器。因为顾名思义：肯定是先有提供，才能进行消费啊。

下面是测试结果：👇👇👇（访问控制层中的请求路径，可以正确的拿到数据，这就说明我们使用直连方式实现了dubbo）


http://chatgpt.dhexx.cn/article/48N1jnxE.shtml

相关文章

分布式基本理解与Dubbo基本概念

分布式基本理解与Dubbo基本概念

学习dubbo之前&#xff0c;先要了解一下什么是分布式 分布式基础理论 什么是分布式系统 分布式系统是若干独立计算机的集合&#xff0c;这些计算机对于用户来说就像单个相关系统。 随着互联网的发展&#xff0c;网站应用的规模不断扩大&#xff0c;常规的垂直应用架构已无法…
阅读更多...
Dubbo的原理和机制

Dubbo的原理和机制

Dubbo :是一个RPC框架&#xff0c;SOA框架&#xff1a; Dubbo缺省协议采用单一长连接和NIO异步通讯&#xff0c;适合于小数据量大并发的服务调用&#xff0c;以及服务消费者机器数远大于服务提供者机器数的情况。 作为RPC&#xff1a;支持各种传输协议&#xff0c;如dubbo,hes…
阅读更多...
dubbo实现原理介绍

dubbo实现原理介绍

一、什么是dubbo Dubbo是Alibaba开源的分布式服务框架&#xff0c;它最大的特点是按照分层的方式来架构&#xff0c;使用这种方式可以使各个层之间解耦合&#xff08;或者最大限度地松耦合&#xff09;。从服务模型的角度来看&#xff0c; Dubbo采用的是一种非常简单的模型…
阅读更多...
Dubbo-聊聊Dubbo协议

Dubbo-聊聊Dubbo协议

前言 Dubbo源码阅读分享系列文章&#xff0c;欢迎大家关注点赞 SPI实现部分 Dubbo-SPI机制 Dubbo-Adaptive实现原理 Dubbo-Activate实现原理 Dubbo SPI-Wrapper 注册中心 Dubbo-聊聊注册中心的设计 Dubbo-时间轮设计 通信 Dubbo-聊聊通信模块设计 什么是协议 在网…
阅读更多...
dubbo客户端的实现

dubbo客户端的实现

业界微服务大行其道。服务与服务之间的同学主要有有以下两大类。 阿里RPC框架&#xff1a;dubboRestFull风格的Http调用 我们知道Http接口我们找到PostMan这种Http客户端。 但是dubbo似乎并没有想关的客户端&#xff0c;我们调试的时常常需要同时打开两个以上的服务。 dubbo是…
阅读更多...
dubbo组成原理-http服务消费端如何调用

dubbo组成原理-http服务消费端如何调用

dubbo协议已经用的很多了&#xff0c;这里来稍微介绍一下http协议&#xff0c;官方对http协议的说明简直少的让人发指。哈哈 百度大部分都只是讲了http服务端的配置 那就先从服务端的配置说起 dubbo需要的jar包这里就不说明了&#xff0c;网上找些maven的pom就可以 web.xml…
阅读更多...
Dubbo基本原理机制

Dubbo基本原理机制

分布式服务框架&#xff1a; –高性能和透明化的RPC远程服务调用方案–SOA服务治理方案 -Apache MINA 框架基于Reactor模型通信框架&#xff0c;基于tcp长连接 Dubbo缺省协议采用单一长连接和NIO异步通讯&#xff0c;适合于小数据量大并发的服务调用&#xff0c;以及服务消费…
阅读更多...
Dubbo基本原理与机制

Dubbo基本原理与机制

1、什么是Dubbo Dubbo 是一款高性能、轻量级的开源 RPC 框架&#xff0c;提供服务自动注册、自动发现等高效服务治理方案&#xff0c; 可以和 Spring 框架无缝集成。 2、Dubbo依赖关系 1、服务消费者&#xff08;Consumer&#xff09;: 调用远程服务的服务消费方&#xff0c…
阅读更多...
dubbo原理和机制

dubbo原理和机制

Dubbo 框架是用来处理分布式系统中&#xff0c;服务发现与注册以及调用问题的&#xff0c;并且管理调用过程。 一&#xff0c;工作流程&#xff1a; 服务提供者在启动的时候&#xff0c;会通过读取一些配置将服务实例化。Proxy 封装服务调用接口&#xff0c;方便调用者调用。…
阅读更多...
Dubbo的原理与机制

Dubbo的原理与机制

​ Dubbo 前言 在介绍Dubbo之前先了解一下基本概念&#xff1a; Dubbo是一个RPC框架&#xff0c;RPC&#xff0c;即Remote Procedure Call&#xff08;远程过程调用&#xff09;&#xff0c;相对的就是本地过程调用&#xff0c;在分布式架构之前的单体应用架构和垂直应用架…
阅读更多...
Dubbo基础及原理机制

Dubbo基础及原理机制

1. 什么是Dubbo&#xff1f; Dubbo是 阿里巴巴公司开源的一个高性能RPC 分布式服务框架&#xff0c;使得应用可通过高性能的 RPC 实现服务的输出和输入功能&#xff0c;可以和 Spring框架无缝集成&#xff0c;现已成为 Apache 基金会孵化项目。 2. 为什么要用Dubbo&#xff1…
阅读更多...
Dubbo原理和机制详解(非常全面)

Dubbo原理和机制详解(非常全面)

Dubbo是一款Java RPC框架&#xff0c;致力于提供高性能的RPC远程服务调用方案。Dubbo 作为主流的微服务框架之一&#xff0c;为开发人员带来了非常多的便利。 本文我们重点详解 Dubbo 的原理机制 mikechen 目录 Dubbo核心功能Dubbo核心组件Dubbo的架构设计Dubbo调用流程 1️…
阅读更多...
大地测量学基础（复习）第一部分

大地测量学基础（复习）第一部分

写在前面 这篇博文是用来复习课程“大地测量学基础”的&#xff0c;里面仅列出本人觉得这门课程比较重要的部分&#xff0c;希望能够帮助到有需要的朋友。 课本采用《大地测量学基础》孔祥元&#xff0c;武汉大学出版社。 前面已经有一篇“大地测量学基础&#xff08;复习&…
阅读更多...
深入理解ArcGIS的地理坐标系、大地坐标系

深入理解ArcGIS的地理坐标系、大地坐标系

1、引言 地理坐标&#xff1a;为球面坐标。 参考平面地是 椭球面,坐标单位:经纬度 大地坐标&#xff1a;为平面坐标。参考平面地是 水平面,坐标单位&#xff1a;米、千米等 地理坐标转换到大地坐标的过程可理解为投影。 &#xff08;投影&#xff1a;将不规则的地球曲面转…
阅读更多...
GNSS定位中的不同高度概念及计算

GNSS定位中的不同高度概念及计算

文章目录 高度相关的几个基本概念RTKLIB中高度设置与计算参考文献 由于在GNSS定位中由多种高度表示&#xff0c;不同的高度概念很容易混淆&#xff0c;中英文对应有时候也容易搞混。因此整理了一下常用的两种高度——椭球高、正高的概念与计算&#xff0c;并且标注了对应的英文…
阅读更多...
概念讲解：大地水准面 | 地球椭球体 | 参考椭球体 | 大地基准面 | 地图投影

概念讲解：大地水准面 | 地球椭球体 | 参考椭球体 | 大地基准面 | 地图投影

文章目录 大地水准面地球椭球体参考椭球体大地基准面地图投影几个概念之间的关系相关文章 大地水准面 指平均海平面通过大陆延伸勾画出的一个连续的封闭曲面。大地水准面包围的球体称为大地球体。从大地水准面起算的陆地高度&#xff0c;称为绝对高度或海拔。 大地水准面是对地…
阅读更多...
地图学的基础知识_天文坐标系_大地坐标系_地心坐标系及其相关概念

地图学的基础知识_天文坐标系_大地坐标系_地心坐标系及其相关概念

学习地图学&#xff0c;由于地理知识欠缺&#xff0c;学习相关投影知识还为时过早&#xff0c;需要复习一些基本概念。 阅读对象:测绘类 地球自然球体: 由地球自然表面所包围的的形体称为地球自然体。 地球自然球体形状:地球不是一个正球体&#xff0c;而是一个极半径略短&a…
阅读更多...
大地测量学

大地测量学

大地测量学简答题复习 问&#xff1a;建立国家平面控制网的方法&#xff1f; 答&#xff1a; 常规大地测量&#xff1a;三角测量&#xff08;已知一个点的坐标&#xff0c;又精密测量了1&#xff0c;2点的边长和坐标方位角&#xff0c;依据三角形的正弦定理推测出其他边的长…
阅读更多...
[复试——大地测量学]第一章节——2022/12/30

[复试——大地测量学]第一章节——2022/12/30

PART 1 大地测量学的定义 是在一定的时间和空间的参考系中&#xff0c;测量和描绘地球形状及其重力场并监测其变化&#xff0c;为人类活动提供地球空间信息的一门学科。 大地测量学的作用 1.建立地面控制网 2.精确测定大地控制点的三维位置以及其重力场参数 大地测量学的…
阅读更多...
1985高程基准与全球大地水准面（EGM2008）的关系综述

1985高程基准与全球大地水准面（EGM2008）的关系综述

​按照惯例&#xff0c;先给结论&#xff1a; &#xff08;1&#xff09;1985国家高程基准与EGM2008的差异有严密的理论公式计算&#xff1b; &#xff08;2&#xff09;1985国家高程基准与EGM20008的垂直偏差与参考系、水准模型、选取的水准点有关系 &#xff08;3&#xf…
阅读更多...
推荐文章

Copyright @ 2022~2023