维持Golang网络RPC连接

在 Go 语言中，使用 net/rpc 包进行网络 RPC 通信时，默认情况下每当客户端对服务器进行调用时都会建立一个新的连接。为了保持连接并避免创建不必要的连接，需要在客户端使用 rpc.dialhttp 方法指定网络类型为 "tcp"，同时在服务器端使用 rpc.NewServer() 创建服务器。这样，每个客户端只会打开一个连接，并且所有对该客户端的 RPC 调用都将使用此连接，从而提高了效率和可扩展性。

据我了解，请在此处阅读 net/rpc 包文档 https://pkg.go.dev/net/[email protected] 每当客户端对服务器进行 rpc 调用时，都会生成一个新的连接已建立。如何实现每个新客户端打开一个新连接、保持连接并仅使用 TPC（即不使用 HTTP）调用 RPC 方法？

正确答案

如果您使用任何标准库方法创建新客户端：

client, err := rpc.dialhttp("tcp", serveraddress + ":1234")
if err != nil {
    log.fatal("dialing:", err)
}

在底层，它会是 call net.Dial，从而产生与 rpc.client 关联的单个连接：

conn, err := net.dial(network, address)

您可以看到 newclient 在此处实例化时采用单个连接：https://cs.opensource.google/go/go/+/refs/tags/go1.17.5:src/net/rpc/client.go;l=193-197;drc=refs%2Ftags%2Fgo1.17.5;bpv=1;bpt=1

对该客户端上的 client.call 的任何调用都将写入和读取该底层连接，而不会生成新连接。

因此，只要您实例化一次客户端，然后对同一客户端进行所有 rpc 调用，您将始终使用单个连接。如果该连接被切断，客户端将不再可用。

rpc.client 也是线程安全的，因此您可以安全地创建它并在各处使用它，而无需建立新连接。

回复您的评论。如果您想运行 rpc 服务器并跟踪连接，您可以这样做：

l, e := net.Listen("tcp", ":1234")
if e != nil {
    log.Fatal("listen error:", e)
}
server := rpc.NewServer()
for {
    conn, err := l.Accept()
    if err != nil {
        panic(err) // replace with log message?
    }
    // Do something with `conn`
    go func() {
        server.ServeConn(conn)
        // The server has stopped serving this connection, you can remove it.
    }()
}

然后对每个连接进来时执行一些操作，并在处理完成后将其删除。

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