Go 内置 RPC 原理，让你用代码写出高性能的网络服务

2023-08-11 09:15:58

Go 内置 RPC：轻松构建高性能网络服务

远程过程调用（RPC） 是一种在分布式系统中实现进程间通信的关键机制。借助 RPC，一个进程可以调用另一个进程中的方法，仿佛它是一个本地方法一样。

Go 语言 内置了一个功能强大的 RPC 框架，基于 HTTP 协议、JSON 数据编码和 net/rpc 包。这使得开发高性能、易于部署的网络服务变得轻而易举。

Go 内置 RPC 服务端实现

创建一个 RPC 服务端很简单：

package main

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

type HelloService struct{}

func (s *HelloService) Hello(request string, reply *string) error {
    *reply = "Hello, " + request
    return nil
}

func main() {
    rpc.Register(new(HelloService))
    rpc.HandleHTTP()
    log.Fatal(http.ListenAndServe(":8080", nil))
}

此代码创建了一个服务端，并注册了一个 HelloService，其中包含一个 Hello 方法。当客户端调用 Hello 方法时，RPC 框架会将请求转发给相应的服务端方法。

Go 内置 RPC 客户端实现

要调用 RPC 服务端的方法，需要创建客户端：

package main

import (
    "log"
    "net/rpc"
)

type HelloServiceClient struct {
    client *rpc.Client
}

func NewHelloServiceClient(address string) (*HelloServiceClient, error) {
    client, err := rpc.DialHTTP("tcp", address)
    if err != nil {
        return nil, err
    }
    return &HelloServiceClient{client}, nil
}

func (c *HelloServiceClient) Hello(request string) (string, error) {
    var reply string
    err := c.client.Call("HelloService.Hello", request, &reply)
    if err != nil {
        return "", err
    }
    return reply, nil
}

func main() {
    client, err := NewHelloServiceClient("localhost:8080")
    if err != nil {
        log.Fatal(err)
    }
    reply, err := client.Hello("World")
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("Received reply: %s", reply)
}