golang学习笔记27——golang 实现 RPC 模块

  • 推荐学习文档
    • golang应用级os框架,欢迎star
    • golang应用级os框架使用案例,欢迎star
    • 案例:基于golang开发的一款超有个性的旅游计划app经历
    • golang实战大纲
    • golang优秀开发常用开源库汇总
    • 想学习更多golang知识,这里有免费的golang学习笔记专栏

文章目录

    • 引言
    • Go 中 RPC 的基础知识
      • 1.RPC 服务端
      • 2.RPC 客户端
    • 代码示例
      • 1.定义 RPC 服务
      • 2.实现 RPC 客户端
    • 使用 JSON-RPC
    • 总结

引言

RPC(Remote Procedure Call)远程过程调用,它允许不同的进程在网络上进行通信,就像调用本地函数一样。在 Go 语言中,实现 RPC 模块相对简洁且高效。本文将详细介绍在 Go 语言中如何实现 RPC 模块。

Go 中 RPC 的基础知识

Go 标准库中的net/rpc包提供了对 RPC 的基本支持。

1.RPC 服务端

在服务端,我们需要定义一个对象,该对象的方法可以被远程调用。这些方法必须满足特定的规则:它们必须是公开的方法(首字母大写),并且必须有两个参数,第一个参数是接收请求的结构体指针,第二个参数是用于返回结果的结构体指针。

2.RPC 客户端

客户端可以像调用本地方法一样调用远程服务端的方法,只需要通过rpc.Dial建立连接后调用Call方法即可。

代码示例

1.定义 RPC 服务

首先,我们定义一个简单的服务,用于执行数学运算。

package mainimport ("errors""net/http""net/rpc"
)// Args 用于传递请求参数
type Args struct {A, B int
}// MathService 数学运算服务
type MathService struct{}// Add 加法运算
func (m *MathService) Add(args *Args, reply *int) error {if args == nil {return errors.New("invalid arguments")}*reply = args.A + args.Breturn nil
}func main() {// 注册服务mathService := new(MathService)rpc.Register(mathService)// 开启 HTTP 服务rpc.HandleHTTP()err := http.ListenAndServe(":1234", nil)if err!= nil {panic(err)}
}

在上述代码中,我们定义了一个MathService结构体,其中Add方法用于执行加法运算。这个方法接收一个Args结构体指针作为参数,将运算结果通过reply指针返回。在main函数中,我们注册了这个服务,并开启了一个 HTTP 服务来处理 RPC 请求。

2.实现 RPC 客户端

package mainimport ("fmt""log""net/rpc"
)func main() {// 连接到 RPC 服务端client, err := rpc.DialHTTP("tcp", "localhost:1234")if err!= nil {log.Fatal("dialing:", err)}// 准备请求参数args := Args{A: 3, B: 4}var reply int// 调用远程方法err = client.Call("MathService.Add", &args, &reply)if err!= nil {log.Fatal("arith error:", err)}// 输出结果fmt.Printf("The result of addition is: %d\n", reply)
}

在客户端代码中,我们首先通过rpc.DialHTTP连接到服务端。然后创建了一个Args结构体并设置了参数值。接着,我们调用client.Call方法来执行远程的Add方法,并将结果存储在reply变量中。

使用 JSON-RPC

除了使用 Go 标准的 RPC 编码,我们还可以使用 JSON-RPC。只需要将rpc.Register替换为rpc.RegisterName并指定编码为jsonrpc。

package mainimport ("errors""log""net/http""net/rpc""net/rpc/jsonrpc"
)// Args 用于传递请求参数
type Args struct {A, B int
}// MathService 数学运算服务
type MathService struct{}// Add 加法运算
func (m *MathService) Add(args *Args, reply *int) error {if args == nil {return errors.New("invalid arguments")}*reply = args.A + args.Breturn nil
}func main() {// 注册服务mathService := new(MathService)rpc.RegisterName("MathService", mathService)// 开启 HTTP 服务http.HandleFunc("/rpc", func(w http.ResponseWriter, r *http.Request) {jsonrpc.ServeRequest(rpc.DefaultServer, w, r)})// 启动服务log.Fatal(http.ListenAndServe(":1234", nil))
}

客户端的调用方式需要稍作修改:

package mainimport ("fmt""log""net/rpc/jsonrpc"
)func main() {// 连接到 RPC 服务端client, err := jsonrpc.Dial("tcp", "localhost:1234")if err!= nil {log.Fatal("dialing:", err)}// 准备请求参数args := Args{A: 3, B: 4}var reply int// 调用远程方法err = client.Call("MathService.Add", &args, &reply)if err!= nil {log.Fatal("arith error:", err)}// 输出结果fmt.Printf("The result of addition is: %d\n", reply)
}

总结

在 Go 语言中实现 RPC 模块非常方便,无论是使用标准的 RPC 编码还是 JSON-RPC。通过简单的几步:定义服务、注册服务、开启服务端以及在客户端进行调用,我们可以轻松地实现跨进程的远程过程调用。在实际应用中,可以根据具体的业务需求选择合适的 RPC 实现方式。

关注我看更多有意思的文章哦!👉👉

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

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

相关文章

golang学习笔记3-变量的声明

声明:本人已有C,C,Python基础,只写本人认为的重点,方便自己回顾。 一、变量的三种声明方式 func main() {//方式1,指定数据类型,声明后若不赋值,使用默认值//比如int的默认值是0,st…

尚品汇-H5移动端整合系统(五十五)

目录: (1)运行前端页面 (2)启动前端页面 (3)添加搜索分类接口 (4)购物车模块修改 (5)登录模块 (6)订单模块 &#…

Golang | Leetcode Golang题解之第423题从英文中重建数字

题目: 题解: func originalDigits(s string) string {c : map[rune]int{}for _, ch : range s {c[ch]}cnt : [10]int{}cnt[0] c[z]cnt[2] c[w]cnt[4] c[u]cnt[6] c[x]cnt[8] c[g]cnt[3] c[h] - cnt[8]cnt[5] c[f] - cnt[4]cnt[7] c[s] - cnt[6]…

【Verilog学习日常】—牛客网刷题—Verilog快速入门—VL16

使用8线-3线优先编码器Ⅰ实现16线-4线优先编码器 描述 ②请使用2片该优先编码器Ⅰ及必要的逻辑电路实现16线-4线优先编码器。优先编码器Ⅰ的真值表和代码已给出。 可将优先编码器Ⅰ的代码添加到本题答案中,并例化。 优先编码器Ⅰ的代码如下: module…

【CentOS 7 】设置密码命令

好久没用虚拟机,今天打开忘了密码,还好设置了快照,赶紧改密码 1.切换到 root 用户 sudo su -2.输入以下命令以更改 root 用户的密码: passwd root3.按照提示输入新的密码,然后再次输入以确认。

MyBatis 源码解析:TypeHandler 设计与自定义实现

引言 在 MyBatis 中,TypeHandler 是一个非常重要的接口,它的作用是将 Java 类型和数据库类型进行互相转换。当我们执行 SQL 查询或插入操作时,TypeHandler 决定了如何将 Java 对象转换为数据库字段类型,或将数据库字段转换为 Jav…

[python]从零开始的PySide安装配置教程

一、PySide是什么? PySide 是 Qt for Python 项目的一部分,它提供了与 PyQt 类似的功能,使开发者能够使用 Python 编程语言来构建基于 Qt 的图形用户界面 (GUI) 应用程序。PySide 是由 Qt 公司官方维护的,而 PyQt 则是由第三方开发…

【Pyside】pycharm2024配置conda虚拟环境

知识拓展 Pycharm 是一个由 JetBrains 开发的集成开发环境(IDE),它主要用于 Python 编程语言的开发。Pycharm 提供了代码编辑、调试、版本控制、测试等多种功能,以提高 Python 开发者的效率。 Pycharm 与 Python 的关系 Pycharm 是…

【JavaEE】——多线程(join阻塞,计算,引用,状态)

阿华代码,不是逆风,就是我疯,你们的点赞收藏是我前进最大的动力!!希望本文内容能够帮助到你! 目录 一:join等待线程结束 1:知识回顾 2:join的功能就是“阻塞等待” …

PyTorch 实现手写数字识别

PyTorch 实现手写数字识别 在本教程中,我们将使用 PyTorch 实现经典的手写数字识别任务。我们将使用 MNIST 数据集,这是一个包含手写数字的图像数据集。我们将介绍如何使用 PyTorch 构建、训练和评估一个简单的卷积神经网络(CNN)…

【linux】kill命令

kill 命令在 Linux 和类 Unix 系统中用于向进程发送信号,默认情况下是发送 SIGTERM(信号 15),请求程序终止运行。如果程序没有响应 SIGTERM 信号,可以使用 SIGKILL(信号 9)强制终止进程&#xf…

java之斗地主部分功能的实现

今天我们要实现斗地主中发牌和洗牌这两个功能,该如何去实现呢? 1.创建牌类:52张牌每一张牌包含两个属性:牌的大小和牌的花色。 故我们优先创建一个牌的类(Card):包含大小和花色。 public class Card { //单张牌的大小及类型/…

无人机+自组网:中继通信增强技术详解

无人机与自组网技术的结合,特别是通过中继通信增强技术,为无人机在复杂环境中的通信提供了稳定、高效、可靠的解决方案。以下是对该技术的详细解析: 一、无人机自组网技术概述 无人机自组网技术是一种利用无人机作为节点,通过无…

proteus仿真学习(1)

一,创建工程 一般选择默认模式,不配置pcb文件 可以选用芯片型号也可以不选 不选则从零开始布局,没有初始最小系统。选用则有初始最小系统以及基础的main函数 本次学习使用从零开始,不配置固件 二,上手软件 1.在元件…

6--SpringBootWeb案例(详解)

目录 环境搭建 部门管理 查询部门 接口文档 代码 删除部门 接口文档 代码 新增部门 接口文档 代码 已有前端,根据接口文档完成后端功能的开发 成品如下: 环境搭建 1. 准备数据库表 (dept 、 emp) -- 部门管理 create table dept( id int un…

深度学习自编码器 - 正则自编码器篇

序言 深度学习领域中,自编码器( Autoencoder \text{Autoencoder} Autoencoder)作为一种无监督学习技术,凭借其独特的结构在数据降维、特征提取、异常检测及数据去噪等方面展现出强大的能力。正则自编码器,作为自编码器…

ES5 在 Web 上的现状

最后一个支持 ES5 的浏览器 IE 11 在 2022 年被微软停止支持,那么今天 Web 上的 ES5 现状如何?在构建生产代码时,Web 开发者的最佳实践是什么? 本文将通过数据来回答这些问题,并基于这些数据为网站开发者和库作者提供一…

Delta Lake如何使用

1. 安装 Java 确保你的系统上安装了 Java 8 或更高版本。可以通过以下命令检查 Java 是否已安装: java -version2. 安装 Apache Spark 下载 Spark: 从 Apache Spark 官方网站 下载适合的版本,建议下载预编译的版本(例如&#xf…

如何有效检测住宅IP真伪?

在当今的互联网时代,住宅IP(即家庭用户通过宽带服务提供商获得的IP地址)在跨境电商、广告投放、网络安全等多个领域扮演着重要角色。然而,随着网络环境的复杂化和欺诈行为的增多,如何有效检测和辨别住宅IP的真伪成为了…

Spring:统一结果私有属性造成的前端无法访问异常报错问题

用户未填写任何评价 1.问题复现 (1)看一段代码 controller: import lombok.extern.slf4j.Slf4j; import org.ljy.testdemo.common.Result; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.w…