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 intName stringAge 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 秒延迟，这样当我们并发调用时，能明显看出多个请求是并行处理的，而不是串行等待。
编写并发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 Userstart := 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包功能基础，但在不需要复杂协议的情况下非常实用。
以上就是Golang RPC客户端与服务端并发处理示例的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1408448.html
微信扫一扫 
支付宝扫一扫 
