Go语言多线程爬虫万能模板它来了！

package main

import (
	"fmt"
	"net/http"
	"os"
	"strings"
	"sync"
)

const (
	proxyHost = "duoip"
	proxyPort = 8000
)

func main() {
	// 创建一个字典来存储商品信息
	productMap := make(map[string]string)

	// 创建一个锁来保护商品字典
锁 := sync.Mutex{}

	// 创建一个队列来存储要爬取的页面
	queue := make(chan string)

	// 创建一个信号量来控制并发数量
	sem := make(chan int, 10)

	// 创建一个信号量来控制线程数量
	threads := make(chan int, 10)

	// 创建一个信号量来控制线程数量
	complete := make(chan bool)

	// 启动一个线程来处理队列
	go handleQueue(queue, sem, productMap, lock, complete)

	// 启动10个线程来爬取页面
	for i := 0; i < 10; i++ {
		threads <- i
	}

	// 关闭信号量来停止线程
	close(threads)

	// 关闭信号量来停止线程
	close(sem)

	// 关闭信号量来停止爬取
	close(queue)

	// 等待所有线程完成
	for i := 0; i < 10; i++ {
		<-complete
	}

	// 打印商品信息
	for _, product := range productMap {
		fmt.Println(product)
	}
}

func handleQueue(queue chan string, sem chan int, productMap map[string]string, lock sync.Mutex, complete chan bool) {
	// 获取信号量来控制并发数量
	sem <- 1
	defer func() {
		<-sem
	}()

	// 从队列中取出一个页面
	page := <-queue

	// 使用代理信息进行网络请求
	resp, err := http.Get(fmt.Sprintf("http://%s:%d/%s", proxyHost, proxyPort, page))
	if err != nil {
		fmt.Println(err)
		return
	}
	defer resp.Body.Close()

	// 检查响应是否成功
	if resp.StatusCode != http.StatusOK {
		fmt.Println("Error:", resp.Status)
		return
	}

	// 解析响应体中的商品信息
	var product string
	if err := http.StripPrefix("/product/", resp.Body, &product); err != nil {
		fmt.Println(err)
		return
	}

	// 使用锁保护商品字典
锁.Lock()
	defer 锁.Unlock()

	// 将商品信息添加到字典中
	productMap[product] = ""

	// 将信号量发送给下一个线程
	sem <- 1
}

func parsePage(page string) {
	// 使用正则表达式解析页面中的商品信息
	// 这里只是一个示例，实际的解析逻辑可能会更复杂
	var product, price string
	if match := strings.MustCompile(`商品名称: (\w+), 价格: (\d+)`).FindStringSubmatch(page); match != nil {
		product = match[1]
		price = match[2]
	}
}