使用Dubbo实现简单的RPC调用（Spring配置文件版）

article/2025/10/4 2:44:00

更多文章和资源欢迎访问：SuperCoder Blog

文章目录

  • 更多文章和资源欢迎访问：[SuperCoder Blog](https://supercoder.com.cn)
  • 前言
  • 一、Dubbo架构
  • 二、安装zookeeper
  • 三、代码实战
    • 1. 创建服务提供方
    • 2. 创建服务消费方
  • 四、服务调用

前言

Dubbo是阿里巴巴公司开源（已捐献给Apache）的高性能、轻量级的Java RPC框架。致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。

官网：Dubbo中文官网

一、Dubbo架构

在这里插入图片描述

二、安装zookeeper

下载地址：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/

上传到服务器

# mac 终端上传，可以使用其他工具
scp /Users/chaishuai/Downloads/apache-zookeeper-3.6.3-bin.tar.gz root@192.168.10.111:/usr/local/

解压并重命名

# 解压
tar -zxvf apache-zookeeper-3.6.3-bin.tar.gz 
# 重命名
mv apache-zookeeper-3.6.3-bin zookeeper

修改配置文件

# 进入配置文件目录
cd /usr/local/zookeeper/conf/
# 因为zookeeper配置文件要叫zoo.cfg，所以复制一份zoo_sample.cfg
cp zoo_sample.cfg zoo.cfg
# 切换到zookeeper目录下，创建zookeeper数据目录
cd /usr/local/zookeeper
mkdir data
# 修改zoo.cfg
vim zoo.cfg
# 修改dataDir=/tmp/zookeeper 为 /usr/local/zookeeper/data

启动zookeeper

# 进入bin目录
cd /usr/local/zookeeper/bin
# 启动zookeeper
./zkServer.sh start
# 查看状态
./zkServer.sh status
# 停止zookeeper
./zkServer.sh stop

注意：zookeeper启动默认会使用8080端口，如果启动后查看状态显示失败，检查8080端口是否被占用。如果被占用可根据实际情况修改。

三、代码实战

1. 创建服务提供方

创建maven web工程dubbo-provider，引入相关依赖

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>cn.com.supercoder</groupId><artifactId>dubbo-provider</artifactId><version>1.0-SNAPSHOT</version><packaging>war</packaging><name>dubbo-provider Maven Webapp</name><url>https://www.supercoder.com.cn</url><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><dubbo.version>2.7.15</dubbo.version><zookeeper.version>3.4.6</zookeeper.version><spring.version>5.2.9.RELEASE</spring.version></properties><dependencies><!--引入实体类模块，因为实体类在多个服务中公用，所以抽取成一个单独的模块--><dependency><groupId>cn.com.supercoder</groupId><artifactId>dubbo-entity</artifactId><version>1.0-SNAPSHOT</version></dependency><!--引入服务接口模块，同样由于服务提供方和服务消费方都要用到，所有抽取--><dependency><groupId>cn.com.supercoder</groupId><artifactId>dubbo-interface</artifactId><version>1.0-SNAPSHOT</version></dependency><!--dubbo--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>${dubbo.version}</version></dependency><!--zookeeper--><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>${zookeeper.version}</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency><!--spring web--><dependency><groupId>org.springframework</groupId><artifactId>spring-web</artifactId><version>${spring.version}</version></dependency></dependencies><build><finalName>dubbo-provider</finalName><pluginManagement><plugins><!--tomcat插件--><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.1</version><configuration><port>9001</port><path>/</path></configuration></plugin></plugins></pluginManagement></build>
</project>

服务提供方要提供的方法

/*** @desc UserService实现类* @author supercoder*/
public class UserServiceImpl implements UserService {@Overridepublic List<User> getUserList() {// 此处模拟返回UserListArrayList<User> list = new ArrayList<>();User userA = new User();userA.setUuid(UUID.randomUUID().toString().replace("-",""));userA.setAge("V1.0.0");userA.setUsername("SuperCoderBlog");userA.setAddress("https://www.supercoder.com.cn");User userB = new User();userB.setUuid(UUID.randomUUID().toString().replace("-", ""));userB.setAge("V1.0.0");userB.setUsername("SuperCoderBbs");userB.setAddress("https://bbs.supercoder.com.cn");list.add(userA);list.add(userB);return list;}
}

创建Spring配置文件并配置要暴露的服务

<?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="dubbo-provider"/><!--配置zookeeper注册中心地址--><dubbo:registry address="zookeeper://xxx.xxx.xxx.xxx:2181"/><!--用dubbo协议在20880端口暴露协议--><dubbo:protocol name="dubbo" port="20881"/><!--声明需要暴露的服务--><dubbo:service interface="cn.com.supercoder.service.UserService" ref="userService"/><!--注册本地bean--><bean id="userService" class="cn.com.supercoder.service.impl.UserServiceImpl"/></beans>

在web.xml中配置监听器加载Spring配置文件

<!DOCTYPE web-app PUBLIC"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN""http://java.sun.com/dtd/web-app_2_3.dtd" ><web-app><display-name>Archetype Created Web Application</display-name><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:provider.xml</param-value></context-param><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener>
</web-app>

2. 创建服务消费方

创建maven web工程dubbo-consumer，引入相关依赖

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>cn.com.supercoder</groupId><artifactId>dubbo-consumer</artifactId><version>1.0-SNAPSHOT</version><packaging>war</packaging><name>dubbo-consumer Maven Webapp</name><url>https://www.supercoder.com.cn</url><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><dubbo.version>2.7.15</dubbo.version><zookeeper.version>3.4.6</zookeeper.version><spring.version>5.2.9.RELEASE</spring.version></properties><dependencies><!--引入实体类所在模块，因为实体类在多个服务中公用，所以抽取成一个单独的模块--><dependency><groupId>cn.com.supercoder</groupId><artifactId>dubbo-entity</artifactId><version>1.0-SNAPSHOT</version></dependency><!--引入服务接口模块，同样由于服务提供方和服务消费方都要用到，所有抽取--><dependency><groupId>cn.com.supercoder</groupId><artifactId>dubbo-interface</artifactId><version>1.0-SNAPSHOT</version></dependency><!--dubbo--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>${dubbo.version}</version></dependency><!--zookeeper--><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>${zookeeper.version}</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency><!--spring-webmvc--><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>${spring.version}</version></dependency></dependencies><build><finalName>dubbo-consumer</finalName><pluginManagement><plugins><!--tomcat插件--><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.1</version><configuration><port>7001</port><path>/</path></configuration></plugin></plugins></pluginManagement></build>
</project>

创建Service调用服务提供方提供的UserService服务

/*** @author supercoder*/
@Service
public class OrderServiceImpl implements OrderService {@Autowiredprivate UserService userService;@Overridepublic List<User> getUserList() {return userService.getUserList();}
}

创建Controller调用Service实现业务调用

/*** @author supercoder*/
@Controller
@RequestMapping("/order")
public class OrderController {@Autowiredprivate OrderService orderService;@RequestMapping("/getAll")@ResponseBodypublic List<User> getUserList(){List<User> userList = orderService.getUserList();return userList;}
}

创建Spring配置文件引用服务

<?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"xmlns:context="http://www.springframework.org/schema/context"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 http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd"><!--服务消费方应用名称，用于计算依赖关系--><dubbo:application name="dubbo-consumer"/><!--配置zookeeper注册中心地址--><dubbo:registry address="zookeeper://123.56.85.35:2181"/><!--生成本地服务代理--><dubbo:reference id="userService" interface="cn.com.supercoder.service.UserService"/><!--开启注解扫描--><context:component-scan base-package="cn.com.supercoder.service"/></beans>

创建SpringMVC配置文件

<?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 http://www.springframework.org/schema/mvc/spring-mvc.xsd"><!--开启注解扫描--><context:component-scan base-package="cn.com.supercoder.controller"/><!--开启注解驱动--><mvc:annotation-driven/></beans>

在web.xml中配置加载Spring和SpringMVC配置文件

<!DOCTYPE web-app PUBLIC"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN""http://java.sun.com/dtd/web-app_2_3.dtd" ><web-app><display-name>Archetype Created Web Application</display-name><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:consumer.xml</param-value></context-param><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener><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:spring-mvc.xml</param-value></init-param><load-on-startup>1</load-on-startup></servlet><servlet-mapping><servlet-name>dispatcherServlet</servlet-name><url-pattern>/*</url-pattern></servlet-mapping>
</web-app>

四、服务调用

完成服务提供方和消费方的创建后，启动两个工程，测试调用。

注意事项

  1. zookeeper服务正常启动
  2. 因为服务调用结果需要序列化后通过网络传输，所以实体类必须实现Serializable接口
  3. 实体类模块和接口模块的代码比较简单，本文省略，需要自行创建

访问 http://localhost:7001/order/getAll 测试

测试结果：
在这里插入图片描述
至此，一个通过Spring配置文件方式实现的Dubbo RPC调用demo就完成了。


http://chatgpt.dhexx.cn/article/vLulRZA8.shtml

相关文章

用一个简单的函数来理一下RPC调用过程

用一个简单的函数来理一下RPC调用过程

1.什么是RPC RPC&#xff08;Remote Procedure Call&#xff09;远程过程调度&#xff0c;简单的理解就是一个节点请求另一个节点的提供的服务。 2.远程调用要面临的三个问题。 &#xff08;1&#xff09;Call ID映射。本地调用中&#xff0c;函数体是直接通过函数指针来指定…
阅读更多...
Dubbo的RPC调用流程

Dubbo的RPC调用流程

首先在客户端启动时会从注册中心拉去和订阅对应的服务列表,Cluster会把拉取到的服务列表聚合成一个cluster&#xff0c;每次RPC调用前会通过Directory#list获取providers地址(已经生成好的invoker列表)&#xff0c;获取这些服务列表给后续路由和负载均衡使用&#xff0c;框架内…
阅读更多...
RPC 调用原理

RPC 调用原理

RPC调用原理 RPC原理 RPC(Remote Procedure Call)即远程过程调用&#xff0c;允许一台计算机调用另一台计算机上的程序得到结果&#xff0c;而代码中不需要做额外的编程&#xff0c;就像在本地调用一样。分布式的应用可以借助RPC来完成服务之间的调用。 RPC框架原理 在RPC框架…
阅读更多...
RPC调用完整流程

RPC调用完整流程

RPC调用完整流程&#xff1a;   调用方持续把请求参数对象序列化成二进制数据&#xff0c;经过 TCP 传输到服务提供方&#xff1b;服务提供方从 TCP 通道里面接收到二进制数据&#xff1b;根据 RPC 协议&#xff0c;服务提供方将二进制数据分割出不同的请求数据&#xff0c;经…
阅读更多...
RPC调用

RPC调用

1.RPC调用、本地调用和HTTP调用 网络调用一般是基于HTTP协议进行调用&#xff0c;RPC是使用TCP或者UDP协议进行调用&#xff0c;效率上回更好&#xff1b; 常用的RPC框架有Thrift、GRPC等&#xff1b; 2.RPC的调用时序图 1&#xff09;调用方调用Proxy请求服务&#xff0c;并…
阅读更多...
简单实现rpc调用

简单实现rpc调用

rpc调用 代码地址 查看代码 rpc称远程调用过程&#xff0c;在rpc调用过程中需要解决的几个问题。 代理协议序列化 技术选型 协议&#xff0c;我们使用java的socket编程套接字代理&#xff0c;使用java的动态代理序列化&#xff0c;使用java的原生的序列化。 rpc衍生出来…
阅读更多...
Go rpc调用

Go rpc调用

RPC原理图 客户端Stub: 客户端存根服务端Stub: 服务端存根 RPC技术架构 服务端&#xff1a;server.go package mainimport ("math""net""net/http""net/rpc" )type MathUtil struct { }// 该方法向外暴露&#xff1a;提供计算圆形面…
阅读更多...
rpc调用 java_RPC调用的简单实现

rpc调用 java_RPC调用的简单实现

RPC调用流程 流程描述： 1.服务调用者发送请求(interface#method#args) 2.客户端进行StringEncode编码 3.数据写到服务提供者 4.服务提供者接受请求 5.将接收的包进行StringDecode解码 6.服务提供方调用对应api 7.服务提供方响应方法调用结果 8.服务提供方将结果集进行StringEn…
阅读更多...
RPC调用和HTTP调用的区别

RPC调用和HTTP调用的区别

一.远程调用方式 无论是微服务还是分布式服务&#xff08;都是SOA&#xff0c;都是面向服务编程&#xff09;&#xff0c;都面临着服务间的远程调用。那么服务间的远程调用方式有哪些呢&#xff1f; 常见的远程调用方式有以下几种&#xff1a; RPC&#xff1a;Remote Produce…
阅读更多...
RPC远程调用通俗理解

RPC远程调用通俗理解

先从一个案例来讲RPC 为了提升饭店的服务能力&#xff0c;饭店从一开始只有一个负责所有事情的厨师发展成有厨师、切菜师、备菜师等多个角色。在饭店只有一个厨师的时候&#xff0c;厨师想要做出一道美味的番茄炒蛋的时候&#xff0c;他需要自己洗番茄、切番茄、打鸡蛋、炒菜。…
阅读更多...
RPC通信基本原理 -- 浅析RPC远程过程调用基本原理

RPC通信基本原理 -- 浅析RPC远程过程调用基本原理

一、RPC基本概念 1.1、RPC简介 RPC 的全称是 Remote Procedure Call是一种进程间通信方式。RPC只是一个概念 而不是具体的协议或框架。它允许程序调用另一个地址空间&#xff08;通常是共享网络的另一台机器上&#xff09;的过程或函数&#xff0c;而不用程序员显式编码这个远…
阅读更多...
RPC服务调用

RPC服务调用

RPC服务调用 一、RPC实现原理深入分析1、RPC的定义&#xff08;1&#xff09;RPC作用&#xff08;2&#xff09;RPC核心组成&#xff08;3&#xff09;RPC调用方式 二、精简版RPC调用代码实现1、场景2、接口设计3、序列化协议 最近在做调用系统相关的服务&#xff0c;采用主从的…
阅读更多...
远程过程调用(RPC)详解

远程过程调用(RPC)详解

本文介绍了什么是远程过程调用(RPC)&#xff0c;RPC 有哪些常用的方法&#xff0c;RPC 经历了哪些发展阶段&#xff0c;以及比较了各种 RPC 技术的优劣。 什么是 RPC RPC 是远程过程调用&#xff08;Remote Procedure Call&#xff09;的缩写形式&#xff0c;Birrell 和 Nels…
阅读更多...
Simple Schnorr Multi-Signatures with Applications to Bitcoin 学习笔记

Simple Schnorr Multi-Signatures with Applications to Bitcoin 学习笔记

1. 引言 Blockstream团队2018年论文《Simple Schnorr Multi-Signatures with Applications to Bitcoin》。 对应的代码实现&#xff1a; https://github.com/KZen-networks/multi-party-schnorr https://github.com/lovesh/signature-schemes 论文要点&#xff1a; MuSig——…
阅读更多...
【密码学原理】数字签名（ElGamal签名，Schnorr签名，椭圆曲线签名，RSA-PSS签名）

【密码学原理】数字签名（ElGamal签名，Schnorr签名，椭圆曲线签名，RSA-PSS签名）

数字签名是公钥密码学发展过程中最重要的概念之一&#xff0c;产生和使用数字签名过程的一般模型如图所示 消息认证可以保护消息交换双方不受第三方的攻击&#xff0c;但是不能处理通信双方自身发生的攻击。例如对下图中的某种方式进行攻击&#xff0c;考虑两种情况&#xff1a…
阅读更多...
Schnorr签名java实现

Schnorr签名java实现

Schnorr签名&#xff08;模指数&#xff09;的实现java 1、算法描述2、算法的实现&#xff08;java&#xff09; 和ElGama数字签名一样&#xff0c;Schnorr数字签名方案也是基于离散对数。 Schnorr数字签名主要工作不依赖于消息&#xff0c;生成签名过程与消息相关的部分需要进…
阅读更多...
Blind Schnorr Signature

Blind Schnorr Signature

1. 引言 前序博客有&#xff1a; 盲签名 blind signature Blind Schnorr Signature交互签名Demo见&#xff1a; Blind Schnorr Signature Interactive Demo 参考资料 [1] Schnorr Applications: Blind Signatures
阅读更多...
本体技术视点 | 为什么 BIP - 340 选择引入 Schnorr 签名算法？

本体技术视点 | 为什么 BIP - 340 选择引入 Schnorr 签名算法？

引言 备受瞩目的技术升级 Taproot 软分叉将于最近激活&#xff0c;激活高度为 709632&#xff0c;距今已不足 500 个区块。此次升级包括三个改进提案&#xff0c;分别是 BIP - 340、BIP - 341 和 BIP - 342。其中&#xff0c;BIP - 340 引入了 Schnorr 签名&#xff0c;BIP - …
阅读更多...
【密码学】Schnorr认证，Schnorr签名，安全性证明

【密码学】Schnorr认证，Schnorr签名，安全性证明

Schnorr是Sigma协议的实例&#xff0c;从Schnorr 认证协议和Schnor签名两个部分来介绍。在前面关于认证协议的讲述中&#xff0c;用到了一些特定的符号&#xff0c;这里会继续使用。 首先认识Schnorr认证协议&#xff0c;定义如图所示 Schnorr认证协议和Schnorr签名方案的安全…
阅读更多...
零知识证明系列之二——Schnorr协议

零知识证明系列之二——Schnorr协议

​Schnorr协议简介 Schnorr协议是由德国数学家和密码学家Claus-Peter Schnorr在1991年提出&#xff0c;是一种基于离散对数难题的知识证明机制。Schnorr本质上是一种零知识的技术&#xff0c;即Prover声称知道一个密钥x的值&#xff0c;通过使用Schnorr加密技术&#xff0c;可…
阅读更多...
推荐文章

Copyright @ 2022~2023