Go语言的RPC机制原生支持并发处理,服务端可同时响应多个客户端请求。通过定义共享结构体和符合RPC签名的方法,结合net/rpc与http包实现服务注册与监听,客户端使用goroutine并发调用,利用WaitGroup同步,5个2秒延迟请求约2秒完成,验证了并行处理能力。

Go语言的RPC(远程过程调用)机制原生支持并发处理,服务端可以同时处理多个客户端请求,而无需额外编写复杂的逻辑。下面通过一个简单的例子展示Golang中RPC服务端与客户端如何实现并发通信。
定义共享的数据结构和接口
为了在服务端和客户端之间通信,需要定义共用的结构体和方法签名。通常将这些内容放在一个独立的包中,或者直接在服务端定义并在客户端引用。假设我们要实现一个用户信息查询服务:
package maintype Args struct { ID int }
type User struct { ID int Name string Age int }
type UserService struct{}
立即学习“go语言免费学习笔记(深入)”;
UserService 提供一个方法 GetUser,用于根据ID返回用户信息。该方法需符合 RPC 方法签名格式:func (t *T) MethodName(args *Args, reply *Reply) error
实现RPC服务端
服务端注册 UserService 并启动监听,Go 的 net/rpc 包默认配合 net/http 处理请求。package mainimport ( "log" "net" "net/http" "net/rpc" )
func (s UserService) GetUser(args Args, reply User) error { // 模拟耗时操作,体现并发能力 time.Sleep(2 time.Second) *reply = User{ID: args.ID, Name: "User-" + fmt.Sprintf("%d", args.ID), Age: 20 + args.ID} return nil }
func main() { rpc.Register(new(UserService)) rpc.HandleHTTP()
l, e := net.Listen("tcp", ":1234") if e != nil { log.Fatal("listen error:", e) } log.Println("RPC server running on :1234") http.Serve(l, nil)}
注意:GetUser 方法模拟了 2 秒延迟,这样当我们并发调用时,能明显看出多个请求是并行处理的,而不是串行等待。
JSON入门指南 中文WORD版下载JSON 即 JavaScript Object Natation,它是一种轻量级的数据交换格式,非常适合于服务器与 JavaScript 的交互。本文将快速讲解 JSON 格式,并通过代码示例演示如何分别在客户端和服务器端进行 JSON 格式数据的处理。
编写并发RPC客户端
客户端通过 net/rpc 调用远程方法,并使用 goroutine 实现多个请求并发发送。package mainimport ( "fmt" "log" "net/rpc" "sync" "time" )
func callRPC(client rpc.Client, id int, wg sync.WaitGroup) { defer wg.Done()
args := &Args{ID: id} var user User start := time.Now() err := client.Call("UserService.GetUser", args, &user) if err != nil { log.Println("Call failed:", err) return } fmt.Printf("Got user: %+v (took %v)\n", user, time.Since(start))}
func main() { client, err := rpc.DialHTTP("tcp", "127.0.0.1:1234") if err != nil { log.Fatal("dialing:", err) } defer client.Close()
var wg sync.WaitGroup // 并发发起5个请求 for i := 1; i <= 5; i++ { wg.Add(1) go callRPC(client, i, &wg) } wg.Wait()}
在这个客户端中,我们使用 sync.WaitGroup 控制并发goroutine的生命周期,每个 callRPC 函数独立发起一次RPC调用。由于服务端是并发处理的,5个耗时约2秒的请求总共只需约2秒完成,而非10秒。
运行结果说明
启动服务端后运行客户端,输出类似:Got user: {ID:1 Name:User-1 Age:21} (took 2.002s) Got user: {ID:2 Name:User-2 Age:22} (took 2.003s) Got user: {ID:3 Name:User-3 Age:23} (took 2.004s) Got user: {ID:4 Name:User-4 Age:24} (took 2.005s) Got user: {ID:5 Name:User-5 Age:25} (took 2.006s)所有请求几乎在同一时间返回,说明服务端确实并发处理了它们。
基本上就这些。Golang的RPC机制简洁高效,结合goroutine天然支持高并发,适合内部微服务或模块间通信场景。虽然官方rpc包功能基础,但在不需要复杂协议的情况下非常实用。










