从0到1实现RPC | 02 RpcConsumer的远程调用

一、RPC的简化版原理如下图(核心是代理机制)。

图片

1.本地代理存根: Stub

2.本地序列化反序列化

3.网络通信

4.远程序列化反序列化

5.远程服务存根: Skeleton

6.调用实际业务服务

7.原路返回服务结果

8.返回给本地调用方

二、新建一个模块rpc-demo-consumer

图片

主要的依赖是rpc-demo-api,即业务服务定义的api接口,rpc-core是核心依赖包。

图片

三、启动方法

在启动方法中注入业务服务接口UserService和OrderService,使用的注解是@RpcConsumer,本文主要的功能就是如何实现这个注解。

在启动的时候会导入ConsumerConfig的配置类。

使用的ApplicationRunner来测试方法调用。

图片

四、ConsumerConfig用来启动消费者服务。

图片

五、ConsumerBootstrap实现了ApplicationContextAware接口,注入ApplicationContext,即Spring的应用上下文,获取bean。

图片

在start()方法中,

1.获取所有的bean;

2.遍历每个bean,查找bean中是否有字段用了@RpcConsumer注解;

3.对被标记了的@RpcConsumer的字段进行遍历;

4.获取到该字段的类型,全限定名;

5.使用动态代理的方式创建消费者对象;

6.把代理对象赋值给空字段。

图片

查找bean中的字段是否使用了@RpcConsumer注解,通过循环遍历的方式进行判断。不断向父类寻找,是因为bean本身可能被Spring进行了CGLIB增强,形成了一个代理类。

图片

使用Proxy创建代理对象。

图片

六、代理对象RpcInvocationHandler中定义了远程调用方法的逻辑。

图片

在invoke()方法中定义具体实现:1.判断是否本地方法,就不需要走远程调用;

2.封装请求参数;

3.发起远程调用;

4.处理调用结果。

图片

本地方法判断:即Object类中方法不需要被代理,不需要发起远程调用请求。

图片

RpcRequest封装了远程调用消费者端请求的数据结构:接口全限定名称、方法名称、方法参数。

图片

通过post方法发起远程调用,使用的是OkHttpClient。

图片

RpcResponse定义了消费者端的响应体数据结构:状态、响应结果数据、异常对象。

图片

处理调用结果:如果成功,就对调用结果数据进行反序列化;如果失败就封装异常信息。

图片

七、对各种情况的基本测试:

1.类对象参数的远程调用;2.本地方法的远程调用;3.基本参数类型的远程调用;4. String类型参数的远程调用;5. 另一个业务范围(订单服务)的远程调用;6. 嵌套注入的远程调用;7. 异常测试

图片

还有哪些问题?

  1. 默认使用的Java的动态代理,还有Spring的切面代理,CGLI增强,ByteBuddy的字节码
  2. 当前还是localhost请求,后续应该是走网络请求。
  3. 基本类型参数并不完整,如果是Double类型参数可能会报错。

工程地址:https://github.com/midnight2104/midnight-rpc

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/764374.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Puppet 2024年度报告:平台工程发掘 DevOps 无限潜质

Puppet 于本周发布了一份2024年的 DevOps 现状报告 The State of DevOps Report: The Evolution of Platform Engineering。该报告显示了平台工程的持续成熟,43%的受访者报告称他们的平台团队已经存在至少3-5年。 自2012年以来,Puppet 每年发布的关于 De…

后端程序员入门react笔记(九)- react 插件使用

setState setState引起的react的状态是异步的。操作完毕setState之后如果直接取值,可能取不到最新的值,我们举个例子console.log(this.state.num)打印的值,总是上一次的值而不是最新的。 import React, {Component} from react; class Ap…

基于ArcGIS的2015-2020辽宁省土地利用变化分析

数据准备 栅格转面 运行ArcToolbox,打开【转换工具】,选择【从栅格转出】里面的【栅格转面工具】,调出面板进行参数设置。输入栅格选择裁剪的2015年中国土地利用遥感监测数据(…

Kafka批量消费

在Spring Kafka中,使用KafkaListener注解处理批量信息时,首先需要开启批量监听模式,并配置相应的consumer参数来控制批量消费行为。以下是配置和处理批量消息的基本步骤: 配置Kafka消费者工厂: 设置batchListener属性为…

数据挖掘与分析学习笔记

一、Numpy NumPy(Numerical Python)是一种开源的Python库,专注于数值计算和处理多维数组。它是Python数据科学和机器学习生态系统的基础工具包之一,因为它高效地实现了向量化计算,并提供了对大型多维数组和矩阵的支持…

复习Day1

92. 递归实现指数型枚举 - AcWing题库 #include <bits/stdc.h> using namespace std; const int N17; int n; bool vis[N];//记录某一个数是否出现过 void dfs(int dep){// if(vis[dep])continue;//没有这一句 因为一定不会有已经选过的数if(depn1){for(int i1;i<n;i…

【Node.js从基础到高级运用】十七、Node.js的性能优化

引言 在软件开发的世界里&#xff0c;性能优化是一个永恒的话题。Node.js作为一个基于Chrome V8引擎的JavaScript运行时&#xff0c;它的性能优化尤为重要。因为Node.js的非阻塞I/O和事件驱动特性&#xff0c;使得它在处理大量并发请求时表现出色。但是&#xff0c;这并不意味着…

【ReactJS】使用GoJS实现自己的图表App

目录 1:用于绘制自定义图表的JavaScript库:用于绘制UML(或BPMN或ERD …)图表的JavaScript库:2:为什么选择GoJS?3:让我们使用现有的React应用程序:步骤1:步骤2:步骤3:步骤4:推荐超级课程: Docker快速入门到精通Kubernetes入门到大师通关课AWS云服务快速入门实战1:…

git创建仓库、克隆、拉取、上传、历史等常见操作集锦

本地工作目录、暂存区、本地仓库和远程仓库 workspace工作区:本地项目地址index/stage暂存区:git add .将工作区内容加入到了暂存区repository本地仓库:在本地存储多个版本的文件,也称为版本库。其中有一个head指针指向最新放入仓库的文件版本,git commit -m "描述你…

[医学分割大模型系列] (1) SAM 分割大模型解析

[医学大模型系列] [1] SAM 分割大模型解析 1. 特点2. 网络结构2.1 Image encoder2.2 Prompt encoder2.3 Mask decoder 3. 数据引擎4. 讨论 论文地址&#xff1a;Segment Anything 开源地址&#xff1a;https://github.com/facebookresearch/segment-anything demo地址&#x…

C#,图片分层(Layer Bitmap)绘制,反色、高斯模糊及凹凸贴图等处理的高速算法与源程序

1 图像反色Invert 对图像处理的过程中会遇到一些场景需要将图片反色,反色就是取像素的互补色,比如当前像素是0X00FFFF,对其取反色就是0XFFFFFF – 0X00FFFF = 0XFF0000,依次对图像中的每个像素这样做,最后得到的就是原始2 图像的反色。 2 高斯模糊(Gauss Blur)算法 …

Word中文字重叠在一起怎么办

Word中文字重叠在一起怎么办 在编辑Word文档时&#xff0c;按照文档排版的设计&#xff0c;对其中的文字设置了字体和字号&#xff0c;没有设置以前&#xff0c;文字在Word中显示是正常的&#xff0c;不过&#xff0c;设置了字体字号后&#xff0c;文字在文档就却重叠在一起了&…

关于Linux环境下的LXD及Docker提权

希望和各位大佬一起学习&#xff0c;如果文章内容有错请多多指正&#xff0c;谢谢&#xff01; 个人博客链接&#xff1a;CH4SER的个人BLOG – Welcome To Ch4sers Blog 0x01 基本概念 LXD、LXC 和 Docker 是三种不同的容器化技术&#xff0c;它们在实现和使用上有一些区别。…

RabbitTemplate :简化与 RabbitMQ 消息代理的交互

RabbitTemplate 是 Spring AMQP 项目中提供的一个核心类&#xff0c;用于简化与 RabbitMQ 消息代理的交互。在 Spring 应用程序中&#xff0c;使用 RabbitTemplate 可以方便地发送和接收消息&#xff0c;从而简化了 RabbitMQ 的使用。 一、RabbitTemplate 概述 RabbitTemplat…

cesium知识点:坐标系

一&#xff0c;地理坐标系 1.经纬度坐标系 对象&#xff1a;没有实际的对象 说明&#xff1a;cesium默认使用WGS84坐标系作为空间参考&#xff0c;坐标原点在椭球的质心。 2.弧度坐标系(Cartographic) 对象&#xff1a;new Cesium.Cartographic(longitude, latitude, heigh…

easyExcel大数据量导出oom

easyExcel大数据量导出 异常信息 com.alibaba.excel.exception.ExcelGenerateException: java.lang.OutOfMemoryError: GC overhead limit exceededat com.alibaba.excel.write.ExcelBuilderImpl.fill(ExcelBuilderImpl.java:84)at com.alibaba.excel.ExcelWriter.fill(Excel…

AI智能分析网关V4养老院视频智能监控方案

随着科技的快速发展&#xff0c;智能监控技术已经广泛应用于各个领域&#xff0c;尤其在养老院这一特定场景中&#xff0c;智能监控方案更是发挥着不可或缺的作用。尤其是伴随着社会老龄化趋势的加剧&#xff0c;养老院的安全管理问题也日益凸显。为了确保老人的生活安全&#…

yarn安装包时报错error Error: certificate has expired

安装教程&#xff1a; 配置镜像地址&#xff1a; npm config set registry https://registry.npmmirror.com//镜像&#xff1a;https://developer.aliyun.com/mirror/NPM 安装yarn&#xff1a; npm install --global yarn查看版本&#xff1a; yarn --version卸载&#xff…

每日五道java面试题之springboot篇(一)

目录&#xff1a; 第一题. 什么是 Spring Boot&#xff1f;第二题. Spring Boot 有哪些优点&#xff1f;第三题. Spring Boot 的核心注解是哪个&#xff1f;它主要由哪几个注解组成的&#xff1f;第四题. 什么是 JavaConfig&#xff1f;第五题. Spring Boot 自动配置原理是什么…