Go语言读取空通道异常：并发订阅通知问题排查

你遇到的问题核心在于消费者goroutine没有正确处理通道关闭后的零值读取，导致通道关闭后持续读取到空的targetUrl并发送无效请求。

具体来说，你的代码大概率是类似这样的结构（简化版）：

// 创建用于传递订阅地址的通道
buffer := make(chan string)

// 启动100个消费者goroutine
for i := 0; i < 100; i++ {
    go func() {
        // 无限循环读取通道
        for {
            sub := <-buffer
            // 向sub发送POST请求
            sendRequest(sub)
        }
    }()
}

// 生产者：将所有订阅者的targetUrl送入通道
for _, target := range subscribers {
    buffer <- target
}
// 假设这里已关闭通道
close(buffer)

当通道被关闭后，<-buffer不会再阻塞等待新数据，而是会持续返回对应类型的零值（这里就是空字符串）。你的消费者goroutine里的无限循环没有判断通道是否已经读完所有有效数据，所以会一直拿到空的targetUrl，然后不断发送无效请求。

你需要让消费者在通道关闭且所有有效元素都处理完后自动退出循环，有两种简洁且符合Go惯用写法的方式：

方式一：使用for range遍历通道（推荐） #

for range会自动在通道关闭且所有元素都被读取后终止循环，无需手动判断，是处理这类场景最简洁的写法：

for i := 0; i < 100; i++ {
    go func() {
        // 遍历通道，直到通道关闭且无剩余有效元素
        for sub := range buffer {
            sendRequest(sub)
        }
        // 循环结束后，goroutine自动退出
    }()
}

方式二：显式判断通道状态 #

如果你需要更细粒度的控制，可以用sub, more := <-buffer的方式，当more为false时，说明通道已关闭且无剩余有效数据，直接退出循环即可：

for i := 0; i < 100; i++ {
    go func() {
        for {
            sub, more := <-buffer
            if !more {
                // 通道已关闭，无更多数据，退出循环
                return
            }
            sendRequest(sub)
        }
    }()
}

这两种方式都能彻底解决读取空通道的问题，让goroutine在任务完成后自动退出，程序也能正常终止，比你之前的临时方案更简洁可靠。

内容的提问来源于stack exchange，提问作者GwydionFR