使用 Go 语言处理并发 HTTP 请求

聖光之護

发布时间：2025-09-09 18:45:01

218人浏览过

来源于php中文网

原创

使用 go 语言处理并发 http 请求

本文旨在介绍如何使用 Go 语言高效地处理并发 HTTP 请求。我们将分析常见的并发处理误区，解释 Go 语言的 HTTP 服务器如何自动处理并发连接，并提供避免连接复用导致阻塞的实用技巧，确保 Web 应用能够快速响应客户端请求。

Go 语言在处理并发 HTTP 请求方面表现出色，但开发者有时可能会遇到一些困惑。以下将深入探讨如何利用 Go 语言的特性来实现高效的并发处理。

Go 语言 HTTP 服务器的并发模型

Go 语言的 net/http 包内置了强大的并发处理能力。每个建立的 TCP 连接都会自动分配到一个独立的 Goroutine 进行处理。这意味着，默认情况下，Go 语言的 HTTP 服务器已经能够并发地处理多个客户端连接。

常见的误区：手动创建 Goroutine

初学者常犯的一个错误是在请求处理函数中手动创建 Goroutine，例如：

func sayHello(c http.ResponseWriter, req *http.Request) {
    fmt.Printf("New Request\n")
    go processRequest(c, req) // 错误的做法
}

func processRequest(w http.ResponseWriter, req *http.Request){
    time.Sleep(time.Second*3)
    w.Write([]byte("Go Say’s Hello(Via http)"))
    fmt.Println("End")
}

虽然看起来每个请求都在独立的 Goroutine 中处理，但实际上，这可能会导致一些问题。最常见的问题是，主 Goroutine（即处理 HTTP 请求的 Goroutine）在 processRequest 函数启动后立即返回，导致连接被关闭，客户端无法收到响应。

为什么手动创建 Goroutine 会出现问题？

HTTP 服务器的底层机制是，当请求处理函数返回时，服务器会认为请求已经处理完毕，并关闭连接。如果在请求处理函数中启动了一个新的 Goroutine 来处理请求，而主 Goroutine 提前返回，那么服务器可能会在 processRequest Goroutine 完成之前关闭连接。

正确的并发处理方式

Go 语言的 HTTP 服务器已经自动处理并发连接，所以不需要手动创建 Goroutine 来处理每个请求。正确的做法是直接在请求处理函数中执行耗时操作：

易达中小企业CMS管理系统1.8.6

初次使用易达CMS企业系统以下简称(易达)，易达系统运行于微软公司开发的 ASP 程序平台，ASP是目前国内应用最广泛的WEB开发语言,空间基于微软windows IIS,使您的购买空间和维护成本降到最低，并以其众多独创或领先的新特性和功能设计，使得用户深刻体验到易达以原创研发、服务客户为主导开发理念的独到之处和领先优势，易达严格上讲是为懂点网站建设和HTML或DIV+CSS技术的人员而开发的一套

下载

func sayHello(c http.ResponseWriter, req *http.Request) {
    fmt.Printf("New Request\n")
    processRequest(c, req) // 正确的做法
}

func processRequest(w http.ResponseWriter, req *http.Request){
    time.Sleep(time.Second*3)
    w.Write([]byte("Go Say’s Hello(Via http)"))
    fmt.Println("End")
}

在这种情况下，每个 TCP 连接都会被分配到一个独立的 Goroutine，并且请求处理函数会在该 Goroutine 中完整地执行，确保客户端能够收到响应。

HTTP 连接复用和阻塞

虽然 Go 语言的 HTTP 服务器能够并发处理多个连接，但 HTTP 连接复用可能会导致阻塞。HTTP 连接复用是指客户端（如浏览器）为了提高效率，会在同一个 TCP 连接上发送多个请求。如果服务器在处理完一个请求之前，无法处理同一连接上的后续请求，就会导致阻塞。

解决方法：禁用 HTTP 连接复用

在开发和测试阶段，可以通过设置 HTTP 请求头 Connection: close 来禁用连接复用。这样，每个请求都会建立一个新的 TCP 连接，避免阻塞。

示例代码：

以下是一个完整的示例代码，演示了如何使用 Go 语言处理并发 HTTP 请求：

package main

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

func main() {
    // 处理 HTTP 命令
    fmt.Printf("Starting http Server ...\n")
    http.HandleFunc("/", sayHello)
    err := http.ListenAndServe("0.0.0.0:8080", nil)
    if err != nil {
        fmt.Printf("ListenAndServe Error: %v\n", err)
    }
}

func sayHello(w http.ResponseWriter, req *http.Request) {
    fmt.Printf("New Request\n")
    processRequest(w, req)
}

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

注意事项：