是否可以发送函数作为 RPC 的响应

Question

我正在尝试实现一个服务器和多个客户端。客户端将向服务器注册，服务器应为客户端提供要调用的特定功能。我不希望特定函数是另一个rpc调用。我正在尝试为map reduce创建一个分布式系统，其中函数将在客户端进程中执行。有没有办法在 Go 中传递函数作为对远程过程调用的响应？以下是我尝试过的：在服务器中 ：type ResgisterResponse struct {    Ack     bool    MapFunc func()}func (a *API) RegisterWorker(addr string, reply *ResgisterResponse) error {    a.worker[addr] = "idle" //idle, working, complete    fmt.Printf("Wokers : %+v\n", a.worker)    *reply = ResgisterResponse{        Ack: true,        MapFunc: func() {            fmt.Println("Hello Worker")        },    }    return nil}和在客户端中：var reply struct {        Ack     bool        MapFunc func()    }err = client.Call("API.RegisterWorker", getLocalAddr()+":"+localPort, &reply)must(err)fmt.Println("Worker registered")reply.MapFunc()当然，我得到的指针错误为零。panic: runtime error: invalid memory address or nil pointer dereference

Answer 1

由于语言设计，通过网络发送普通函数将不起作用。在单个程序中，您可以将函数作为参数传递，因为它们是在同一二进制文件中编译的。在服务器进程中，您可以获取它们的地址/引用，因为它们映射在内存中，但是当您发送函数时，您实际上会发送指向它的指针，该指针在客户端的内存中不是有效的地址（因此指针错误无效）。

为了解决您的问题，我会让客户端根据id（可能是提及函数名称的字符串）向服务器注册一组可用函数。服务器将在 Run RPC 调用中发回函数 ID，客户端将根据此 ID 选择函数并运行它

还有一些实验库可以在运行时评估Go代码，但我认为它们不安全。这是一个例子。