Go语言并发处理HTTP请求教程

花韻仙語

发布时间：2025-09-09 18:15:25

612人浏览过

来源于php中文网

原创

go语言并发处理http请求教程

本文将介绍如何在Go语言中并发处理HTTP请求。默认情况下，Go的net/http包会自动并发处理连接，每个TCP连接都会分配一个goroutine。然而，由于HTTP流水线和浏览器连接复用等机制，可能会出现请求阻塞的情况。本文将解释Go的HTTP处理机制，并提供一些技巧来确保请求能够真正并发执行。

Go语言的net/http包在处理HTTP请求时，默认情况下会为每个TCP连接创建一个新的goroutine。这意味着理论上，只要有新的连接建立，就可以并发处理请求。然而，在实际应用中，由于HTTP流水线（HTTP pipelining）和浏览器连接复用等机制的存在，可能会导致请求阻塞，使得并发处理的效果不明显。

理解Go的HTTP处理机制

当一个客户端（例如浏览器）向Go Web服务器发起HTTP请求时，服务器会监听指定的端口（例如8080）。一旦接收到连接，net/http包会自动启动一个新的goroutine来处理该连接上的所有请求。这听起来似乎已经实现了并发，但问题在于：

HTTP流水线： 允许客户端在不需要等待前一个请求完成的情况下，发送多个HTTP请求。
连接复用： 现代浏览器通常会复用同一个TCP连接来发送多个HTTP请求，以减少连接建立和关闭的开销。

如果浏览器复用同一个连接发送多个请求，那么即使服务器为每个连接创建了goroutine，这些请求仍然会在同一个goroutine中按顺序处理，从而导致阻塞。

立即学习“go语言免费学习笔记（深入）”；

示例代码分析

考虑以下示例代码：

package main

import (
    "fmt"
    "net/http"
    "time"
)

func main() {
    fmt.Println("Starting http Server ... ")
    http.HandleFunc("/", sayHello)
    err := http.ListenAndServe("0.0.0.0:8080", nil)
    if err != nil {
        fmt.Println("ListenAndServe Error:", err)
    }
}

func sayHello(w http.ResponseWriter, r *http.Request) {
    fmt.Println("New Request")
    processRequest(w, r)
}

func processRequest(w http.ResponseWriter, r *http.Request) {
    time.Sleep(time.Second * 3)
    _, err := w.Write([]byte("Go Say’s Hello(Via http)"))
    if err != nil {
        fmt.Println("Write Error:", err)
    }
    fmt.Println("End")
}

这段代码创建了一个简单的HTTP服务器，它在收到请求后会休眠3秒钟，然后返回 "Go Say’s Hello(Via http)"。如果使用浏览器连续刷新页面，会发现每次刷新都需要等待3秒钟，这表明请求并没有并发处理。

尝试并发处理（失败的尝试）

68爱写

专业高质量AI4.0论文写作平台，免费生成大纲，支持无线改稿

下载

为了尝试并发处理请求，可能会尝试在sayHello函数中使用go关键字启动一个新的goroutine来处理每个请求：

func sayHello(w http.ResponseWriter, r *http.Request) {
    fmt.Println("New Request")
    go processRequest(w, r) // 使用 go 关键字
}

虽然这样确实会并发执行processRequest函数，但浏览器仍然会等待响应。这是因为http.ResponseWriter的生命周期与处理函数相关联，如果处理函数返回后，ResponseWriter可能已经失效，导致浏览器无法接收到完整的响应。

正确的并发处理方法

要实现真正的并发处理，需要确保每个请求都在独立的goroutine中处理，并且ResponseWriter的生命周期足够长，能够完成响应的发送。一种方法是使用channel来传递响应数据：

package main

import (
    "fmt"
    "net/http"
    "time"
)

func main() {
    fmt.Println("Starting http Server ... ")
    http.HandleFunc("/", sayHello)
    err := http.ListenAndServe("0.0.0.0:8080", nil)
    if err != nil {
        fmt.Println("ListenAndServe Error:", err)
    }
}

func sayHello(w http.ResponseWriter, r *http.Request) {
    fmt.Println("New Request")
    go processRequest(w, r)
}

func processRequest(w http.ResponseWriter, r *http.Request) {
    time.Sleep(time.Second * 3)
    response := "Go Say’s Hello(Via http)"
    _, err := w.Write([]byte(response))
    if err != nil {
        fmt.Println("Write Error:", err)
    }
    fmt.Println("End")
}

在这个修改后的版本中，processRequest函数仍然在独立的goroutine中执行，但直接将响应写入http.ResponseWriter。由于http.ResponseWriter是在sayHello函数中创建的，并在processRequest函数执行完成之前保持有效，因此浏览器可以接收到完整的响应。

注意事项和总结