如何使用Golang实现RPC调用_Golang RPC通信方法与示例

net/rpc.Register不生效主因是注册对象非导出结构体指针、未在ServeConn前注册,且方法需大写、接收者为指针、参数返回值可gob编码,签名须为func(T,Args,*Reply)error。

Go 标准库的 net/rpc 支持基于 TCP 或 HTTP 的 RPC,但默认只支持 Go 客户端调用 Go 服务端,且要求双方使用相同的编码协议(如 gob)。跨语言或生产环境建议改用 gRPC,但若只是内部轻量服务互通,net/rpc 仍可快速落地。

为什么 rpc.Register 不生效?

常见原因是注册对象不是导出(首字母大写)的结构体指针,或未在 rpc.ServeConn 前完成注册。Go 的 RPC 只能导出方法:方法名必须大写、接收者必须是指针、参数和返回值类型必须可被 gob 编码。

  • rpc.Register 必须传入指针:rpc.Register(&MyService{}),而非 rpc.Register(MyService{})
  • 服务结构体字段和方法名必须首字母大写(如 DoWork),否则无法被序列化和反射调用
  • 每个方法签名必须严格为 func(*T, *Args, *Reply) error,其中 *Args*Reply 都需是导出结构体指针

如何用 HTTP 协议暴露 RPC 服务?

标准库支持将 RPC 服务挂载到 HTTP handler 上,便于调试或与反向代理集成。关键在

于调用 rpc.HandleHTTP() 后启动 HTTP server,并确保监听路径为 /rpc(默认)。

  • 服务端启动时需先调用 rpc.Register,再调用 rpc.HandleHTTP()
  • HTTP 模式下,客户端必须用 rpc.DialHTTP 连接,不能用 rpc.Dial
  • HTTP handler 默认注册两个路径:/rpc(用于 RPC 调用)和 /debug/rpc(用于查看已注册方法)
package main

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

type Args struct { A, B int }

type Arith int

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

func main() { rpc.Register(new(Arith)) rpc.HandleHTTP() log.Fatal(http.ListenAndServe(":1234", nil)) }

客户端连接失败:dial tcp: lookup xxx: no such host 是什么问题?

这是 DNS 解析失败,不是 RPC 协议问题。常见于客户端用主机名(如 "myserver:1234")连接,但宿主环境无法解析该域名。最稳妥的方式是用 IP + 端口直连,或确保 /etc/hosts 或 DNS 配置正确。

  • 检查服务端是否真实监听在对应地址:运行 netstat -tuln | grep 1234,确认是 0.0.0.0:1234127.0.0.1:1234,而非仅 localhost:1234
  • 若服务端绑定的是 localhost,Docker 容器内客户端无法访问;应改用 0.0.0.0
  • 防火墙或 SELinux 可能拦截端口,临时关闭验证:sudo ufw disable(Linux)

如何让 RPC 支持 JSON 编码?

标准 net/rpc 支持插件式编解码器,只需用 rpc.NewServer() 替代全局默认 server,并注册 jsonrpc.NewServerCodec。但注意:JSON 编码不支持 Go 特有类型(如 time.Timemap[interface{}]interface{}),且方法名必须匹配 JSON 字段规则(首字母大写即为 PascalCase)。

  • 服务端需手动处理连接:接收 net.Conn 后调用 server.ServeCodec(jsonrpc.NewServerCodec(conn))
  • 客户端需用 jsonrpc.NewClientCodec 构造 codec,再传给 rpc.NewClient
  • JSON RPC 无内置 HTTP 封装,若需走 HTTP,应直接用 net/http + json 手写,或换用 gorilla/rpc

真正容易被忽略的是错误传播:RPC 方法里 panic 会导致连接中断,且错误不会透出堆栈;必须显式 return error。另外,net/rpc 没有超时控制,客户端 Call 会永久阻塞,务必用 context 包封装或自行加 channel select 超时。