当前位置：首页 > 文章列表 > Golang > Go教程 > Golang实现RPC客户端与服务端详解

Golang实现RPC客户端与服务端详解

2025-11-09 23:01:38 0浏览收藏

本文详细介绍了如何使用 Golang 的 `net/rpc` 包实现 RPC（远程过程调用）客户端和服务端。通过定义满足特定条件（导出、两个参数、返回值 error）的服务接口和数据结构，例如 `Add` 方法接收 `Args` 结构体并返回 `int` 指针和 `error`，即可搭建 RPC 服务。服务端需注册服务实例（如 `Calculator`）并监听 TCP 端口，而客户端则通过 `Dial` 函数连接服务端，并使用 `Call` 方法传递参数并获取远程方法的执行结果。文章提供完整的代码示例，包括服务端监听、客户端连接与调用，以及详细的运行步骤，帮助开发者快速掌握 Golang RPC 的使用，适用于纯 Go 环境下的高效服务通信。

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类型

例如：

<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端口。

<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>