Golang的net/rpc包可实现远程过程调用，需定义符合规则的服务方法和数据结构；2. 服务端注册实例并监听HTTP端口，客户端通过Dial连接并调用远程方法；3. 异常处理需关注网络错误、超时及服务端返回错误，建议设置连接与调用超时；4. 默认使用gob编码，不支持跨语言，适用于轻量级内部通信。
在分布式系统中，RPC（Remote Procedure Call）是一种常见的通信方式。Golang标准库提供了net/rpc包，支持通过网络调用远程函数，就像调用本地方法一样。本文将介绍如何使用Golang实现RPC调用，并结合实际场景讲解异常处理的最佳实践。
定义RPC服务接口与数据结构
要使用Golang的RPC功能，首先需要定义服务端提供的方法和通信的数据结构。这些方法必须满足特定签名规则，才能被RPC框架识别。
例如，定义一个简单的算术服务：
type Args struct {
A, B int
}
<p>type Arith int</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">go语言免费学习笔记（深入）</a>”；</p><p>func (t <em>Arith) Multiply(args </em>Args, reply <em>int) error {
</em>reply = args.A * args.B
return nil
}</p>注意：方法必须是可导出的（首字母大写），且接收者是指针类型。参数必须是指针，返回值为error类型。这是net/rpc的基本要求。
启动RPC服务端
服务端需要注册服务实例，并监听网络连接。
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
func main() {
arith := new(Arith)
rpc.Register(arith)
rpc.HandleHTTP()
l, e := net.Listen("tcp", ":1234")
if e != nil {
log.Fatal("listen error:", e)
}
http.Serve(l, nil)
}
上面代码注册了Arith服务，并通过HTTP暴露RPC接口。默认路径为/rpc，使用gob编码传输数据。
编写RPC客户端进行调用
客户端通过rpc.Dial连接服务端，并调用远程方法。
client, err := rpc.DialHTTP("tcp", "127.0.0.1:1234")
if err != nil {
log.Fatal("dialing:", err)
}
args := &Args{A: 7, B: 8}
var reply int
err = client.Call("Arith.Multiply", args, &reply)
if err != nil {
log.Fatal("call failed:", err)
}
fmt.Printf("Multiply: %d*%d=%d\n", args.A, args.B, reply)
client.Call 是同步调用，会阻塞直到收到响应或发生错误。
RPC调用中的异常处理实践
RPC调用可能因网络、序列化、服务端逻辑等问题失败。正确处理这些异常是保障系统稳定的关键。
- 检查
client.Call返回的error：可能是网络中断、超时、服务不可达或服务端内部错误。 - 服务端方法返回的错误也会传递给客户端，可用于业务逻辑判断。
- 建议对RPC调用设置超时机制，避免长时间阻塞。
示例：添加超时控制
// 使用带超时的连接
client, err := net.DialTimeout("tcp", "127.0.0.1:1234", 5*time.Second)
if err != nil {
log.Fatal("dial timeout:", err)
}
defer client.Close()
<p>// 将连接包装为RPC客户端
rpcClient := rpc.NewClient(client)
defer rpcClient.Close()</p><p>// 设置Call超时
done := make(chan error, 1)
go func() {
done <- rpcClient.Call("Arith.Multiply", args, &reply)
}()
select {
case err = <-done:
if err != nil {
log.Fatal("call error:", err)
}
case <-time.After(3 * time.Second):
log.Fatal("call timeout")
}</p>这种模式可以有效防止调用卡死，提升系统的容错能力。
常见问题与注意事项
-
编码格式限制：
net/rpc默认使用gob，客户端和服务端必须都使用相同编码。如需JSON支持，可使用net/rpc/jsonrpc。 -
方法签名严格：必须符合
func (t *T) MethodName(argType T1, replyType *T2) error格式。 - 无法跨语言：gob是Go专用格式，若需跨语言通信，建议使用gRPC或JSON-RPC。
- 错误信息传递：服务端panic会导致连接终止，应避免未捕获的异常。
基本上就这些。Golang的net/rpc简单易用，适合内部微服务通信或模块解耦。虽然功能不如gRPC强大，但在轻量级场景下仍具实用价值。关键是做好连接管理、超时控制和错误处理，才能构建健壮的远程调用系统。
