Golang RPC客户端与服务端并发处理示例-Golang-PHP中文网

Golang RPC客户端与服务端并发处理示例

P粉602998670

发布： 2025-09-23 08:09:01

原创

542人浏览过

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

golang rpc客户端与服务端并发处理示例

Go语言的RPC（远程过程调用）机制原生支持并发处理，服务端可以同时处理多个客户端请求，而无需额外编写复杂的逻辑。下面通过一个简单的例子展示Golang中RPC服务端与客户端如何实现并发通信。

定义共享的数据结构和接口

为了在服务端和客户端之间通信，需要定义共用的结构体和方法签名。通常将这些内容放在一个独立的包中，或者直接在服务端定义并在客户端引用。

假设我们要实现一个用户信息查询服务：

package main
<p>type Args struct {
ID int
}</p><p>type User struct {
ID   int
Name string
Age  int
}</p><p>type UserService struct{}</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>

登录后复制

UserService 提供一个方法 GetUser，用于根据ID返回用户信息。该方法需符合 RPC 方法签名格式：func (t *T) MethodName(args *Args, reply *Reply) error

实现RPC服务端

服务端注册 UserService 并启动监听，Go 的 net/rpc 包默认配合 net/http 处理请求。

package main
<p>import (
"log"
"net"
"net/http"
"net/rpc"
)</p><p>func (s <em>UserService) GetUser(args </em>Args, reply <em>User) error {
// 模拟耗时操作，体现并发能力
time.Sleep(2 </em> time.Second)
*reply = User{ID: args.ID, Name: "User-" + fmt.Sprintf("%d", args.ID), Age: 20 + args.ID}
return nil
}</p><p>func main() {
rpc.Register(new(UserService))
rpc.HandleHTTP()</p><pre class='brush:php;toolbar:false;'>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 秒延迟，这样当我们并发调用时，能明显看出多个请求是并行处理的，而不是串行等待。

JoinMC智能客服

JoinMC智能客服，帮您熬夜加班，7X24小时全天候智能回复用户消息，自动维护媒体主页，全平台渠道集成管理，电商物流平台一键绑定，让您出海轻松无忧！

查看详情

编写并发RPC客户端

客户端通过 net/rpc 调用远程方法，并使用 goroutine 实现多个请求并发发送。

package main
<p>import (
"fmt"
"log"
"net/rpc"
"sync"
"time"
)</p><p>func callRPC(client <em>rpc.Client, id int, wg </em>sync.WaitGroup) {
defer wg.Done()</p><pre class='brush:php;toolbar:false;'>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包功能基础，但在不需要复杂协议的情况下非常实用。

以上就是Golang RPC客户端与服务端并发处理示例的详细内容，更多请关注php中文网其它相关文章！