从6.824的kv.go理解tcp协议

本文是在学习6.824课程时，对Lec 2的kv.go产生的困惑的解释和总结。

kv.go

首先对kv.go的情况进行解释。这里只会取一些重点片段进行解释，需要了解完整代码细节的，读者可自行选择文章最后的参考条目进行详细了解。

主逻辑

func main() {
    //启动rpc服务，一个kv存储
    server() 

    //写入一个kv键值对
    put("subject", "6.824")
    fmt.Printf("Put(subject, 6.824) done\n")
    //读出刚才存储的key的value
    fmt.Printf("get(subject) -> %s\n", get("subject"))
}

主逻辑非常简单，启动一个kv存储的rpc服务，然后运行简单的读写功能测试。

server()

func server() {
    kv := new(KV)
    kv.data = map[string]string{}
    rpcs := rpc.NewServer()
    rpcs.Register(kv)
    l, e := net.Listen("tcp", ":1234")
    if e != nil {
        log.Fatal("listen error:", e)
    }
    go func() {
        for {
            conn, err := l.Accept()
            if err == nil {
                go rpcs.ServeConn(conn)
            } else {
                break
            }
        }
        l.Close()
    }()
}

启动服务，监听1234端口，并开始接受客户端的连接

client

func get(key string) string {
    client := connect()
    args := GetArgs{key}
    reply := GetReply{}
    err := client.Call("KV.Get", &args, &reply)
    if err != nil {
        log.Fatal("error:", err)
    }
    client.Close()
    return reply.Value
}

func put(key string, val string) {
    client := connect()
    args := PutArgs{key, val}
    reply := PutReply{}
    err := client.Call("KV.Put", &args, &reply)
    if err != nil {
        log.Fatal("error:", err)
    }
    client.Close()
}

客户端方法总体逻辑是一致，首先进行tcp连接的建立，然后进行rpc方法调用，最后关闭连接

解析过程

如果你运行该程序，会发现打印如下：

$ go run kv.go
Put(subject, 6.824) done
get(subject) -> 6.824

$

为什么程序最后会退出，而不是因为server在监听阻塞住。我自己的解释是：首先是因为server()中的无限接收请求的循环是运行在goroutine当中，所以之后的客户端请求可以并发的运行；其次因为主线程没有其他方法的阻塞，所以会在所有逻辑结束后退出，也意味该进程退出了，这样其中的所有线程都会结束，包括其中创建的goroutine。
如果读者有更好的解释欢迎留言讨论。

在该程序的主逻辑中，实际发生了两次tcp连接，我们知道一次tcp协议的运行过程有三个阶段：连接创建、数据传送和连接终止。server()下开启的rpc服务监听着1234端口，而get和put()中的connect()则完成一次tcp连接创建的三次握手，如图下