当前位置：首页 > 文章列表 > Golang > Go教程 > GolangRPC多服务通信实战教程

GolangRPC多服务通信实战教程

2026-01-01 10:07:42 0浏览收藏

大家好，今天本人给大家带来文章《Golang RPC多服务通信实战示例》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

先定义共享结构体，再分别实现UserService和OrderService的RPC通信。UserService监听8081提供用户查询，OrderService监听8082并调用UserService获取用户信息，客户端通过调用OrderService完成订单与用户数据聚合。

Golang RPC多服务间通信示例

在Golang中实现多个服务间的RPC通信，可以通过标准库net/rpc轻松完成。下面是一个清晰的多服务间RPC通信示例，包含两个独立的服务（UserService和OrderService），它们通过RPC进行解耦通信。

1. 定义共享的数据结构与接口

为了支持跨服务调用，先定义共用的请求和响应结构体。这些结构可以放在一个独立的包中（如common），或直接复制到各服务中。

// common/types.go
package common

type User struct {
    ID   int
    Name string
}

type Order struct {
    ID       int
    UserID   int
    Product  string
}

2. UserService 提供用户查询功能

UserService对外暴露一个RPC方法GetUser，根据ID返回用户信息。

// user_service/server.go
package main

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

type UserService struct{}

func (s *UserService) GetUser(uid int, user *common.User) error {
    // 模拟数据库查找
    userData := map[int]common.User{
        1: {ID: 1, Name: "Alice"},
        2: {ID: 2, Name: "Bob"},
    }
    *user = userData[uid]
    return nil
}

func main() {
    rpc.Register(new(UserService))
    listener, err := net.Listen("tcp", ":8081")
    if err != nil {
        log.Fatal("Listen error:", err)
    }
    defer listener.Close()
    log.Println("UserService 启动在 :8081")
    for {
        conn, _ := listener.Accept()
        go rpc.ServeConn(conn)
    }
}

3. OrderService 调用 UserService 获取用户信息

OrderService在返回订单详情时，需要通过RPC向UserService查询关联的用户信息。

// order_service/server.go
package main

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

type OrderService struct{}

func (s *OrderService) GetOrder(oid int, reply *common.Order) error {
    // 模拟订单数据
    orderData := map[int]common.Order{
        101: {ID: 101, UserID: 1, Product: "Laptop"},
        102: {ID: 102, UserID: 2, Product: "Phone"},
    }
    *reply = orderData[oid]

    // 调用 UserService 获取用户信息
    client, err := rpc.Dial("tcp", "127.0.0.1:8081")
    if err != nil {
        log.Printf("无法连接 UserService: %v", err)
        return nil
    }
    defer client.Close()

    var user common.User
    err = client.Call("UserService.GetUser", reply.UserID, &user)
    if err != nil {
        log.Printf("调用 GetUser 失败: %v", err)
    } else {
        log.Printf("订单 %d 关联用户: %s", reply.ID, user.Name)
    }

    return nil
}

func main() {
    rpc.Register(new(OrderService))
    listener, err := net.Listen("tcp", ":8082")
    if err != nil {
        log.Fatal("Listen error:", err)
    }
    defer listener.Close()
    log.Println("OrderService 启动在 :8082")
    for {
        conn, _ := listener.Accept()
        go rpc.ServeConn(conn)
    }
}

4. 客户端调用 OrderService

客户端只需访问OrderService，它会自动联动UserService完成数据聚合。

// client/main.go
package main

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

func main() {
    client, err := rpc.Dial("tcp", "127.0.0.1:8082")
    if err != nil {
        log.Fatal("Dial error:", err)
    }
    defer client.Close()

    var order common.Order
    err = client.Call("OrderService.GetOrder", 101, &order)
    if err != nil {
        log.Fatal("Call error:", err)
    }

    log.Printf("获取订单: %+v", order)
}

运行顺序：