Golang使用RPC实现程序远程调用详解
作者：我叫黑大帅
RPC 让你在写代码时,调用另一台远程机器上的函数,就像调用本地的函数一样简单,下面小编就和大家详细介绍一下Golang如何使用RPC实现程序远程调用吧
net/rpc 则是为了让两个 Go 程序之间直接对话。
RPC 让你在写代码时，调用另一台远程机器上的函数，就像调用本地的函数一样简单。
Go 标准库中的 net/rpc 目前处于冻结状态（不再增加新功能）。在现代的实际工程中，大家通常会使用 gRPC 或 Kratos 等更强大的框架。
RPC 的核心规则
net/rpc 要求你的函数必须遵守特定的签名格式，才能被远程调用。
- 方法所属的类型必须是导出的（首字母大写）。
- 方法本身必须是导出的（首字母大写）。
- 方法必须有两个参数，且都必须是导出类型或内置类型。
- 方法的第二个参数必须是指针（因为服务器要把结果写回这个指针里）。
- 方法必须返回一个
error类型。
func (t *T) MethodName(args T1, reply *T2) error
常用 API
服务端 API
rpc.Register(rcvr any): 将你的结构体注册为 RPC 服务。结构体名默认就是服务名。rpc.HandleHTTP(): 如果你想让 RPC 走 HTTP 协议，调用这个注册路由。rpc.Accept(lis net.Listener): 如果你想走纯 TCP 协议，用这个接收连接。
客户端 API
rpc.Dial(network, address string): 连接远程 RPC 服务器（比如传 "tcp", "localhost:1234"）。rpc.DialHTTP(network, address string): 连接走 HTTP 协议的 RPC 服务器。client.Call(serviceMethod string, args any, reply any): 同步调用远程函数。程序会在这里等待结果返回。
实例：实现一个远程乘法计算器
提供方
package main
import (
"fmt"
"net"
"net/rpc"
)
// 1. 定义传入的参数结构体
type Args struct {
A, B int
}
// 2. 定义服务结构体
type MathService struct{}
// 3. 实现服务方法（严格遵守 5 条规则）
func (m *MathService) Multiply(args Args, reply *int) error {
*reply = args.A * args.B
fmt.Printf("服务端执行：计算 %d * %d\n", args.A, args.B)
return nil
}
func main() {
// 实例化服务
math := new(MathService)
// 注册 RPC 服务，客户端就可以通过 "MathService.Multiply" 来调用了
rpc.Register(math)
// 启动 TCP 监听
listener, err := net.Listen("tcp", ":1234")
if err != nil {
panic(err)
}
fmt.Println("RPC 服务端已启动，监听端口 1234...")
// 接收请求并处理
rpc.Accept(listener)
}
调用方
package main
import (
"fmt"
"log"
"net/rpc"
)
// 客户端 需要定义一样的参数结构体
type Args struct {
A, B int
}
func main() {
// 1. 拨号连接 RPC 服务器
client, err := rpc.Dial("tcp", "localhost:1234")
if err != nil {
log.Fatal("拨号失败:", err)
}
defer client.Close()
// 2. 准备参数和接收结果的变量
args := Args{A: 10, B: 20}
var reply int
// 3. 发起调用！ 第一个参数是 "结构体名.方法名"
err = client.Call("MathService.Multiply", args, &reply)
if err != nil {
log.Fatal("调用失败:", err)
}
fmt.Printf("调用成功！结果是: %d\n", reply)
}
到此这篇关于Golang使用RPC实现程序远程调用详解的文章就介绍到这了,更多相关Go RPC远程调用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！