Go 語言 并發(fā)獲取多個URL

原文鏈接：https://gopl-zh.github.io/ch1/ch1-06.html

1.6. 并發(fā)獲取多個URL

Go語言最有意思并且最新奇的特性就是對并發(fā)編程的支持。并發(fā)編程是一個大話題，在第八章和第九章中會專門講到。這里我們只淺嘗輒止地來體驗一下Go語言里的goroutine和channel。

下面的例子fetchall，和前面小節(jié)的fetch程序所要做的工作基本一致，fetchall的特別之處在于它會同時去獲取所有的URL，所以這個程序的總執(zhí)行時間不會超過執(zhí)行時間最長的那一個任務，前面的fetch程序執(zhí)行時間則是所有任務執(zhí)行時間之和。fetchall程序只會打印獲取的內(nèi)容大小和經(jīng)過的時間，不會像之前那樣打印獲取的內(nèi)容。

gopl.io/ch1/fetchall

// Fetchall fetches URLs in parallel and reports their times and sizes.
package main

import (
    "fmt"
    "io"
    "io/ioutil"
    "net/http"
    "os"
    "time"
)

func main() {
    start := time.Now()
    ch := make(chan string)
    for _, url := range os.Args[1:] {
        go fetch(url, ch) // start a goroutine
    }
    for range os.Args[1:] {
        fmt.Println(<-ch) // receive from channel ch
    }
    fmt.Printf("%.2fs elapsed\n", time.Since(start).Seconds())
}

func fetch(url string, ch chan<- string) {
    start := time.Now()
    resp, err := http.Get(url)
    if err != nil {
        ch <- fmt.Sprint(err) // send to channel ch
        return
    }
    nbytes, err := io.Copy(ioutil.Discard, resp.Body)
    resp.Body.Close() // don't leak resources
    if err != nil {
        ch <- fmt.Sprintf("while reading %s: %v", url, err)
        return
    }
    secs := time.Since(start).Seconds()
    ch <- fmt.Sprintf("%.2fs  %7d  %s", secs, nbytes, url)
}

下面使用fetchall來請求幾個地址：

$ go build gopl.io/ch1/fetchall
$ ./fetchall https://golang.org http://gopl.io https://godoc.org
0.14s     6852  https://godoc.org
0.16s     7261  https://golang.org
0.48s     2475  http://gopl.io
0.48s elapsed

goroutine是一種函數(shù)的并發(fā)執(zhí)行方式，而channel是用來在goroutine之間進行參數(shù)傳遞。main函數(shù)本身也運行在一個goroutine中，而go function則表示創(chuàng)建一個新的goroutine，并在這個新的goroutine中執(zhí)行這個函數(shù)。

main函數(shù)中用make函數(shù)創(chuàng)建了一個傳遞string類型參數(shù)的channel，對每一個命令行參數(shù)，我們都用go這個關鍵字來創(chuàng)建一個goroutine，并且讓函數(shù)在這個goroutine異步執(zhí)行http.Get方法。這個程序里的io.Copy會把響應的Body內(nèi)容拷貝到ioutil.Discard輸出流中（譯注：可以把這個變量看作一個垃圾桶，可以向里面寫一些不需要的數(shù)據(jù)），因為我們需要這個方法返回的字節(jié)數(shù)，但是又不想要其內(nèi)容。每當請求返回內(nèi)容時，fetch函數(shù)都會往ch這個channel里寫入一個字符串，由main函數(shù)里的第二個for循環(huán)來處理并打印channel里的這個字符串。

當一個goroutine嘗試在一個channel上做send或者receive操作時，這個goroutine會阻塞在調(diào)用處，直到另一個goroutine從這個channel里接收或者寫入值，這樣兩個goroutine才會繼續(xù)執(zhí)行channel操作之后的邏輯。在這個例子中，每一個fetch函數(shù)在執(zhí)行時都會往channel里發(fā)送一個值（ch <- expression），主函數(shù)負責接收這些值（<-ch）。這個程序中我們用main函數(shù)來完整地處理/接收所有fetch函數(shù)傳回的字符串，可以避免因為有兩個goroutine同時完成而使得其輸出交錯在一起的危險。

練習 1.10： 找一個數(shù)據(jù)量比較大的網(wǎng)站，用本小節(jié)中的程序調(diào)研網(wǎng)站的緩存策略，對每個URL執(zhí)行兩遍請求，查看兩次時間是否有較大的差別，并且每次獲取到的響應內(nèi)容是否一致，修改本節(jié)中的程序，將響應結(jié)果輸出到文件，以便于進行對比。

練習 1.11： 在fetchall中嘗試使用長一些的參數(shù)列表，比如使用在alexa.com的上百萬網(wǎng)站里排名靠前的。如果一個網(wǎng)站沒有回應，程序?qū)⒉扇≡鯓拥男袨?？（Section8.9 描述了在這種情況下的應對機制）。