Go HTTP 服务并发请求处理：基于 Channel 的等待与响应机制-Golang-PHP中文网

Go HTTP 服务并发请求处理：基于 Channel 的等待与响应机制

碧海醫心

发布： 2025-07-29 20:22:17

原创

820人浏览过

go http 服务并发请求处理：基于 channel 的等待与响应机制

本文档旨在介绍如何使用 Go 语言和 channel 实现一个 HTTP 服务，该服务能够处理并发请求，并确保客户端获取到最新的资源。通过示例代码，详细讲解了如何利用 goroutine 和 channel 实现请求的等待与响应，并提供了优化建议，帮助开发者构建高效、可靠的并发 HTTP 服务。

在构建高并发的 HTTP 服务时，一个常见的需求是处理对同一资源的并发请求，并确保客户端获取到最新的资源。本文将介绍如何使用 Go 语言的 goroutine 和 channel 机制来实现这一目标。我们将通过一个具体的例子，展示如何让客户端的请求等待，直到资源更新后才返回响应。

基于 Channel 的请求等待与响应

以下是一个使用 net/http 标准库实现的基本示例，展示了如何使用 channel 控制请求的等待与响应：

package main

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

var (
    resourceChan = make(chan string) // 用于传递最新资源的 channel
    listeners    = make([]chan string, 0) // 存储等待资源的 channel 列表
)

func resourceHandler(w http.ResponseWriter, r *http.Request) {
    // 创建一个用于接收资源的 channel
    resourceReceiver := make(chan string)
    listeners = append(listeners, resourceReceiver)

    // 等待资源更新
    resource := <-resourceReceiver

    // 响应客户端
    fmt.Fprintf(w, resource)
}

func resourceLoop() {
    for {
        time.Sleep(5 * time.Second) // 模拟资源每 5 秒更新一次
        newResource := fmt.Sprintf("Cool - %s", time.Now().String())

        // 通知所有等待者
        for _, listener := range listeners {
            listener <- newResource
        }
        listeners = make([]chan string, 0) // 清空等待者列表
    }
}

func main() {
    http.HandleFunc("/resource", resourceHandler)

    go resourceLoop() // 启动资源更新循环

    fmt.Println("Server listening on :8080")
    http.ListenAndServe(":8080", nil)
}

登录后复制

代码解释：

resourceChan: 一个用于传递最新资源的 channel。虽然在这个例子中未使用，但在更复杂的场景中，可以用于在资源更新时广播给多个消费者。
listeners: 一个存储 channel 的 slice。每个客户端请求都会创建一个 channel，并将其添加到 listeners 中。
resourceHandler: HTTP 请求处理函数。它创建一个新的 channel (resourceReceiver)，并将其添加到 listeners 中。然后，它会阻塞，直到从 resourceReceiver 接收到新的资源。收到资源后，它会将资源写入 HTTP 响应。
resourceLoop: 一个 goroutine，模拟资源定期更新。它每 5 秒生成一个新的资源，并将其发送到 listeners 中的所有 channel。然后，它清空 listeners slice，以便为下一轮请求做好准备。
main: 主函数。它注册 /resource 路由，启动 resourceLoop goroutine，并启动 HTTP 服务器。