Golang RPC接口调用与服务开发项目-Golang-PHP中文网

Golang RPC接口调用与服务开发项目

P粉602998670

发布： 2025-09-28 22:03:02

原创

786人浏览过

答案：Go语言通过net/rpc包实现RPC服务与客户端调用，需定义共享结构体和接口，服务端注册实现结构体并启用HTTP监听，客户端通过DialHTTP连接并调用远程方法。示例中UserService提供GetUser方法，客户端请求UserRequest返回User对象，运行后输出Received user: {ID:1 Name:Alice}，表明调用成功。注意方法签名需符合规范，参数可Gob序列化，适用于轻量级分布式通信场景。

golang rpc接口调用与服务开发项目

在Go语言中实现RPC（远程过程调用）接口调用与服务开发，是一种高效、简洁的分布式通信方式。Go标准库自带了net/rpc包，支持通过HTTP或自定义协议进行方法调用，且天然支持Gob编码。下面介绍如何从零搭建一个完整的RPC服务与客户端调用流程。

定义共享的数据结构与服务接口

为了使服务端和客户端能正确通信，需要定义共用的结构体和方法签名。通常将这些内容放在一个独立的包中，例如shared。

示例：定义一个用户信息服务

user.go

package shared

type User struct {
    ID   int
    Name string
}

type UserRequest struct {
    ID int
}

type UserServiceInterface interface {
    GetUser(req UserRequest, user *User) error
}

登录后复制

实现RPC服务端

服务端需注册一个实现了指定接口的结构体，并通过HTTP暴露RPC服务。

server.go

package main

import (
    "log"
    "net/http"
    "net/rpc"
    "your-project/shared"
)

type UserService struct{}

func (s *UserService) GetUser(req shared.UserRequest, user *shared.User) error {
    // 模拟数据库查询
    *user = shared.User{ID: req.ID, Name: "Alice"}
    return nil
}

func main() {
    // 注册服务
    userService := new(UserService)
    rpc.Register(userService)
    
    // 使用HTTP作为传输层
    rpc.HandleHTTP()
    
    log.Println("Serving RPC on :8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

登录后复制

编写RPC客户端调用代码

客户端通过HTTP连接到服务端，调用远程方法就像本地调用一样，只是需要传入指针接收返回值。

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

Felvin

AI无代码市场，只需一个提示快速构建应用程序

161

查看详情

client.go

package main

import (
    "log"
    "net/rpc"
    "your-project/shared"
)

func main() {
    // 建立与服务端的连接
    client, err := rpc.DialHTTP("tcp", "localhost:8080")
    if err != nil {
        log.Fatal("Connection failed:", err)
    }
    defer client.Close()

    // 准备请求和响应对象
    req := shared.UserRequest{ID: 1}
    var user shared.User

    // 调用远程方法
    err = client.Call("UserService.GetUser", req, &user)
    if err != nil {
        log.Fatal("Call failed:", err)
    }

    log.Printf("Received user: %+v", user)
}

登录后复制