Go语言中channel用于goroutine间通信。示例构建并发任务系统：通过无缓冲channel分发URL任务，多个worker协程处理HTTP请求，结果通过带缓冲channel返回，主程序收集并输出。使用defer close关闭channel确保优雅退出，错误统一返回，体现任务分发、并发执行与结果聚合的经典并发模式。
Go语言中的channel是实现goroutine之间通信的核心机制。它不仅能传递数据，还能控制并发执行的流程。下面通过一个实际项目示例来展示channel在真实场景中的使用方式。
任务分发与结果收集系统
假设我们要构建一个简单的并发任务处理系统：从任务队列中读取一批URL，每个任务负责发起HTTP请求获取响应状态码，并将结果汇总输出。整个过程使用channel进行协调和通信。
以下是完整可运行的代码示例：
package main
import (
"fmt"
"net/http"
"time"
)
// Task 表示一个待处理的任务
type Task struct {
ID int
URL string
}
// Result 表示任务执行后的结果
type Result struct {
TaskID int
URL string
StatusCode int
Err error
}
// Worker 启动一个工作协程处理任务
func Worker(id int, jobs <-chan Task, results chan<- Result, timeout time.Duration) {
client := &http.Client{Timeout: timeout}
for task := range jobs {
resp, err := client.Get(task.URL)
var statusCode int
if err != nil {
// 请求失败也返回结果，便于主程序处理
statusCode = -1
} else {
statusCode = resp.StatusCode
resp.Body.Close()
}
// 将结果发送回结果channel
results <- Result{
TaskID: task.ID,
URL: task.URL,
StatusCode: statusCode,
Err: err,
}
fmt.Printf("Worker %d processed task %d: %s\n", id, task.ID, task.URL)
}
}
func main() {
const numWorkers = 3
const numTasks = 5
// 创建无缓冲任务channel和带缓冲的结果channel
jobs := make(chan Task)
results := make(chan Result, numTasks)
// 启动多个worker协程
for w := 1; w <= numWorkers; w++ {
go Worker(w, jobs, results, 5*time.Second)
}
// 发送任务到channel
go func() {
defer close(jobs) // 所有任务发送完成后关闭jobs channel
for i := 1; i <= numTasks; i++ {
jobs <- Task{
ID: i,
URL: fmt.Sprintf("https://httpbin.org/status/%d", 200+i*100%300),
}
}
}()
// 收集所有结果
for i := 0; i < numTasks; i++ {
result := <-results
if result.Err != nil {
fmt.Printf("Task %d (%s) failed: %v\n", result.TaskID, result.URL, result.Err)
} else {
fmt.Printf("Task %d (%s) returned status: %d\n", result.TaskID, result.URL, result.StatusCode)
}
}
// 可选：等待一段时间确保所有goroutine完成（生产环境建议用sync.WaitGroup）
time.Sleep(time.Second)
}关键设计点解析
channel类型选择：任务channel使用无缓冲channel（make(chan Task)），保证任务被真正消费才继续；结果channel使用带缓冲channel，避免worker阻塞。
立即学习“go语言免费学习笔记（深入）”；
优雅关闭机制：通过defer close(jobs)确保任务发送完成后关闭channel，range循环会自动退出，防止goroutine泄漏。
错误处理统一：即使请求失败，仍然通过result channel返回信息，主流程能集中处理成功与失败情况。
扩展建议
- 加入context控制整体超时或取消信号
- 使用sync.WaitGroup替代sleep等待worker结束
- 增加限流逻辑，防止瞬间大量HTTP请求
- 将结果写入文件或数据库，而非仅打印
基本上就这些。这个例子展示了channel如何自然地串联起任务分发、并发执行和结果聚合三个阶段，是Go并发编程的经典模式。
