Go语言Channels实现TCP/IP端口扫描未返回全部开放端口求助

Hey there! 先给你吃个定心丸：Channels绝对是Go里实现并发端口扫描的正确姿势——毕竟Go的CSP并发模型天生就适合这种高IO、多任务并行的场景，比Ruby里的并发实现要高效得多。你现在扫不全开放端口，大概率是Channels的使用逻辑或者并发控制出了问题，我给你梳理几个常见的坑和解决思路：

常见问题排查点 #

1. 主goroutine提前退出，未等待扫描任务完成 #

这是最容易犯的错误：你启动了一堆goroutine去扫端口，但主goroutine没等它们全部跑完就直接退出了，导致部分扫描任务被强制终止，自然会漏掉开放端口。

解决办法：用sync.WaitGroup配合Channels，等所有扫描goroutine执行完毕后再关闭结果Channel，确保主goroutine能接收完所有扫描结果。

2. 并发数过高被目标限流/拦截 #

如果一下子启动几百上千个goroutine同时发起连接，目标主机的防火墙或者TCP栈可能会把你的请求当成洪水攻击，直接丢弃部分连接请求，导致你误以为这些端口是关闭的。

解决办法：用带缓冲的Channel做信号量，限制同时运行的扫描goroutine数量（比如设为50-100，根据目标网络环境调整），避免请求过载。

3. 未设置合理的连接超时 #

Go的默认TCP连接超时可能不符合扫描需求：如果超时太短，部分响应慢的开放端口会被误判为关闭；如果超时太长，扫描速度会变得极慢，甚至可能导致部分任务挂起。

解决办法：一定要用net.DialTimeout显式设置超时时间（比如1-3秒），确保每个连接尝试都能在合理时间内得到结果。

4. Channel接收逻辑不完整 #

比如你用for range接收结果，但没有正确关闭Channel，导致主goroutine一直阻塞；或者用select时只处理了部分情况，导致部分开放端口的结果没有被接收。

解决办法：在所有扫描任务完成后，一定要关闭结果Channel，这样for range才能正常退出，遍历完所有结果。

5. 错误处理不当 #

有些时候，连接失败并不代表端口关闭（比如防火墙拦截导致的超时），但如果你的代码直接忽略所有错误，可能会把某些特殊情况的开放端口漏掉；反过来，如果错误处理逻辑错误，也可能把开放端口当成错误丢弃。

解决办法：可以根据错误类型做区分，比如判断是connection refused（端口确实关闭）还是timeout（可能被过滤），不过对于基础扫描来说，只要能捕获到成功连接的情况即可。

正确的示例代码 #

给你一个简单的参考实现，覆盖了上面提到的所有关键点：

package main

import (
	"fmt"
	"net"
	"sync"
	"time"
)

// 单个端口扫描函数
func scanPort(host string, port int, results chan<- string, wg *sync.WaitGroup) {
	defer wg.Done()
	addr := fmt.Sprintf("%s:%d", host, port)
	// 显式设置2秒超时
	conn, err := net.DialTimeout("tcp", addr, 2*time.Second)
	if err != nil {
		return
	}
	defer conn.Close()
	results <- fmt.Sprintf("Port %d is open", port)
}

func main() {
	targetHost := "127.0.0.1"
	startPort := 1
	endPort := 1000

	// 用于接收扫描结果的Channel
	results := make(chan string)
	var wg sync.WaitGroup

	// 并发控制信号量：最多同时运行50个扫描goroutine
	semaphore := make(chan struct{}, 50)

	for port := startPort; port <= endPort; port++ {
		wg.Add(1)
		semaphore <- struct{}{} // 占用一个并发槽位
		// 启动goroutine扫描端口，注意传参避免循环变量问题
		go func(p int) {
			defer func() { <-semaphore }() // 释放槽位
			scanPort(targetHost, p, results, &wg)
		}(port)
	}

	// 单独启动goroutine，等待所有扫描完成后关闭结果Channel
	go func() {
		wg.Wait()
		close(results)
	}()

	// 遍历所有扫描结果并输出
	for result := range results {
		fmt.Println(result)
	}
}

总结 #

Channels完全适合用来实现Go的端口扫描，你的问题应该是在并发控制、goroutine等待、超时设置或者结果接收逻辑上出了疏漏。可以对照上面的排查点和示例代码，检查自己的实现哪里有问题，应该就能解决扫不全端口的问题了。

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