Go语言中定制与扩展HTTP处理器：利用闭包传递额外参数

type Handler interface {
    ServeHTTP(ResponseWriter, *Request)
}

type HandlerFunc func(ResponseWriter, *Request)

// 这是一个不符合 http.HandlerFunc 签名的函数，无法直接注册
func myHandlerWithChannel(w http.ResponseWriter, r *http.Request, myChannel chan string) {
    // ... 使用 myChannel ...
}

package main

import (
    "fmt"
    "net/http"
    "time" // 用于模拟通道发送超时
)

// MyCustomArgument 结构体用于封装需要传递给处理器的自定义参数。
// 它可以包含任何类型的数据，例如通道、配置、数据库连接等。
type MyCustomArgument struct {
    MessageChannel chan string // 用于处理器与程序其他部分通信的通道
    ConfigValue    string      // 示例配置值
}

// createHandlerWithArgs 是一个工厂函数。
// 它接收 MyCustomArgument 类型的自定义参数，并返回一个 http.HandlerFunc。
func createHandlerWithArgs(args MyCustomArgument) http.HandlerFunc {
    // 返回的这个匿名函数就是实际的 HTTP 处理器。
    // 它通过闭包捕获了外部函数传入的 'args' 参数。
    return func(w http.ResponseWriter, r *http.Request) {
        // 在这里，我们可以安全地使用 'args' 中包含的数据。
        // 尝试将请求信息发送到通道
        select {
        case args.MessageChannel <- fmt.Sprintf("请求路径: %s, 客户端IP: %s", r.URL.Path, r.RemoteAddr):
            fmt.Println("成功将消息发送到通道。")
        case <-time.After(50 * time.Millisecond): // 设置一个超时，防止通道阻塞
            fmt.Println("发送消息到通道超时。通道可能已满或接收端处理缓慢。")
        }

        // 向客户端发送响应，包含配置信息
        fmt.Fprintf(w, "Hello from customized handler! 配置值: %s\n", args.ConfigValue)
    }
}

func main() {
    // 1. 创建一个用于程序内部通信的缓冲通道。
    // 缓冲通道可以避免在发送和接收不同步时立即阻塞。
    msgChan := make(chan string, 10) // 缓冲通道，容量为10

    // 2. 实例化自定义参数结构体，并传入通道和其他配置。
    customArgs := MyCustomArgument{
        MessageChannel: msgChan,
        ConfigValue:    "教程示例配置值",
    }

    // 3. 使用工厂函数 createHandlerWithArgs 创建带有自定义参数的处理器，
    // 并使用 http.Handle 或 http.HandleFunc 注册到 HTTP 路由。
    http.Handle("/custom", createHandlerWithArgs(customArgs))
    // 也可以使用 http.HandleFunc("/custom", createHandlerWithArgs(customArgs))

    // 4. 启动一个独立的 Goroutine，模拟程序的其他部分从通道接收并处理消息。
    go func() {
        for msg := range msgChan {
            fmt.Printf("【异步处理】程序其他部分收到消息: %s\n", msg)
        }
        fmt.Println("消息接收 Goroutine 退出。") // 当通道关闭时此行会打印
    }()

    fmt.Println("HTTP 服务器正在监听 :8080 端口...")
    // 5. 启动 HTTP 服务器。
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        // 如果服务器启动失败，通常是端口被占用或其他网络问题
        panic("ListenAndServe 错误: " + err.Error())
    }
}