错误的RPC响应

使用远程过程设置响应时出现错误，导致客户端收到错误状态和空字符串。在协调器中，mapjob 过程预期会修改 reply 指针，但该代码并未修改其状态和输入字段。相反，它重新分配了 reply 指针，导致客户端接收未修改的零值响应。

我正在尝试使用一个远程过程，该过程将在结构中设置回复，并使用布尔状态和字符串作为下一个输入。 在该过程中，我将布尔状态设置为 true 并将一个值放入输入中。 但在客户端中，它得到错误状态和空字符串。 在程序中：

func(c *coordinator)mapjob(req mr.maprequest, reply *mr.mapresponse) error {
    //logic to set up response...
    reply = &mr.mapresponse{
        status: newstatus,
        input:  newin,
    }
    fmt.printf("[reply] %+v\n", reply)

    return nil
}

打印 [reply] &{status:true input:1.txt}

在客户端时：

err := client.Call("Coordinator.MapJob", req, &reply)
        fmt.Printf("reply from procedure %+v\n", reply)

从过程 {status:false 输入:} 打印：reply

我在这里缺少什么？ 我已将整个代码放在 https://github.com/brotchu/projectmr 中 该过程在协调器中定义，客户端在工作器中定义。 将其全部粘贴到此处可能会太多。

解决方案

客户端结构看起来只由零值组成（false 和空字符串）。

我认为 client.call 调用不会改变回复。我认为这是因为 mapjob 也不会改变回复。

reply = &mr.mapresponse{
        status: newstatus,
        input:  newin,
    }

应该是

reply.status = newstatus
reply.input =  newin

您必须更改调用期间传递的回复值，因此替换

reply = &mr.mapresponse{
    status: newstatus,
    input:  newin,
}

与

*reply = mr.MapResponse{
    Status: newStatus,
    Input:  newIn,
}

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~