当前位置：首页 > 文章列表 > Golang > Go教程 > GoHTTPServer并发安全与变量使用技巧

GoHTTPServer并发安全与变量使用技巧

2025-11-22 12:48:33 0浏览收藏

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《Go HTTP Server 并发安全与全局变量使用指南》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

Go HTTP Server 与全局变量的并发安全

本文探讨了在 Go 语言编写的 HTTP 服务器中使用全局变量的并发安全问题。由于每个连接都在独立的 Goroutine 中处理，直接修改全局变量可能导致数据竞争。文章提供了一种使用 Goroutine 和 Channel 来安全地更新全局变量的通用模式，并强调了在并发环境下保护共享资源的重要性。

在 Go 语言中，使用 net/http 包可以方便地创建 HTTP 服务器。然而，当涉及到并发处理请求时，如果直接使用全局变量，可能会遇到数据竞争的问题。这是因为 Go 的 HTTP 服务器为每个连接启动一个新的 Goroutine 来处理请求。多个 Goroutine 同时访问和修改同一个全局变量，如果没有适当的同步机制，就会导致不可预测的结果。

并发安全问题

考虑以下简单的 HTTP 服务器示例：

package main

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

var cur int = 0

func handler(w http.ResponseWriter, r *http.Request) {
    cur = cur + 1
    fmt.Fprintf(w, "Current value: %d\n", cur)
}

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())
    http.HandleFunc("/", handler)
    http.ListenAndServe(":9010", nil)
}

在这个例子中，cur 是一个全局变量，用于记录请求的数量。handler 函数每次被调用时，都会递增 cur 的值。由于 handler 函数可能被多个 Goroutine 同时调用，因此对 cur 的递增操作不是并发安全的。

使用 Goroutine 和 Channel 解决并发安全问题

为了解决这个问题，可以使用 Goroutine 和 Channel 来安全地更新全局变量。以下是一个改进后的示例：

package main

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

var counterInput = make(chan int)

func handler(w http.ResponseWriter, r *http.Request) {
    counterInput <- 1
    fmt.Fprintf(w, "Request received\n")
}

func counter(c <-chan int) {
    cur := 0
    for v := range c {
        cur += v
        fmt.Printf("Counter updated: %d\n", cur)
    }
}

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())
    go counter(counterInput)
    http.HandleFunc("/", handler)
    http.ListenAndServe(":9010", nil)
}

在这个改进后的示例中，我们创建了一个名为 counterInput 的 Channel。handler 函数不再直接修改全局变量 cur，而是将一个值发送到 counterInput Channel。另一个 Goroutine 运行 counter 函数，它从 counterInput Channel 接收值，并更新 cur 的值。

这种方法通过 Channel 实现了 Goroutine 之间的同步，保证了对 cur 的更新是并发安全的。只有一个 Goroutine 负责更新 cur 的值，避免了数据竞争。

其他并发控制方法

除了使用 Channel，还可以使用 sync.Mutex 来保护全局变量。以下是一个使用 sync.Mutex 的示例：

package main

import (
    "fmt"
    "net/http"
    "runtime"
    "sync"
)

var (
    cur int = 0
    mu  sync.Mutex
)

func handler(w http.ResponseWriter, r *http.Request) {
    mu.Lock()
    defer mu.Unlock()
    cur = cur + 1
    fmt.Fprintf(w, "Current value: %d\n", cur)
}

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())
    http.HandleFunc("/", handler)
    http.ListenAndServe(":9010", nil)
}

在这个例子中，我们使用 sync.Mutex 来保护 cur 的访问。在 handler 函数中，我们首先调用 mu.Lock() 来获取锁，然后在函数结束时调用 mu.Unlock() 来释放锁。这样可以确保在同一时刻只有一个 Goroutine 可以访问和修改 cur 的值。