package main

import (
	"context"
	"errors"
	"sync"
)

func request(ctx context.Context, url string) error {
	result := make(chan int)
	err := make(chan error)
	go func() {
		// 假如isSuccess是請(qǐng)求返回的結(jié)果，成功則通過(guò)result傳遞成功信息，錯(cuò)誤通過(guò)error傳遞錯(cuò)誤信息
		isSuccess := true
		if isSuccess {
			result <- 1
		} else {
			err <- errors.New("some error happen")
		}
	}()

	select {
	case <-ctx.Done():
		// 其他請(qǐng)求失敗
		return ctx.Err()
	case e := <-err:
		// 本次請(qǐng)求失敗，返回錯(cuò)誤信息
		return e
	case <-result:
		// 本此請(qǐng)求成功，不返回錯(cuò)誤信息
		return nil
	}
}

func main() {
	ctx, cancel := context.WithCancel(context.Background())
	// 調(diào)用接口a
	err := request(ctx, "https://xxx.com/a")
	if err != nil {
		return
	}
	wg := sync.WaitGroup{}
	// 調(diào)用接口b
	wg.Add(1)
	go func() {
		defer wg.Done()
		err := request(ctx, "https://xxx.com/b")
		if err != nil {
			cancel()
		}
	}()
	// 調(diào)用接口c
	wg.Add(1)
	go func() {
		defer wg.Done()
		err := request(ctx, "https://xxx.com/c")
		if err != nil {
			cancel()
		}
	}()
	wg.Wait()
}

package main

import (
    "context"
    "fmt"
    "time"
)

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 50*time.Millisecond)
    defer cancel()

    select {
    case <-time.After(1 * time.Second):
        fmt.Println("overslept")
    case <-ctx.Done():
        fmt.Println(ctx.Err()) // 輸出 "context deadline exceeded"
    }
}

package main

import (
	"context"
	"io"
	"log"
	"net/http"
	"time"
)

func main() {
	req, err := http.NewRequest(http.MethodGet, "https://www.baidu.com", nil)
	if err != nil {
		log.Fatal(err)
	}

	// 構(gòu)造一個(gè)超時(shí)間為50毫秒的Context
	ctx, cancel := context.WithTimeout(context.Background(), 50*time.Millisecond)
	defer cancel()
	req = req.WithContext(ctx)
	
	c := &http.Client{}
	res, err := c.Do(req)
	if err != nil {
		log.Fatal(err)
	}
	defer res.Body.Close()
	out, err := io.ReadAll(res.Body)
	if err != nil {
		log.Fatal(err)
	}
	log.Println(string(out))
}

type traceIdKey struct{}{}

// 定義固定的Key
var TraceIdKey = traceIdKey{}

func ServeHTTP(w http.ResponseWriter, req *http.Request){
  // 首先從請(qǐng)求中獲取到traceID
  traceId := getTraceIdFromRequest(req)
  // 將Key存入Context中
  ctx := context.WithValue(req.Context(), TraceIdKey, traceId)
  // 設(shè)置超時(shí)時(shí)間
  ctx = context.WithTimeout(ctx, time.Second)
  // 攜帶traceId發(fā)起rpc請(qǐng)求
  repResp := RequestRPC(ctx, ...)
  // 攜帶traceId查詢(xún)DB
  dbResp := RequestDB(ctx, ...)
  // ...
}

func RequestRPC(ctx context.Context, ...) interface{} {
    // 獲取traceid，在調(diào)用rpc時(shí)記錄日志
    traceId, _ := ctx.Value(TraceIdKey)
    // 發(fā)起請(qǐng)求

    // ...
    return
}