本文详解 go 语言中基于 goroutine 的并发端口扫描实现，重点解决因未关闭通道导致的程序阻塞问题，并提供健壮、可复用的并发扫描模式。
本文详解 go 语言中基于 goroutine 的并发端口扫描实现，重点解决因未关闭通道导致的程序阻塞问题，并提供健壮、可复用的并发扫描模式。
在 Go 中实现高性能端口扫描，核心在于合理利用并发模型——goroutine + channel + sync.WaitGroup 的经典组合。你提供的代码逻辑基本正确，但存在一个关键缺陷：未关闭用于接收结果的 channel，导致 for elem := range ch 永远阻塞，程序无法退出。
为什么程序会卡住？
Go 中 range 遍历 channel 时，会一直等待新值，直到该 channel 被显式关闭（close(ch)）。你的代码中：
- 创建了带缓冲的 channel：ch := make(chan *portscan.ScanResult, len(splitPorts))
- 启动所有 goroutine 并调用 wg.Wait() 等待全部完成
- 但未在 wg.Wait() 后执行 close(ch)
因此，即使所有 goroutine 已发送完结果并调用 wg.Done()，主 goroutine 仍在 range ch 中无限等待“可能的后续数据”，造成死锁。
正确的并发扫描结构（修正版）
func scanPorts(ip string, ports []int32, timeout int32) []*portscan.ScanResult {
ch := make(chan *portscan.ScanResult, len(ports))
var wg sync.WaitGroup
// 启动每个端口的扫描 goroutine
for _, port := range ports {
wg.Add(1)
go func(p int32) {
defer wg.Done() // 推荐 defer，确保执行
res := &portscan.ScanResult{
Port: p,
IsOpen: false,
}
addr := fmt.Sprintf("%s:%d", ip, p)
conn, err := net.DialTimeout("tcp", addr, time.Duration(timeout)*time.Millisecond)
if err == nil {
conn.Close()
res.IsOpen = true
}
ch <h3>关键注意事项与学习要点</h3>
- close(ch) 必须由 sender（即主 goroutine）在 wg.Wait() 后调用：只有 sender 知道所有数据已发送完毕；receiver 不应也不允许关闭 channel。
- 避免闭包变量捕获陷阱：循环中启动 goroutine 时，若直接引用 port 变量（如 go func(){...}(port) 未传参），所有 goroutine 可能读到同一个最终值。应通过函数参数 go func(p int32){...}(port) 显式传递当前值。
- channel 缓冲大小建议设为 len(ports)：防止 goroutine 因 channel 满而阻塞，同时避免内存浪费。
- 超时与错误处理需健壮：net.DialTimeout 已处理连接超时，但生产环境建议进一步封装重试、限速（如使用 semaphore 控制并发数），避免对目标主机造成过大压力。
- protobuf 兼容性提示：你使用 int32 是因 protobuf 不支持 int16，这是合理妥协；但实际网络编程中端口号范围是 0–65535，uint16 更语义准确——可在业务层转换，不影响 protobuf 序列化。
总结
端口扫描是理解 Go 并发模型的绝佳实践场景。其本质是「扇出（fan-out）→ 并发执行 → 扇入（fan-in）」模式：用 goroutine 扇出任务，用 channel 收集结果，用 WaitGroup 同步完成信号。close(channel) 是扇入阶段的必要收尾动作，缺失它将破坏整个并发流程的确定性。掌握这一模式，不仅解决端口扫描问题，更为构建高并发网络工具打下坚实基础。
