package main

import (
	"fmt"
	"time"
)

func main() {
	// 在主 goroutine 中設(shè)置 defer，用于捕獲 panic
	// 注意：這個(gè) defer 只能捕獲發(fā)生在主 goroutine 中的 panic
	defer func() {
		// recover() 只能捕獲當(dāng)前 goroutine 內(nèi)的 panic，
		// 如果 panic 發(fā)生在其他 goroutine 中，該 defer 無(wú)法捕獲
		if e := recover(); e != nil {
			fmt.Println("捕獲到 panic：", e)
		}
	}()

	// 啟動(dòng)子 goroutine，演示 panic 的傳播范圍
	go func() {
		// 輸出提示信息，表示子 goroutine 開(kāi)始執(zhí)行
		fmt.Println("子 goroutine 開(kāi)始")
		// 主動(dòng)觸發(fā) panic，注意這里的 panic 發(fā)生在子 goroutine 內(nèi)，
		// 因此主 goroutine 中的 defer 無(wú)法捕獲該 panic
		panic("Goroutine 發(fā)生 panic")
	}()

	// 主 goroutine 等待一段時(shí)間，確保子 goroutine 有足夠時(shí)間執(zhí)行
	time.Sleep(2 * time.Second)
	// 輸出主 goroutine 結(jié)束信息
	fmt.Println("主 goroutine 結(jié)束")
}

子 goroutine 開(kāi)始
panic: Goroutine 發(fā)生 panic

goroutine 18 [running]:
main.main.func2()
        ~/golang-tutorial/tt.go:25 +0x59
created by main.main in goroutine 1
        ~/golang-tutorial/tt.go:20 +0x3b
exit status 2

package main

import (
	"fmt"
	"time"
)

func main() {
	defer func() {
		if e := recover(); e != nil {
			fmt.Println("捕獲到 panic：", e)
		}
	}()

	go func() {
		defer func() {
			if e := recover(); e != nil {
				fmt.Println("子 goroutine 捕獲到 panic：", e)
			}
		}()
		fmt.Println("子 goroutine 開(kāi)始")
		panic("Goroutine 發(fā)生 panic")
	}()

	time.Sleep(2 * time.Second)
	fmt.Println("主 goroutine 結(jié)束")
}

子 goroutine 開(kāi)始
子 goroutine 捕獲到 panic： Goroutine 發(fā)生 panic
主 goroutine 結(jié)束

package main

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

func main() {
	urls := []string{
		"https://httpbin1.org/get",
		"https://httpbin.org/get",
		"https://httpbin2.org/get",
		"https://httpbin3.org/get",
	}

	var wg sync.WaitGroup
	// 創(chuàng)建一個(gè)帶緩沖的錯(cuò)誤通道，大小為 URL 數(shù)量
	errCh := make(chan error, len(urls))

	// 遍歷所有 URL，分別啟動(dòng) goroutine 發(fā)起請(qǐng)求
	for _, url := range urls {
		wg.Add(1)
		go func(url string) {
			defer wg.Done() // 保證 goroutine 結(jié)束時(shí)減少計(jì)數(shù)
			resp, err := http.Get(url)
			if err != nil {
				// 如果請(qǐng)求出錯(cuò)，將錯(cuò)誤發(fā)送到錯(cuò)誤通道中
				errCh <- fmt.Errorf("請(qǐng)求 %s 失?。?%v", url, err)
				return
			}
			defer resp.Body.Close()
			// 打印成功信息
			fmt.Printf("請(qǐng)求 %s 成功，狀態(tài)碼： %d\n", url, resp.StatusCode)
		}(url)
	}

	// 等待所有 goroutine 執(zhí)行完畢
	wg.Wait()
	// 關(guān)閉錯(cuò)誤通道
	close(errCh)

	// 遍歷錯(cuò)誤通道，輸出所有錯(cuò)誤信息
	for err := range errCh {
		fmt.Println("錯(cuò)誤信息：", err)
	}
}

package main

import (
	"fmt"
	"io"
	"net/http"
	"sync"
)

// Result 用于封裝每個(gè)請(qǐng)求的結(jié)果和錯(cuò)誤信息
type Result struct {
	URL        string // 請(qǐng)求的 URL
	StatusCode int    // 返回的 HTTP 狀態(tài)碼
	Err        error  // 請(qǐng)求過(guò)程中發(fā)生的錯(cuò)誤
	Content    []byte // 返回的內(nèi)容
}

func main() {
	urls := []string{
		"https://httpbin1.org/get",
		"https://httpbin.org/get",
		"https://httpbin2.org/get",
		"https://httpbin3.org/get",
	}

	var wg sync.WaitGroup
	// 創(chuàng)建帶緩沖的結(jié)果通道，大小為 URL 數(shù)量
	resCh := make(chan Result, len(urls))

	// 遍歷 URL，啟動(dòng) goroutine 進(jìn)行請(qǐng)求
	for _, url := range urls {
		wg.Add(1)
		go func(url string) {
			defer wg.Done()
			resp, err := http.Get(url)

			result := Result{URL: url}

			if err != nil {
				// 將錯(cuò)誤結(jié)果封裝后發(fā)送到結(jié)果通道
				result.Err = err
			} else {
				defer resp.Body.Close()
				body, _ := io.ReadAll(resp.Body)
				// 將成功的結(jié)果封裝后發(fā)送到結(jié)果通道
				result.StatusCode = resp.StatusCode
				result.Content = body
			}

			resCh <- result
		}(url)
	}

	// 等待所有 goroutine 執(zhí)行完畢
	wg.Wait()
	close(resCh)

	// 遍歷結(jié)果通道，輸出每個(gè)請(qǐng)求的結(jié)果和錯(cuò)誤信息
	for res := range resCh {
		if res.Err != nil {
			fmt.Printf("請(qǐng)求 %s 失敗： %v\n", res.URL, res.Err)
		} else {
			fmt.Printf("請(qǐng)求 %s 成功，狀態(tài)碼： %d, 內(nèi)容： %s \n", res.URL, res.StatusCode, string(res.Content))
		}
	}
}

package main

import (
	"fmt"
	"net/http"

	"golang.org/x/sync/errgroup"
)

func main() {
	urls := []string{
		"https://httpbin1.org/get",
		"https://httpbin.org/get",
		"https://httpbin2.org/get",
		"https://httpbin3.org/get",
	}

	// 定義一個(gè)存儲(chǔ)結(jié)果的切片，與 errgroup 共同使用
	results := make([]string, len(urls))
	var g errgroup.Group

	// 遍歷所有 URL，啟動(dòng) goroutine 執(zhí)行 HTTP 請(qǐng)求
	for i, url := range urls {
		i, url := i, url // 為了避免閉包引用同一個(gè)變量
		g.Go(func() error {
			fmt.Println("開(kāi)始請(qǐng)求：", url)
			resp, err := http.Get(url)
			if err != nil {
				return fmt.Errorf("請(qǐng)求 %s 失?。?%v", url, err)
			}
			defer resp.Body.Close()
			results[i] = fmt.Sprintf("請(qǐng)求 %s 成功，狀態(tài)碼： %d", url, resp.StatusCode)
			return nil
		})
	}

	// 等待所有 goroutine 執(zhí)行完畢
	if err := g.Wait(); err != nil {
		fmt.Println("發(fā)生錯(cuò)誤：", err)
	}

	// 輸出所有請(qǐng)求成功的結(jié)果
	for _, res := range results {
		fmt.Println(res)
	}
}

開(kāi)始請(qǐng)求： https://httpbin3.org/get
開(kāi)始請(qǐng)求： https://httpbin2.org/get
開(kāi)始請(qǐng)求： https://httpbin1.org/get
開(kāi)始請(qǐng)求： https://httpbin.org/get
發(fā)生錯(cuò)誤： 請(qǐng)求 https://httpbin3.org/get 失?。?Get "https://httpbin3.org/get": dial tcp: lookup httpbin3.org: no such host

請(qǐng)求 https://httpbin.org/get 成功，狀態(tài)碼： 200

package main

import (
	"context"
	"fmt"
	"net/http"

	"golang.org/x/sync/errgroup"
)

func main() {
	urls := []string{
		"https://httpbin1.org/get",
		"https://httpbin.org/get",
		"https://httpbin2.org/get",
		"https://httpbin3.org/get",
	}

	// 使用 context.Background 創(chuàng)建基本上下文，并通過(guò) WithContext 包裝 errgroup
	ctx := context.Background()
	g, ctx := errgroup.WithContext(ctx)

	// 定義存儲(chǔ)結(jié)果的切片
	results := make([]string, len(urls))

	// 遍歷所有 URL，啟動(dòng) goroutine 發(fā)起請(qǐng)求
	for i, url := range urls {
		i, url := i, url
		g.Go(func() error {
			fmt.Println("開(kāi)始請(qǐng)求：", url)
			// 在發(fā)起請(qǐng)求前，根據(jù) context 判斷是否取消
			req, err := http.NewRequestWithContext(ctx, "GET", url, nil)
			if err != nil {
				return err
			}

			resp, err := http.DefaultClient.Do(req)
			if err != nil {
				return fmt.Errorf("請(qǐng)求 %s 失敗： %v", url, err)
			}
			defer resp.Body.Close()

			results[i] = fmt.Sprintf("請(qǐng)求 %s 成功，狀態(tài)碼： %d", url, resp.StatusCode)
			return nil
		})
	}

	// 如果有任一任務(wù)返回錯(cuò)誤，將自動(dòng)取消所有依賴于 ctx 的請(qǐng)求
	if err := g.Wait(); err != nil {
		fmt.Println("錯(cuò)誤發(fā)生：", err)
	}

	for _, res := range results {
		fmt.Println(res)
	}
}

開(kāi)始請(qǐng)求： https://httpbin3.org/get
開(kāi)始請(qǐng)求： https://httpbin.org/get
開(kāi)始請(qǐng)求： https://httpbin2.org/get
開(kāi)始請(qǐng)求： https://httpbin1.org/get
錯(cuò)誤發(fā)生： 請(qǐng)求 https://httpbin1.org/get 失?。?Get "https://httpbin1.org/get": dial tcp: lookup httpbin1.org: no such host