http.Client 和 http.Server 处理请求和响应的流程分析

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

// HTTP cannot have multiple simultaneous active requests.[*]
// Until the server replies to this request, it can't read another,
// so we might as well run the handler in this goroutine.
// [*] Not strictly true: HTTP pipelining. We could let them all process
// in parallel even if their responses need to be serialized.
// But we're not going to implement HTTP pipelining because it
// was never deployed in the wild and the answer is HTTP/2.

// HTTP 不能有多个同时活动的请求。[*]
// 在服务器回复这个请求之前，它不能读取另一个，
// 所以我们不妨在这个 goroutine 中运行处理程序。
// [*] 不完全正确：HTTP 流水线。 我们可以让他们全部处理
// 并行，即使它们的响应需要序列化。
// 但是我们不打算实现 HTTP 流水线，因为它
// 从未在野外部署过，答案是 HTTP/2。

1
2
3
4
5
6
7

// Write the request concurrently with waiting for a response,
// in case the server decides to reply before reading our full
// request body.

// 在等待响应的同时写入请求，
// 如果服务器决定在阅读我们的完整内容之前回复
// 请求正文。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

func ServeHTTP(w http.ResponseWriter, req *http.Request) {
	fmt.Println("服务端收到 request")
	time.Sleep(time.Second * 10)
	w.WriteHeader(200)
	w.Write([]byte("客户端收到 response"))
}

func Client() {
	// 客户端
	client := &http.Client{
		Transport: &http.Transport{
			IdleConnTimeout:     0, // 连接永不超时
			MaxIdleConnsPerHost: 2, // 控制每个服务端保持的最大空闲（保持活动）连接数
			MaxConnsPerHost:3,// 和同一个服务端同时连接的最大数目
		},
	}

	// 发送三个请求
	for i := 0; i < 4; i++ {
		go func() {
			resq, err := client.Get("http://localhost:9999/")

			if err == nil {
				var s []byte = make([]byte, 30)
				resq.Body.Read(s)
				fmt.Println()
				fmt.Println(string(s))
			}
			resq.Body.Close()
		}()
	}
}

func Server() {
	// 服务端
	server := &http.Server{
		Addr:        "localhost:9999",
		IdleTimeout: 0, // 连接永不超时，如果服务端设置超时时间 30 分钟，30 分钟内没有新的报文，服务端会主动关闭连接。
		Handler:     http.DefaultServeMux,
	}
	http.DefaultServeMux.HandleFunc("/", ServeHTTP)
	server.ListenAndServe()
}

func main() {
	go Server()
	time.Sleep(time.Second)
	go Client()
	select {}
}