Golang如何使用RPC进行跨服务通信-Golang-PHP中文网

Golang如何使用RPC进行跨服务通信

P粉602998670

发布： 2025-10-09 18:00:01

原创

956人浏览过

Go语言通过net/rpc包实现RPC通信，需定义符合规范的方法，如func (t Arith) Multiply(args Args, reply *int) error；服务端注册结构体实例并监听TCP端口，客户端通过rpc.Dial连接并用Call调用远程方法；默认使用gob编码，仅支持TCP，适用于Go间通信，生产环境建议用gRPC。

golang如何使用rpc进行跨服务通信

在Go语言中，使用RPC（Remote Procedure Call）进行跨服务通信是一种高效且简洁的方式。Golang标准库自带了net/rpc包，支持通过网络调用远程方法，就像调用本地函数一样。下面介绍如何使用Golang的RPC机制实现服务间通信。

RPC的基本要求和工作原理

Go的RPC基于函数签名有严格限制：方法必须是公开的，接收者是结构体指针，且方法参数必须是两个可序列化的参数，第一个是请求参数，第二个是返回结果，并且第二个参数是指针类型，返回值为error。

示例格式：

func (t *Arith) Multiply(args *Args, reply *int) error

其中Args是一个结构体，包含需要传递的字段。RPC默认使用Go的gob编码传输数据，因此客户端和服务端需共享结构体定义。

立即学习“go语言免费学习笔记（深入）”；

编写RPC服务端

服务端需要注册一个服务对象，并将其暴露在某个端口上监听请求。

步骤如下：

定义服务结构体和符合RPC规范的方法
使用rpc.Register注册服务
通过net.Listen开启TCP监听
使用rpc.Accept接受并处理连接

示例代码片段：

package main

import ( "net/rpc" "net" "log" )

type Args struct { A, B int }

type Arith int

AppMall应用商店

AI应用商店，提供即时交付、按需付费的人工智能应用服务

查看详情

func (t Arith) Multiply(args Args, reply int) error { reply = args.A * args.B return nil }

func main() { arith := new(Arith) rpc.Register(arith) l, e := net.Listen("tcp", ":1234") if e != nil { log.Fatal("listen error:", e) } rpc.Accept(l) }

编写RPC客户端

客户端通过TCP连接到服务端，调用远程方法。

主要步骤：

使用rpc.Dial建立与服务端的连接
准备请求参数
调用Call方法执行远程函数
获取返回结果或错误

示例代码：

package main

import ( "net/rpc" "log" )

type Args struct { A, B int }

func main() { client, err := rpc.Dial("tcp", "127.0.0.1:1234") if err != nil { log.Fatal("dialing:", err) } defer client.Close()

args := &Args{7, 8}
var reply int
err = client.Call("Arith.Multiply", args, &reply)
if err != nil {
    log.Fatal("call error:", err)
}
log.Printf("Result: %d", reply)

登录后复制

}