如何在 Go 中通过 Channel 实现请求-响应模式-Golang

本文介绍一种简洁、安全且符合 go 通道哲学的请求-响应通信模式：让调用方携带专属响应通道（chan response）进入共享任务队列，服务端处理完成后直接向该通道发送结果，从而实现高并发 http 请求与后台计算任务的同步解耦。

在构建高并发 HTTP 服务时，若需对耗时极长的计算任务（如 SAT 求解）进行串行化或限流处理，单纯使用无缓冲 channel 传递请求会导致调用方阻塞却无法获知结果——因为 channel 只负责“投递”，不负责“回传”。Go 的优雅解法是：将响应通道作为请求数据的一部分显式携带，形成“请求即契约”的设计。

以下是一个生产就绪的简化示例：

type Request struct {
    Input int
    RespC chan Response // 推荐值类型（小结构体），避免 nil 指针与内存分配开销
}

type Response struct {
    Result int
    Err    error
}

// 全局请求通道（可带缓冲提升吞吐）
var ReqC = make(chan Request, 100)

// 后台处理 goroutine（启动一次即可）
func startProcessor() {
    go func() {
        for req := range ReqC {
            // 模拟昂贵计算（如调用 SAT 求解器）
            result, err := expensiveSATComputation(req.Input)
            // 直接向请求者提供的通道写入结果（保证一对一）
            req.RespC <- Response{Result: result, Err: err}
        }
    }()
}

// HTTP 处理函数示例
func handleSAT(w http.ResponseWriter, r *http.Request) {
    input, err := parseInput(r)
    if err != nil {
        http.Error(w, "bad request", http.StatusBadRequest)
        return
    }

    // 创建专属响应通道（容量为 1，确保接收不阻塞）
    respC := make(chan Response, 1)
    // 发送请求（含响应通道）
    ReqC <- Request{Input: input, RespC: respC}

    // 同步等待结果（此处可加 context.WithTimeout 防止永久阻塞）
    select {
    case res := <-respC:
        if res.Err != nil {
            http.Error(w, res.Err.Error(), http.StatusInternalServerError)
            return
        }
        json.NewEncoder(w).Encode(map[string]int{"result": res.Result})
    }
}

✅ 关键优势：