科普向 -- 什么是RPC
科普向 – 什么是RPC
RPC,全称为远程过程调用(Remote Procedure Call
),是一种计算机通信协议,允许程序在不同的地址空间(通常是不同的计算机)上执行代码。RPC使得程序可以像调用本地函数一样调用远程函数,屏蔽了底层的网络通信细节。
RPC的基本工作原理如下:
- 客户端调用:客户端程序调用一个本地的代理函数(也称为存根,stub),这个函数封装了对远程函数的调用。
- 序列化请求:代理函数将调用参数序列化(也称为编组,marshalling)成一个标准格式,通常是字节流。
- 发送请求:序列化后的请求通过网络传输到远程服务器。
- 服务器接收请求:服务器上的代理函数接收请求并进行反序列化(解组,unmarshalling),恢复出原始的调用参数。
- 执行远程函数:服务器执行实际的远程函数,并将结果返回给代理函数。
- 返回结果:代理函数将结果序列化,并通过网络传回客户端。
- 客户端接收结果:客户端的代理函数接收并反序列化结果,然后将结果返回给原始调用者。
RPC的主要优点包括:
- 透明性:调用远程函数与调用本地函数的方式相同,程序员无需关注底层的网络通信细节。
- 模块化:可以将不同功能模块分布在不同的服务器上,提高系统的可扩展性和可靠性。
常见的RPC框架和协议包括:
- gRPC:由Google开发的高性能RPC框架,基于HTTP/2和Protocol Buffers。
- XML-RPC:基于XML的RPC协议,使用HTTP作为传输协议。
- JSON-RPC:基于JSON的RPC协议,简单易用。
- Thrift:由Apache开发的跨语言RPC框架,支持多种序列化格式和传输协议。
通过RPC,分布式系统中的各个组件能够高效地进行通信和协作,从而实现复杂的业务逻辑。
RPC(远程过程调用)不仅可以用于不同计算机之间的通信,也可以在同一台计算机上实现。这种情况下,RPC仍然有其应用价值,主要体现在以下几个方面:
- 模块化设计:通过RPC,可以将应用程序的不同模块分离为独立的服务,即使它们运行在同一台计算机上。这种设计方式有助于代码的组织和维护。
- 语言无关性:RPC可以用于不同编程语言之间的调用。例如,一个用Python编写的模块可以通过RPC调用一个用C++编写的模块。
- 统一接口:即使在同一台计算机上,不同模块之间的通信也可以通过统一的接口进行,简化了开发和调试过程。
- 模拟分布式环境:在开发和测试阶段,可以先在本地实现和测试RPC调用,然后再部署到实际的分布式环境中。
在同一台计算机上实现RPC的具体方法与跨计算机实现RPC的基本原理相同。常见的实现方式包括:
- 本地环回网络接口(localhost):即使在同一台计算机上,也可以通过环回地址(127.0.0.1)进行网络通信。
- 共享内存:一些高性能的RPC实现可能会利用共享内存来传递数据,以减少网络通信的开销。
- 管道(Pipes):在同一台计算机上,不同进程之间可以通过管道进行通信。
下面是一个使用Python和gRPC
在同一台计算机上实现RPC的简单示例:
1. 定义.proto文件:
syntax = "proto3";service ExampleService {rpc SayHello (HelloRequest) returns (HelloResponse);
}message HelloRequest {string name = 1;
}message HelloResponse {string message = 1;
}
2. 生成gRPC代码:
python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. example.proto
3. 实现服务器:
import grpc
from concurrent import futures
import example_pb2
import example_pb2_grpcclass ExampleServiceServicer(example_pb2_grpc.ExampleServiceServicer):def SayHello(self, request, context):return example_pb2.HelloResponse(message=f"Hello, {request.name}!")def serve():server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))example_pb2_grpc.add_ExampleServiceServicer_to_server(ExampleServiceServicer(), server)server.add_insecure_port('[::]:50051')server.start()server.wait_for_termination()if __name__ == '__main__':serve()
4. 实现客户端:
import grpc
import example_pb2
import example_pb2_grpcdef run():with grpc.insecure_channel('localhost:50051') as channel:stub = example_pb2_grpc.ExampleServiceStub(channel)response = stub.SayHello(example_pb2.HelloRequest(name='World'))print("Client received: " + response.message)if __name__ == '__main__':run()
通过这种方式,即使在同一台计算机上,客户端和服务器也可以通过RPC进行通信。
相关文章:
科普向 -- 什么是RPC
科普向 – 什么是RPC RPC,全称为远程过程调用(Remote Procedure Call),是一种计算机通信协议,允许程序在不同的地址空间(通常是不同的计算机)上执行代码。RPC使得程序可以像调用本地函数一样调…...

SpringBoot教程(二十四) | SpringBoot实现分布式定时任务之Quartz(基础)
SpringBoot教程(二十四) | SpringBoot实现分布式定时任务之Quartz(基础) 简介适用场景Quartz核心概念Quartz 存储方式Quartz 版本类型引入相关依赖开始集成方式一:内存方式(MEMORY)存储实现定时任务1. 定义任务类2. 定…...

【现代控制理论】第2-5章课后题刷题笔记
文章目录 第二章:线性控制系统的状态空间描述第三章:控制系统状态空间描述的特性3.1 计算状态转移矩阵(矩阵指数函数)3.2 计算系统的时间响应(状态方程的解)3.3 判断系统的能控性和能观性,以及能…...
(四)Proteus仿真STM32单片机使用定时器控制LED
(四)Protues仿真STM32单片机使用定时器控制LED – ARMFUN 定时器在单片机中具有重要的作用,它可以提供精确的时间控制和事件触发功能。相比之下,使用延时函数(delay function)来实现时间控制存在以下一些坏…...

Python快速编程小案例——打印蚂蚁森林植树证书
提示:(个人学习),案例来自工业和信息化“十三五”人才培养规划教材,《Python快速编程入门》第2版,黑马程序员◎编著 蚂蚁森林是支付宝客户端发起“碳账户”的一款公益活动:用户通过步行地铁出行、在线消费等…...

Cherno游戏引擎笔记(61~72)
---------------一些维护和更改------------- 》》》》 Made Win-GenProjects.bat work from every directory 代码更改: echo off->pushd ..\->pushd %~dp0\..\call vendor\bin\premake\premake5.exe vs2019popdPAUSE 为什么要做这样的更改? …...

FWA(固定无线接入),CPE(客户终端设备)简介
文章目录 FWA(Fixed Wireless Access),固定无线接入CPE(Customer Premise Equipment),用户驻地设备 FWA(Fixed Wireless Access),固定无线接入 固定无线接入(…...

使用IDEA启动项目build时,解决Java编译时内存溢出问题:OutOfMemoryError深入解析
文章目录 简介问题描述解决方案常见解决方案示例代码示例1:增加JVM堆内存代码示例2:检查并修复内存泄漏代码示例3:分批编译代码示例4:使用编译器参数减少内存使用代码示例5:升级编译器和库 结论进一步的资源 简介 在J…...
Kafka如何实现高可用
Kafka实现高可用性主要依赖于其副本机制和Leader选举。以下是Kafka实现高可用的关键点: 多副本机制:Kafka中的每个分区(Partition)都有多个副本(Replica),这些副本分布在不同的Broker上。其中一…...
高级java每日一道面试题-2024年10月1日-服务器篇[Redis篇]-Redis数据结构压缩列表和跳跃表的区别?
如果有遗漏,评论区告诉我进行补充 面试官: Redis数据结构压缩列表和跳跃表的区别? 我回答: 关于Redis数据结构的理解是一个重要的考察点,特别是压缩列表(ziplist)和跳跃表(skiplist)这两种数据结构&…...
使用 ElLoading 组件来实现加载(loading)功能
在 Element Plus 中,你可以使用 ElLoading 组件来实现加载(loading)功能。ElLoading 通常用于在数据加载或某些异步操作进行时,向用户展示一个覆盖整个页面的加载提示。 以下是如何在你的 Vite Vue 3 JavaScript 项目中使用 El…...

Win10 IDEA连接虚拟机中的Hadoop(HDFS)
获取虚拟机的ip 虚拟机终端输入 ip a关闭虚拟机防火墙 sudo ufw disable修改Hadoop的core-site.xml文件 将localhost修改为虚拟机局域网IP # 位置可能不一样,和Hadoop安装位置有关 cd /usr/local/hadoop/etc/hadoop vim core-site.xmlIDEA 连接 创建Maven项目…...
tp8自带的文件缓存如何配置
TP8自带的缓存是文件缓存。 ThinkPHP6默认的缓存驱动是文件缓存,它将缓存数据存储在应用的runtime目录下的cache目录中。文件缓存适用于单机环境下的应用,对于数据量较小且读写频率较低的应用场景,是一种简单有效的缓存方案。 ThinkPHP8…...

【环境搭建】MAC M1安装ElasticSearch
STEP1 官网下载ES Download Elasticsearch | Elastic,下载mac m1对应版本的es STEP2 进入bin文件夹,执行./elasticSearch 浏览器输入 127.0.0.1:9200 STEP 3 下载对应Kibana版本,Download Kibana Free | Get Started Now | Elastic 出现报错…...

[linux 驱动]网络设备驱动详解
目录 1 描述 2 结构体 2.1 net_device 2.2 sk_buff 2.3 net_device_ops 2.4 ethtool_ops 3 相关函数 3.1 网络协议接口层 3.1.1 dev_queue_xmit 3.1.2 netif_rx 3.1.3 alloc_skb 3.1.4 kfree_skb 3.1.5 skb_put 3.1.6 skb_push 3.1.7 skb_reserve 3.2 网络设备驱…...
【ShuQiHere】 重新定义搜索:本体搜索引擎的时代
🌐 【ShuQiHere】 什么是本体搜索引擎?🤖 本体搜索引擎(Ontological Search Engine, OSE) 是一种基于语义理解和本体结构的智能搜索工具。与传统的关键词搜索不同,本体搜索引擎能够理解搜索背后的深层语义…...

Ruby脚本:自动化网页图像下载的实践案例
随着互联网的快速发展,网页上的内容变得越来越丰富,尤其是图像资源。对于需要大量图像资源的设计师、内容创作者或数据分析师来说,手动下载这些图片不仅耗时耗力,而且效率低下。因此,自动化网页图像下载成为了一个迫切…...

ArcGIS中分区统计栅格值前需要进行投影吗(在投影坐标系下进行吗),为什么?
最近,我接到了一个分区统计栅格数值前需要进行投影,或者说是必须需要在投影坐标系下进行吗的咨询。 答案是不需要刻意去变。 但是他又说他把地理坐标系下分区统计结果与投影坐标系下的分区统计结果分别做了一遍,并进行了对比,两个…...

怎么将视频原声提出来?视频原声提取,让创作更自由
在数字媒体时代,视频已成为我们日常生活和工作中不可或缺的一部分。有时,我们可能想要提取视频中的音频部分,无论是为了制作音频素材、学习语言,还是为了其他创意用途。那么,怎么将视频原声提出来呢?本文将…...

在IDEA里用XDebug调试PHP,断点....
做程序开发,调试必不可少,这里最近用到了PHP,顺便写个关于PHP的调试安装使用: 1、首先是PHP先安装xdebug扩展(还有zend的),这个我的工具是IDEA,所以安装方法也相对简单,如果你是用VSCode等应该也是一样,如下图,找到这个PHP->DEBUG 2、直接点上面的Install XDebug 就可以帮你…...

地震勘探——干扰波识别、井中地震时距曲线特点
目录 干扰波识别反射波地震勘探的干扰波 井中地震时距曲线特点 干扰波识别 有效波:可以用来解决所提出的地质任务的波;干扰波:所有妨碍辨认、追踪有效波的其他波。 地震勘探中,有效波和干扰波是相对的。例如,在反射波…...
数据链路层的主要功能是什么
数据链路层(OSI模型第2层)的核心功能是在相邻网络节点(如交换机、主机)间提供可靠的数据帧传输服务,主要职责包括: 🔑 核心功能详解: 帧封装与解封装 封装: 将网络层下发…...
【android bluetooth 框架分析 04】【bt-framework 层详解 1】【BluetoothProperties介绍】
1. BluetoothProperties介绍 libsysprop/srcs/android/sysprop/BluetoothProperties.sysprop BluetoothProperties.sysprop 是 Android AOSP 中的一种 系统属性定义文件(System Property Definition File),用于声明和管理 Bluetooth 模块相…...
【Web 进阶篇】优雅的接口设计:统一响应、全局异常处理与参数校验
系列回顾: 在上一篇中,我们成功地为应用集成了数据库,并使用 Spring Data JPA 实现了基本的 CRUD API。我们的应用现在能“记忆”数据了!但是,如果你仔细审视那些 API,会发现它们还很“粗糙”:有…...

Spring数据访问模块设计
前面我们已经完成了IoC和web模块的设计,聪明的码友立马就知道了,该到数据访问模块了,要不就这俩玩个6啊,查库势在必行,至此,它来了。 一、核心设计理念 1、痛点在哪 应用离不开数据(数据库、No…...

接口自动化测试:HttpRunner基础
相关文档 HttpRunner V3.x中文文档 HttpRunner 用户指南 使用HttpRunner 3.x实现接口自动化测试 HttpRunner介绍 HttpRunner 是一个开源的 API 测试工具,支持 HTTP(S)/HTTP2/WebSocket/RPC 等网络协议,涵盖接口测试、性能测试、数字体验监测等测试类型…...
Git常用命令完全指南:从入门到精通
Git常用命令完全指南:从入门到精通 一、基础配置命令 1. 用户信息配置 # 设置全局用户名 git config --global user.name "你的名字"# 设置全局邮箱 git config --global user.email "你的邮箱example.com"# 查看所有配置 git config --list…...
k8s从入门到放弃之HPA控制器
k8s从入门到放弃之HPA控制器 Kubernetes中的Horizontal Pod Autoscaler (HPA)控制器是一种用于自动扩展部署、副本集或复制控制器中Pod数量的机制。它可以根据观察到的CPU利用率(或其他自定义指标)来调整这些对象的规模,从而帮助应用程序在负…...
SQL进阶之旅 Day 22:批处理与游标优化
【SQL进阶之旅 Day 22】批处理与游标优化 文章简述(300字左右) 在数据库开发中,面对大量数据的处理任务时,单条SQL语句往往无法满足性能需求。本篇文章聚焦“批处理与游标优化”,深入探讨如何通过批量操作和游标技术提…...
统计学(第8版)——统计抽样学习笔记(考试用)
一、统计抽样的核心内容与问题 研究内容 从总体中科学抽取样本的方法利用样本数据推断总体特征(均值、比率、总量)控制抽样误差与非抽样误差 解决的核心问题 在成本约束下,用少量样本准确推断总体特征量化估计结果的可靠性(置…...