Golang channel通信机制项目示例-Golang-PHP中文网

Golang channel通信机制项目示例

P粉602998670

发布： 2025-10-15 17:17:02

原创

1154人浏览过

Go语言中channel用于goroutine间通信。示例构建并发任务系统：通过无缓冲channel分发URL任务，多个worker协程处理HTTP请求，结果通过带缓冲channel返回，主程序收集并输出。使用defer close关闭channel确保优雅退出，错误统一返回，体现任务分发、并发执行与结果聚合的经典并发模式。

golang 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)
}

登录后复制