Go内置RPC方法无法正确返回结果——MIT 6.824实验1问题

核心问题 #

你的RPC调用返回值异常，本质是两个原因：

1. 结构体字段未导出：Go语言中，小写开头的字段属于包私有成员，RPC序列化框架（如实验中用到的net/rpc）无法访问这些字段，导致客户端接收时只能拿到字段的零值。
2. Chan类型无法序列化：Chan是Go进程内goroutine的通信原语，依赖进程内存空间和调度器，无法被序列化为跨进程传输的数据，所以客户端收到的AS字段始终是nil。

另外你提到的「让reply指针指向同一内存地址」是不可能实现的——客户端和服务器是独立进程，内存空间完全隔离，RPC的本质是将服务器端的结构体序列化后通过网络传输，在客户端反序列化为新的对象，二者内存地址必然不同，只能保证字段值一致。

具体修改方案 #

1. 修正ReplyStruct的字段可见性与类型 #

将所有字段改为大写开头（导出成员），并把Chan类型替换为可序列化的切片：

type ReplyStruct struct {
    Filename    string   // 原filename改为大写导出
    MapOrReduce string   // 原MapOrReduce改为大写（你原来的字段名大小写混乱，统一规范）
    AS          []string // 将chan string替换为[]string，用于传输文件名集合
}

2. 修改服务器端GetTask方法 #

将Chan中的内容转换为切片后返回，避免阻塞可以用非阻塞方式收集现有数据：

func (c *Coordinator) GetTask(args *string, reply *ReplyStruct) error {
    // 非阻塞收集ReduceFileNames中的现有数据
    var reduceFiles []string
    for {
        select {
        case fn, ok := <-ReduceFileNames:
            if !ok {
                break
            }
            reduceFiles = append(reduceFiles, fn)
        default:
            // 无数据时退出循环，避免阻塞
            break
        }
    }

    reply.AS = reduceFiles
    reply.Filename = ApplyForMapTask()
    reply.MapOrReduce = "map"
    log.Println(reply)
    return nil
}

func ApplyForMapTask() string {
    if fn, ok := <-mapFileNames; ok == true {
        return fn
    } else {
        isMap = false
        sync.OnceFunc(switchStatus)() // 注意这里要加()执行函数
        return "map task finish"
    }
}

3. 调整客户端调用代码 #

客户端访问结构体字段时要对应使用大写名称：

func CallWork() ReplyStruct {
    args := "test"
    replyTask := ReplyStruct{}

    ok := call("Coordinator.GetTask", &args, &replyTask)

    if ok {
        log.Printf("返回结果: Filename=%s, Type=%s, ReduceFiles=%v", 
            replyTask.Filename, replyTask.MapOrReduce, replyTask.AS)
    } else {
        fmt.Printf("call failed!\n")
        os.Exit(666)
    }
    return replyTask
}

修改后效果 #

服务器端设置的字段值会被正常序列化并传输到客户端，客户端能拿到正确的Filename、MapOrReduce和AS切片数据。

内容的提问来源于stack exchange，提问作者berry