当前位置: 首页 > news >正文

Go 中 RPC 的使用教程

前言

RPC(Remote Procedure Call)是一种允许程序调用远程服务器上函数的方法,调用过程对于开发者来说像是调用本地函数一样方便。Go 语言自带了强大的 net/rpc 库,能够让开发者轻松实现基于 Go 的 RPC 服务。本文将介绍 Go 中 RPC 的使用方法,并通过简单示例展示如何搭建 RPC 服务和客户端。


一、什么是 RPC?

RPC(远程过程调用)是一种跨网络通信协议,允许程序在不同的主机上执行代码而不需要明确处理底层网络通信。使用 RPC,开发者只需编写服务端的逻辑,然后客户端可以像调用本地函数一样调用服务端的函数,底层的网络传输、序列化和反序列化都由 RPC 框架处理。

在 Go 中,RPC 是通过 net/rpc 包实现的,Go 标准库还支持 JSON-RPC 和 HTTP 传输协议。


二、Go 中 RPC 的基本原理

Go 中的 RPC 框架遵循以下几条规则:

  1. 服务对象是公开的结构体类型。
  2. 服务对象的方法必须是公开的,并且方法必须有两个参数和一个返回值。第一个参数是输入参数,第二个参数是指针类型用于接收返回结果,返回值是 error 类型。
  3. 客户端通过 net/rpc 库向服务端发出请求,服务端执行对应的函数,返回结果。

三、Go 中 RPC 的使用步骤

1. 定义服务

首先,我们需要定义一个服务。这个服务是一个 Go 结构体,其中包含一些方法供客户端调用。

package mainimport ("errors""net""net/rpc""fmt"
)// 定义服务结构体
type Arith struct{}// 定义输入参数
type Args struct {A, B int
}// 定义服务方法
func (t *Arith) Multiply(args *Args, reply *int) error {*reply = args.A * args.Breturn nil
}func (t *Arith) Divide(args *Args, reply *int) error {if args.B == 0 {return errors.New("divide by zero")}*reply = args.A / args.Breturn nil
}

在上面的代码中,我们定义了 Arith 结构体,它有两个方法 MultiplyDivide,分别用于乘法和除法运算。

2. 启动 RPC 服务

接下来,我们需要启动一个 RPC 服务器,让客户端可以通过网络调用这个服务。

func main() {arith := new(Arith)rpc.Register(arith)  // 注册服务listener, err := net.Listen("tcp", ":1234")  // 监听端口if err != nil {fmt.Println("Error starting server:", err)}fmt.Println("Server is listening on port 1234...")for {conn, err := listener.Accept()  // 接收连接if err != nil {fmt.Println("Error accepting connection:", err)continue}go rpc.ServeConn(conn)  // 使用 goroutine 处理每个连接}
}

这段代码启动了一个监听在 1234 端口的 RPC 服务器。每当有客户端请求连接时,服务器会处理该连接并执行相应的 RPC 方法。

3. 创建 RPC 客户端

服务端已经准备好了,接下来我们需要编写客户端代码,客户端将通过 RPC 远程调用服务端的函数。

package mainimport ("fmt""log""net/rpc"
)type Args struct {A, B int
}func main() {client, err := rpc.Dial("tcp", "localhost:1234")  // 连接服务端if err != nil {log.Fatal("dialing:", err)}// 调用 Multiply 方法args := Args{A: 7, B: 8}var reply interr = client.Call("Arith.Multiply", args, &reply)if err != nil {log.Fatal("arith error:", err)}fmt.Printf("Arith: %d * %d = %d\n", args.A, args.B, reply)// 调用 Divide 方法args = Args{A: 10, B: 2}err = client.Call("Arith.Divide", args, &reply)if err != nil {log.Fatal("arith error:", err)}fmt.Printf("Arith: %d / %d = %d\n", args.A, args.B, reply)
}

在这段代码中,客户端首先通过 rpc.Dial 函数连接到服务端。连接建立后,客户端调用远程的 MultiplyDivide 方法,并输出结果。

4. 运行程序

首先在一个终端启动服务端:

go run server.go

然后在另一个终端运行客户端:

go run client.go

运行后,客户端会输出类似以下内容:

Arith: 7 * 8 = 56
Arith: 10 / 2 = 5

四、Go 中的 RPC 进阶

1. 异步调用

Go 的 RPC 框架支持异步调用,可以通过 Go 方法实现。它会返回一个 Call 对象,通过该对象可以获取异步调用的结果。

call := client.Go("Arith.Multiply", args, &reply, nil)
replyCall := <-call.Done  // 等待结果
fmt.Printf("Async result: %d * %d = %d\n", args.A, args.B, replyCall.Reply)

2. 使用 HTTP 作为传输协议

Go 也支持通过 HTTP 协议进行 RPC 通信,只需稍加配置:

rpc.HandleHTTP()
listener, err := net.Listen("tcp", ":1234")
go http.Serve(listener, nil)

在客户端中,通过 rpc.DialHTTP 连接服务端:

client, err := rpc.DialHTTP("tcp", "localhost:1234")

五、总结

通过 net/rpc,Go 提供了一个简单而高效的 RPC 实现。它让开发者可以轻松地构建分布式系统,并且底层的通信和序列化都由库自动处理,极大地降低了开发复杂性。本文通过一个简单的示例展示了如何在 Go 中使用 RPC,希望能为你的开发提供帮助。

相关文章:

Go 中 RPC 的使用教程

前言 RPC&#xff08;Remote Procedure Call&#xff09;是一种允许程序调用远程服务器上函数的方法&#xff0c;调用过程对于开发者来说像是调用本地函数一样方便。Go 语言自带了强大的 net/rpc 库&#xff0c;能够让开发者轻松实现基于 Go 的 RPC 服务。本文将介绍 Go 中 RP…...

挖耳勺可以伸进耳朵多深?安全可视挖耳勺推荐!

一般来说&#xff0c;挖耳勺不应该伸进耳朵太深&#xff0c;外耳道的长度大约在2.5厘米到3.5厘米之间&#xff0c;但不建议将挖耳勺伸进超过外耳道外1/3的深度&#xff0c;也就是大概1厘米左右较为安全。因为如果伸得太深&#xff0c;很容易损伤外耳道皮肤&#xff0c;引起疼痛…...

SuperMap GIS基础产品FAQ集锦(20240911)

一、SuperMap iObjects Java 问题1&#xff1a;【iObject Python】Objects Python产品有哪些能力特性和优势&#xff1f; 11.2.0 【解决办法】iObjects Python产品包含传统GIS功能&#xff08;基于iObjects Java扩展的功能接口&#xff09;和AI GIS功能模块。 其中传统GIS功能…...

从状态管理到性能优化:全面解析 Android Compose

文章目录 引言一、Android Compose基本概念1.1 什么是Android Compose?1.2 Compose的优势1.3 如何在项目中使用Compose 二、Compose中的状态管理2.1 状态管理的重要性2.2 Compose中的状态和数据流2.3 使用State和MutableState处理状态2.4 通过ViewModel进行状态管理 三、Compo…...

ChatGPT提示词优化大师使用指南

我希望你成为我的ChatGPT提示词优化大师。 您的目标是帮助我根据自己的需要制定尽可能最好的提示。 你提供的提示应该是站在我向ChatGPT发起请求的角度来写的。我的初始提示词如下&#xff1a;此处填入你的初始提示词 ChatGPT提示词生成器 我希望你充当提示词生成器。 比如&…...

计算机毕业设计 智能推荐旅游平台 Java+SpringBoot+Vue 前后端分离 文档报告 代码讲解 安装调试

&#x1f34a;作者&#xff1a;计算机编程-吉哥 &#x1f34a;简介&#xff1a;专业从事JavaWeb程序开发&#xff0c;微信小程序开发&#xff0c;定制化项目、 源码、代码讲解、文档撰写、ppt制作。做自己喜欢的事&#xff0c;生活就是快乐的。 &#x1f34a;心愿&#xff1a;点…...

【拥抱AI】基于多种数据分段工具的优缺点分析

最近在深入了解RAG方面的知识&#xff0c;其中数据清洗和数据分段是创建知识库的重要步骤。数据清洗目前暂时选用了MinerU&#xff0c;然后就需要针对数据分段进行选型。 以下是我了解到的几种数据分段工具&#xff0c;简单总结了一下它们的优缺点&#xff0c;权当笔记分享&am…...

在 Windows 系统上,文件传输到虚拟机(VM)可以通过 VS Code 的图形界面(GUI)或命令行工具进行操作

在 Windows 系统上&#xff0c;文件传输到虚拟机&#xff08;VM&#xff09;可以通过 VS Code 的图形界面&#xff08;GUI&#xff09;或命令行工具进行操作。以下是几种方法&#xff1a; ### 方法 1: 使用 VS Code 图形界面 1. **连接到远程 VM**&#xff1a; - 在 VS Cod…...

kafka的主要功能

Apache Kafka 是一个分布式流处理平台&#xff0c;它最初由 LinkedIn 开发&#xff0c;后来捐赠给了 Apache Software Foundation&#xff0c;并成为了 Apache 的顶级项目。Kafka 设计用于处理实时数据流&#xff0c;并且提供了高性能、可扩展性和持久性。下面是 Kafka 的主要功…...

vue3中provide和inject详解

provide和inject是什么 provide 和 inject 是 Vue.js 框架中提供的一种依赖注入机制。这种机制允许一个祖先组件&#xff08;提供者&#xff09;向其所有子孙组件&#xff08;使用者&#xff09;提供数据或方法&#xff0c;而不需要通过逐层组件传递属性&#xff08;props&…...

相约华中科技大学,移动云技术论坛来了!NineData创始人CEO叶正盛将分享《数据库全球实时传输技术实践》的主题演讲

2024年9月12日&#xff0c;中国移动云能力中心将在华中科技大学举办“智算浪潮下数据库发展论坛”&#xff0c;共同探讨数据库技术与应用的创新&#xff0c;分享算力网络时代数据库未来发展的洞见。本次论坛&#xff0c;NineData 创始人&CEO 叶正盛受邀参会&#xff0c;并来…...

华为 昇腾 310P 系列 AI 处理器支持 140Tops 的 AI 算力。

1、产品简介 模组是基于昇腾 310P 系列 AI 处理器设计而成&#xff0c;可实现图像、视频等多种数据分析 与推理计算。超强的视频编解码能力以及支持 140Tops 的 AI 算力。在边缘侧及端侧的嵌入式计算 领域&#xff0c;有着极高的性价比&#xff0c;具有超强算力、 超高能效、…...

基于单片机的小型生态鱼缸控制器设计

本设计以STC89C52单片机为核心&#xff0c;利用DS18B20温度传感器和LCD1602液晶显示器实时采集和显示当前环境温度&#xff0c;并根据与预设温度阈值的比较结果控制加热棒或风扇进行加热或制冷操作。此外&#xff0c;该控制器还利用DS1302完成计时功能&#xff0c;在预设时间点…...

git-repo使用

即使用 XML 格式文件&#xff08;manifest 清单文件&#xff09;定义一个项目的多仓库关联&#xff0c;然后用 repo 客户端工具操作多仓库 git repo命令行格式&#xff1a; git repo <子命令> <参数>创建一个空目录&#xff0c;作为工作区。 $ mkdir workspace$ …...

如何设计实现完成一个FPGA项目

设计并完成一个FPGA项目是一个复杂但非常有价值的工程任务。以下是一个详细的步骤指南,帮助你从零开始完成一个FPGA项目。 1. 项目定义与需求分析 确定项目目标:明确项目要实现的功能和性能指标。需求分析:列出所有功能需求、性能需求、接口需求等。可行性分析:评估技术可…...

Oracle(106)如何实现透明数据加密?

透明数据加密&#xff08;TDE&#xff09;是一种用于保护数据库中静态数据的加密技术。TDE通过自动加密数据库文件和日志文件&#xff0c;确保数据在磁盘上是加密的&#xff0c;从而防止未经授权的访问。TDE的一个主要优点是它对应用程序是透明的&#xff0c;不需要对应用程序代…...

用Python实现时间序列模型实战——Day 18: 时间序列中的季节性与周期性预测

一、学习内容 1. 季节性调整与周期性预测 季节性调整 是在时间序列分析中常用的技术&#xff0c;旨在去除数据中因季节性波动导致的周期性变化&#xff0c;使数据更易于解释和预测。通常&#xff0c;我们可以使用季节性分解方法来分离时间序列中的趋势、季节性和随机成分。 …...

JavaScript ES6特性(var let const、function=>、增强表达赋值、类与对象)

一、var let const 1、var var明明定义在for里面的但是外部能够访问这个变量,说明var可以跨域访问。 2、let let明明定义在for里面的但是外部不能够访问这个变量,说明let不可以跨域访问。 3、const const foo = {}; // 为 foo 添加一个属性,可以成功 foo.prop = 123; fo…...

Paddle安装详解(CPU版本)

目录 1. 安装Python2. 安装paddle3. 验证3.1 初步验证3.2 将numpy版本从2.1.1降为2.0.13.3 再次验证1. 安装Python Python版本 C:\Users\james>python --version Python 3.12.62. 安装paddle 安装paddle及依赖库setuptools python -m pip install paddlepaddle==2.6.1 -…...

PHP即刻送达同城派送小程序系统

即刻送达&#xff0c;同城派送小程序系统让生活更便捷 &#x1f680; 瞬间连接&#xff0c;即刻送达的奇迹 你是否曾经因为等待快递而焦急万分&#xff1f;是否渴望有一种方式能让物品像魔法一样瞬间出现在你面前&#xff1f;现在&#xff0c;有了“即刻送达同城派送小程序系…...

零门槛NAS搭建:WinNAS如何让普通电脑秒变私有云?

一、核心优势&#xff1a;专为Windows用户设计的极简NAS WinNAS由深圳耘想存储科技开发&#xff0c;是一款收费低廉但功能全面的Windows NAS工具&#xff0c;主打“无学习成本部署” 。与其他NAS软件相比&#xff0c;其优势在于&#xff1a; 无需硬件改造&#xff1a;将任意W…...

基于大模型的 UI 自动化系统

基于大模型的 UI 自动化系统 下面是一个完整的 Python 系统,利用大模型实现智能 UI 自动化,结合计算机视觉和自然语言处理技术,实现"看屏操作"的能力。 系统架构设计 #mermaid-svg-2gn2GRvh5WCP2ktF {font-family:"trebuchet ms",verdana,arial,sans-…...

多场景 OkHttpClient 管理器 - Android 网络通信解决方案

下面是一个完整的 Android 实现&#xff0c;展示如何创建和管理多个 OkHttpClient 实例&#xff0c;分别用于长连接、普通 HTTP 请求和文件下载场景。 <?xml version"1.0" encoding"utf-8"?> <LinearLayout xmlns:android"http://schemas…...

C++ 求圆面积的程序(Program to find area of a circle)

给定半径r&#xff0c;求圆的面积。圆的面积应精确到小数点后5位。 例子&#xff1a; 输入&#xff1a;r 5 输出&#xff1a;78.53982 解释&#xff1a;由于面积 PI * r * r 3.14159265358979323846 * 5 * 5 78.53982&#xff0c;因为我们只保留小数点后 5 位数字。 输…...

(转)什么是DockerCompose?它有什么作用?

一、什么是DockerCompose? DockerCompose可以基于Compose文件帮我们快速的部署分布式应用&#xff0c;而无需手动一个个创建和运行容器。 Compose文件是一个文本文件&#xff0c;通过指令定义集群中的每个容器如何运行。 DockerCompose就是把DockerFile转换成指令去运行。 …...

django blank 与 null的区别

1.blank blank控制表单验证时是否允许字段为空 2.null null控制数据库层面是否为空 但是&#xff0c;要注意以下几点&#xff1a; Django的表单验证与null无关&#xff1a;null参数控制的是数据库层面字段是否可以为NULL&#xff0c;而blank参数控制的是Django表单验证时字…...

深度学习之模型压缩三驾马车:模型剪枝、模型量化、知识蒸馏

一、引言 在深度学习中&#xff0c;我们训练出的神经网络往往非常庞大&#xff08;比如像 ResNet、YOLOv8、Vision Transformer&#xff09;&#xff0c;虽然精度很高&#xff0c;但“太重”了&#xff0c;运行起来很慢&#xff0c;占用内存大&#xff0c;不适合部署到手机、摄…...

【FTP】ftp文件传输会丢包吗?批量几百个文件传输,有一些文件没有传输完整,如何解决?

FTP&#xff08;File Transfer Protocol&#xff09;本身是一个基于 TCP 的协议&#xff0c;理论上不会丢包。但 FTP 文件传输过程中仍可能出现文件不完整、丢失或损坏的情况&#xff0c;主要原因包括&#xff1a; ✅ 一、FTP传输可能“丢包”或文件不完整的原因 原因描述网络…...

Matlab实现任意伪彩色图像可视化显示

Matlab实现任意伪彩色图像可视化显示 1、灰度原始图像2、RGB彩色原始图像 在科研研究中&#xff0c;如何展示好看的实验结果图像非常重要&#xff01;&#xff01;&#xff01; 1、灰度原始图像 灰度图像每个像素点只有一个数值&#xff0c;代表该点的​​亮度&#xff08;或…...

解析“道作为序位生成器”的核心原理

解析“道作为序位生成器”的核心原理 以下完整展开道函数的零点调控机制&#xff0c;重点解析"道作为序位生成器"的核心原理与实现框架&#xff1a; 一、道函数的零点调控机制 1. 道作为序位生成器 道在认知坐标系$(x_{\text{物}}, y_{\text{意}}, z_{\text{文}}…...