Function Iterate

utils.go:101–139

Iterate 从Reader中迭代读取主机信息

(reader io.Reader)

// Iterate 从Reader中迭代读取主机信息
func Iterate(reader io.Reader) <-chan Host {
	hostChan := make(chan Host, 100) // 带缓冲的channel
	
	go func() {
		defer close(hostChan)
		
		scanner := bufio.NewScanner(reader)
		for scanner.Scan() {
			line := strings.TrimSpace(scanner.Text())
			
			// 跳过空行和注释行
			if line == "" || strings.HasPrefix(line, "#") {
				continue
			}
			
			// 解析主机
			host, err := ParseHost(line)
			if err != nil {
				if config.Verbose {
					printError(fmt.Sprintf("解析失败: %s - %v", line, err))
				}
				continue
			}
			
			// 如果是CIDR，展开所有IP
			if host.Type == HostTypeCIDR {
				expandCIDR(host, hostChan)
			} else {
				hostChan <- host
			}
		}
		
		if err := scanner.Err(); err != nil {
			printError(fmt.Sprintf("读取输入时出错: %v", err))
		}
	}()
	
	return hostChan
}

// expandCIDR 展开CIDR为所有包含的IP地址
func expandCIDR(host Host, hostChan chan<- Host) {