使用 Go 语言处理并发 HTTP 请求-Golang-PHP中文网

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

聖光之護

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

原创

209人浏览过

使用 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 来处理每个请求。正确的做法是直接在请求处理函数中执行耗时操作：

phpList

phpList提供开源电子邮件营销服务，包括分析、列表分割、内容个性化和退信处理。丰富的技术功能和安全稳定的代码基础是17年持续开发的结果。在95个国家使用，在20多种语言中可用，并用于去年发送了250亿封电子邮件活动。您可以使用自己的SMTP服务器部署它，或在http://phplist.com上获得免费的托管帐户。

查看详情

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")
}

登录后复制

注意事项：