Go RPC中匿名函数传递的局限性：GobEncoder与代码序列化深度解析

// common/types.go
package common

// Args 是RPC方法接受的参数
type Args struct {
    A, B int
}

// Reply 是RPC方法返回的结果
type Reply struct {
    C int
}

// WorkerService 定义了工作节点提供的服务方法
type WorkerService struct{}

// worker/main.go
package main

import (
    "fmt"
    "log"
    "net"
    "net/rpc"
    "gob_func_example/common" // 假设 common 包在正确路径
)

// Add 方法实现加法
func (t *common.WorkerService) Add(args *common.Args, reply *common.Reply) error {
    reply.C = args.A + args.B
    fmt.Printf("Worker executed Add: %d + %d = %d\n", args.A, args.B, reply.C)
    return nil
}

// Multiply 方法实现乘法
func (t *common.WorkerService) Multiply(args *common.Args, reply *common.Reply) error {
    reply.C = args.A * args.B
    fmt.Printf("Worker executed Multiply: %d * %d = %d\n", args.A, args.B, reply.C)
    return nil
}

func main() {
    worker := new(common.WorkerService)
    rpc.Register(worker) // 注册服务

    tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234")
    if err != nil {
        log.Fatal(err)
    }

    listener, err := net.ListenTCP("tcp", tcpAddr)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("Worker RPC server listening on :1234")
    rpc.Accept(listener) // 监听并接受RPC连接
}

// client/main.go
package main

import (
    "fmt"
    "log"
    "net/rpc"
    "gob_func_example/common" // 假设 common 包在正确路径
)

func main() {
    client, err := rpc.Dial("tcp", "localhost:1234")
    if err != nil {
        log.Fatal("dialing:", err)
    }
    defer client.Close()

    // 调用 Add 方法
    argsAdd := common.Args{A: 7, B: 8}
    var replyAdd common.Reply
    err = client.Call("WorkerService.Add", argsAdd, &replyAdd)
    if err != nil {
        log.Fatal("WorkerService.Add error:", err)
    }
    fmt.Printf("Client received Add result: %d + %d = %d\n", argsAdd.A, argsAdd.B, replyAdd.C)

    // 调用 Multiply 方法
    argsMultiply := common.Args{A: 5, B: 6}
    var replyMultiply common.Reply
    err = client.Call("WorkerService.Multiply", argsMultiply, &replyMultiply)
    if err != nil {
        log.Fatal("WorkerService.Multiply error:", err)
    }
    fmt.Printf("Client received Multiply result: %d * %d = %d\n", argsMultiply.A, argsMultiply.B, replyMultiply.C)
}