教泥 Go 分布式入门喵！

1236 字

6 分钟

教泥 Go 分布式入门喵！

2026-04-11

Nyang's Programming Classroom

Go

/

Distributed Systems

/

RPC

/

Tsundere Cat

/

Tutorial

哈？“分布式”？这种到处都在吹的基础概念，你居然到现在还搞不明白喵？(¬_¬)

真是个笨蛋……听好了，本喵今天心情好，就勉为其难地给你开个小灶。你可别误会了，本喵才不是特意为了教你才写这篇博客的，只是看你一直抓耳挠腮的样子实在太碍眼了喵！

把耳朵竖起来听好：所谓的分布式，根本不是什么魔法！说白了，就是“一只喵干不完的活，通过网络打电话叫另一只喵来帮忙”喵！

在 Go 语言里，最简单的“打电话”方式就是 RPC（远程过程调用）。你只需要记住，它能让你在一台电脑上，像调用本地函数一样，去调用另一台电脑上的函数。

现在，本喵就带你写一个“老板喵”和“打工喵”的例子。眼睛别眨，本喵只演示一次！

第一步：被迫营业的“打工喵” (服务端)#

首先，我们需要一只在后台默默干活的打工喵。它什么都不用管，只需要竖起耳朵听端口里的网络请求，然后帮忙算算今天能吃多少个小鱼干罐头就行了。

新建一个文件叫 server.go，给我一字不差地敲进去喵：

1
package main
2

3
import (
4
  "fmt"
5
  "net"
6
  "net/rpc"
7
)
8

9
// 笨蛋，这是我们要通过网络传递的数据包喵！
10
type CansArgs struct {
11
  A, B int
12
}
13

14
// 这是我们的打工喵服务
15
type NyangService struct{}
16

17
// 打工喵的核心技能：算乘法。
18
// 记住了，Go RPC 的方法签名必须长这样：(参数, 返回值指针) error！写错打手心喵！
19
func (s *NyangService) CalculateCans(args *CansArgs, reply *int) error {
20
  fmt.Printf("[打工喵] 收到指令喵！正在计算 %d * %d...\n", args.A, args.B)
21
  *reply = args.A * args.B
22
  return nil
23
}
24

25
func main() {
26
  // 把打工喵注册到服务中心
27
  nyang := new(NyangService)
28
  rpc.Register(nyang)
29

30
  // 监听 8080 端口，就像挂上电话机等待老板呼叫喵
31
  listener, err := net.Listen("tcp", ":8080")
32
  if err != nil {
33
    panic("电话线断了喵！" + err.Error())
34
  }
35
  fmt.Println("[打工喵] 哼，本喵已经在 8080 端口准备好了，快点把任务交过来！")
36

37
  // 阻塞在这里，接听电话
38
  rpc.Accept(listener)
39
}

第二步：只会发号施令的“老板喵” (客户端)#

现在，打工喵已经准备好了。接下来写“老板喵”的代码。老板喵自己是不屑于算数学题的，它只会通过网络把数字甩给打工喵，然后等结果。

新建另一个文件叫 client.go，快点：

1
package main
2

3
import (
4
  "fmt"
5
  "net/rpc"
6
)
7

8
// 客户端也得知道数据长什么样，不然怎么发喵？
9
type CansArgs struct {
10
  A, B int
11
}
12

13
func main() {
14
  // 1. 拿起电话，拨号给 localhost 的 8080 端口
15
  // （要是以后打工喵搬到了云服务器上，就把 localhost 换成那边的 IP，懂了吗笨蛋！）
16
  client, err := rpc.Dial("tcp", "localhost:8080")
17
  if err != nil {
18
    panic("呼叫打工喵失败，它是不是摸鱼去了喵？" + err.Error())
19
  }
20
  defer client.Close()
21

22
  // 2. 准备好要算的数据
23
  args := CansArgs{A: 7, B: 8}
24
  var reply int
25

26
  // 3. 远程调用！告诉对面的网络：给我执行 NyangService 里的 CalculateCans 方法！
27
  fmt.Println("[老板喵] 喂？对面的，给本喵算算 7 * 8 等于几喵！")
28
  err = client.Call("NyangService.CalculateCans", args, &reply)
29
  if err != nil {
30
    panic("计算失败喵！" + err.Error())
31
  }
32

33
  // 4. 拿到结果啦！
34
  fmt.Printf("[老板喵] 算得还挺快，结果是：%d 个罐头喵！\n", reply)
35
}