📚 课程目录第2章 Go Channel基础回顾

2. Go Channel 基础回顾：channel的创建与类型、无缓冲与有缓冲channel、channel的关闭与遍历

Channel 是 Go 语言中 goroutine 之间通信的核心原语，其设计哲学源自 C.A.R. Hoare 的 CSP（Communicating Sequential Processes）模型。在中间件链路开发中，channel 承担着数据传递、信号通知、任务编排等关键职责。本节将系统回顾 channel 的创建方式、类型体系、缓冲机制以及生命周期管理，为后续的管道链构建和错误聚合奠定基础。

2.1 Channel 的创建与类型体系

Channel 使用 make 内置函数创建，其类型由元素类型和方向性共同决定。方向性是 Go 类型系统对 channel 的静态约束，能够在编译期防止误用。

创建方式	类型	说明
`make(chan T)`	`chan T`	无缓冲 channel，双向
`make(chan T, n)`	`chan T`	有缓冲 channel，容量为 n
`make(chan<- T)`	`chan<- T`	只发送 channel（单向）
`make(<-chan T)`	`<-chan T`	只接收 channel（单向）

类型转换规则：双向 channel chan T 可以隐式转换为单向 chan<- T 或 <-chan T，但反向转换不被允许。这一特性在函数签名中广泛用于约束 channel 的使用权限。

// 创建双向 channel
ch := make(chan int, 10)

// 函数参数约束为只发送
func producer(out chan<- int) {
    out <- 42
}

// 函数参数约束为只接收
func consumer(in <-chan int) {
    val := <-in
    _ = val
}

2.2 无缓冲 Channel：同步通信的基石

无缓冲 channel（容量为 0）的发送和接收操作是同步阻塞的：发送方必须等待接收方就绪，反之亦然。这种机制天然实现了 goroutine 之间的 rendezvous（会合点）。

关键行为：
发送操作阻塞，直到有接收方读取数据
接收操作阻塞，直到有发送方写入数据
保证发送和接收发生在同一时刻，形成 happens-before 关系

func main() {
    ch := make(chan string)

    go func() {
        // 发送方：阻塞直到 main goroutine 接收
        ch <- "hello from goroutine"
    }()

    // 接收方：阻塞直到 goroutine 发送
    msg := <-ch
    fmt.Println(msg)
}

2.3 有缓冲 Channel：异步解耦与流量调节

有缓冲 channel 在创建时指定容量 n，内部维护一个 FIFO 队列。发送操作仅在缓冲区满时阻塞，接收操作仅在缓冲区空时阻塞。这种机制实现了生产者和消费者之间的异步解耦。

缓冲区状态	发送操作	接收操作
缓冲区未满	立即写入，不阻塞	—
缓冲区已满	阻塞直到有空间	—
缓冲区非空	—	立即读取，不阻塞
缓冲区为空	—	阻塞直到有数据

func main() {
    // 创建容量为 3 的有缓冲 channel
    ch := make(chan int, 3)

    // 发送 3 个元素，不会阻塞
    ch <- 1
    ch <- 2
    ch <- 3

    // 第 4 次发送会阻塞，因为缓冲区已满
    // ch <- 4  // 取消注释将导致死锁

    fmt.Println(<-ch) // 1
    fmt.Println(<-ch) // 2
    fmt.Println(<-ch) // 3
}

常见陷阱：有缓冲 channel 的容量不是性能调优的唯一参数。过大的缓冲区会掩盖生产者和消费者之间的速度不匹配，导致延迟增加和内存占用上升。在中间件链路中，建议根据实际压测结果动态调整缓冲区大小。

2.4 Channel 的关闭与遍历

关闭 channel 是通知接收方“不再有数据”的标准方式。关闭操作由发送方执行，接收方通过 value, ok := <-ch 检测 channel 是否已关闭。

关闭原则：
只在发送方关闭 channel，不要在接收方关闭
关闭已关闭的 channel 会引发 panic
向已关闭的 channel 发送数据会引发 panic
从已关闭的 channel 接收数据：缓冲区有数据则正常读取，无数据则返回零值

func main() {
    ch := make(chan int, 3)

    // 发送方
    go func() {
        for i := 0; i < 5; i++ {
            ch <- i
        }
        close(ch) // 关闭 channel，通知接收方
    }()

    // 方式1：使用 for range 遍历（推荐）
    for val := range ch {
        fmt.Println(val)
    }

    // 方式2：使用 ok 模式手动检测
    // for {
    //     val, ok := <-ch
    //     if !ok {
    //         break
    //     }
    //     fmt.Println(val)
    // }
}

操作	channel 未关闭	channel 已关闭
发送 `ch <- v`	正常发送或阻塞	panic: send on closed channel
接收 `<-ch`	正常接收或阻塞	返回零值（缓冲区空时）
接收 + ok `v, ok := <-ch`	`ok == true`	`ok == false`
`close(ch)`	正常关闭	panic: close of closed channel
`for range ch`	持续迭代	自动退出循环

最佳实践：在中间件链路中，推荐使用 for range 遍历 channel，它会在 channel 关闭时自动退出循环，避免手动管理 ok 标志。同时，使用 defer close(ch) 确保发送方在函数退出时正确关闭 channel，防止资源泄漏。

// 中间件链路中的典型模式
func pipelineStage(in <-chan Task) <-chan Result {
    out := make(chan Result, 10)
    go func() {
        defer close(out) // 确保关闭输出 channel
        for task := range in {
            result := process(task)
            out <- result
        }
    }()
    return out
}