如何在Golang中实现RPC客户端和服务端-Golang-PHP中文网

如何在Golang中实现RPC客户端和服务端

P粉602998670

发布： 2025-10-16 18:35:02

原创

198人浏览过

Go的RPC实现基于net/rpc包，需定义导出方法，如Add接收Args结构并返回int指针和error；服务端注册Calculator实例并监听TCP端口；客户端通过Dial连接后调用Calculator.Add方法传参获取结果。

如何在golang中实现rpc客户端和服务端

在Golang中实现RPC（远程过程调用）客户端和服务端非常简单，标准库net/rpc提供了完整的支持。下面以一个基础示例说明如何使用Go的RPC机制进行通信。

1. 定义服务接口和数据结构

RPC通信需要双方约定好方法签名和参数结构。我们先定义一个简单的服务，用于计算两个数的和。

创建一个公共的数据结构和方法定义，通常放在独立的包中，但为了演示方便，这里直接在主包中定义：

注意：RPC方法必须满足以下条件：

方法是导出的（大写字母开头）
有两个参数，第一个是接收参数，第二个是返回结果（都是导出类型）
第二个参数是指针类型
返回值是error类型

例如：

立即学习“go语言免费学习笔记（深入）”；

<strong>type Args struct {
    A, B int
}

type Calculator int

func (c *Calculator) Add(args Args, result *int) error {
    *result = args.A + args.B
    return nil
}</strong>

登录后复制

2. 启动RPC服务端

服务端注册服务并监听TCP端口。

JoinMC智能客服

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

查看详情

<strong>package main

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

func main() {
    // 注册服务实例
    calc := new(Calculator)
    rpc.Register(calc)

    // 监听端口
    listener, err := net.Listen("tcp", ":1234")
    if err != nil {
        log.Fatal("监听端口失败:", err)
    }
    defer listener.Close()

    log.Println("RPC服务已启动，监听端口: 1234")
    for {
        conn, err := listener.Accept()
        if err != nil {
            continue
        }
        go rpc.ServeConn(conn)
    }
}</strong>

登录后复制

3. 编写RPC客户端

客户端连接服务端并调用远程方法。

<strong>package main

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

func main() {
    // 连接服务端
    client, err := rpc.Dial("tcp", "localhost:1234")
    if err != nil {
        log.Fatal("连接失败:", err)
    }
    defer client.Close()

    // 准备参数和接收结果
    args := Args{A: 5, B: 10}
    var reply int

    // 调用远程方法
    err = client.Call("Calculator.Add", args, &reply)
    if err != nil {
        log.Fatal("调用失败:", err)
    }

    fmt.Printf("结果: %d\n", reply) // 输出: 结果: 15
}</strong>

登录后复制