go 构建高并发系统的关键技术：goroutines：轻量级协程，在同一个地址空间中高效运行。通道：在 goroutines 之间通信的机制，用于发送和接收值。

如何利用 Go 构建高并发系统

Go 是一种以并发性闻名的语言，使其成为构建高并发系统的理想选择。本文将介绍如何利用 Go 框架构建高并发系统，并提供实战案例。

Goroutines

立即学习“go语言免费学习笔记（深入）”；

Go 的并发性基于 Goroutines，它们是轻量级的协程。Goroutines 与线程不同，它们在同一个地址空间中运行，共享相同的内存，这意味着它们可以比线程更加高效。

package main

import (
    "fmt"
)

func main() {
    // 创建 10 个 Goroutine
    for i := 0; i < 10; i++ {
        go func(i int) {
            fmt.Printf("Goroutine %dn", i)
        }(i)
    }
}

通道

通道是一种在 Goroutines 之间通信的机制。它们允许 Goroutines 发送和接收值。

package main

import (
    "fmt"
    "sync"
)

func main() {
    // 创建一个通道
    ch := make(chan int)

    // 启动一个 Goroutine 来向通道发送值
    go func() {
        for i := 0; i < 10; i++ {
            ch <- i
        }
        close(ch)
    }()

    // 从通道中接收值
    var wg sync.WaitGroup
    wg.Add(1)
    go func() {
        for {
            v, ok := <-ch
            if !ok {
                break
            }
            fmt.Printf("Received %dn", v)
        }
        wg.Done()
    }()

    wg.Wait()
}

实战案例：并发爬虫

考虑一个需要从多个网站爬取数据的场景。我们可以使用 Go 并发性来提高爬取速度。

package main

import (
    "fmt"
    "sync"
)

type Result struct {
    URL      string
    Contents []byte
}

func main() {
    // 创建一个并发爬虫
    crawl := make(chan string)
    results := make(chan *Result)

    // 启动一个 Goroutine 来管理爬取任务
    go func() {
        for url := range crawl {
            go func(url string) {
                contents, err := fetch(url)
                if err != nil {
                    fmt.Printf("Fetch error: %vn", err)
                    return
                }
                results <- &Result{URL: url, Contents: contents}
            }(url)
        }
    }()

    // 启动一个 Goroutine 来收集结果
    go func() {
        var wg sync.WaitGroup
        for {
            r := <-results
            fmt.Printf("Crawled %sn", r.URL)
            wg.Done()
        }
    }()

    // 提交爬取任务
    crawl <- "https://example.com"
    crawl <- "https://example.org"
    close(crawl)
}

通过利用 Go 的 Goroutines 和通道，我们可以构建高并发系统，例如并发爬虫，以最大限度地提高性能。