使用Golang中的现有连接进行远程过程调用

本篇文章向大家介绍《使用Golang中的现有连接进行远程过程调用》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

我有一个现有的 TCP 连接 (net.Conn)，我正在尝试在该连接上使用（开发）RPC 客户端-服务器应用程序。

到目前为止，我探索了标准库中的 gRPC 和 net/rpc；除非我遗漏了什么，否则两者似乎都需要完全控制连接。

我可以使用 gob 进行自定义实现来序列化请求/回复，但由于我还需要良好的错误处理（至少对于我在服务器端生成的错误），我试图查看是否存在一些现有的我可以使用的框架。

有什么建议/想法吗？

正确答案

经过更多调查，我意识到我对 net/rpc 的看法是错误的。对此表示歉意。

您可以在服务器端调用 rpc.serveconn 并在客户端调用 rpc.newclient 传递现有连接，只要它实现 io.readwritecloser

示例服务器：

package main

import (
    "net/rpc"
    "os"

    "myapp/pkg"
)

func main() {
    fsops := new(pkg.fsops)
    s := rpc.newserver()
    s.register(fsops)
    s.serveconn(pkg.rwcloser{os.stdin, os.stdout})
}

示例客户端：

package main

import (
    "net/rpc"
    "os"

    "myapp/pkg"
)

func main() {
    client := rpc.NewClient(pkg.RWCloser{os.Stdin, os.Stdout})

    var reply pkg.XXXReply
    err := client.Call("FSOps.XXX", "args", &reply)

}

理论要掌握，实操不能落！以上关于《使用Golang中的现有连接进行远程过程调用》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！