Go 言語でのリクエスト サービスの低下と同時ネットワーク リクエストの例外処理の問題を解決するにはどうすればよいですか?

リクエスト サービスの低下と同時ネットワーク リクエストの例外処理の問題を Go 言語で解決するにはどうすればよいですか?

インターネットの急速な発展に伴い、同時ネットワーク要求を必要とするアプリケーションがますます増えています。ただし、同時実行性が高い場合、ネットワーク要求によりタイムアウト、ブロッキング、その他の問題が発生する可能性があり、システム全体の安定性と信頼性に影響を与えます。この問題に直面した場合、Go 言語が提供するいくつかのテクノロジーを使用して、リクエスト サービスの低下と同時ネットワーク リクエストの例外処理の問題を解決できます。

1. リクエスト サービスのダウングレード
システム負荷が特定のしきい値に達した場合、システム全体の安定性を確保するためにリクエスト サービスのダウングレード ルールを設定することで、一部の複雑で時間のかかるリクエストをダウングレードできます。 Go 言語では、sync.WaitGroup と context を使用して、リクエスト サービスのダウングレードを実装できます。

1. sync.WaitGroup を使用して、すべてのコルーチン リクエストが終了するのを待ちます。

   package main
   
   import (
    "fmt"
    "net/http"
    "sync"
   )
   
   func makeRequest(url string, wg *sync.WaitGroup) {
    defer wg.Done()
   
    resp, err := http.Get(url)
    if err != nil {
        fmt.Printf("请求 [%s] 失败：%s
   ", url, err.Error())
        return
    }
    defer resp.Body.Close()
   
    // 处理响应数据
    // ...
   }
   
   func main() {
    urls := []string{
        "https://www.example.com",
        "https://www.example2.com",
        "https://www.example3.com",
    }
   
    var wg sync.WaitGroup
    wg.Add(len(urls))
   
    for _, url := range urls {
        go makeRequest(url, &wg)
    }
   
    wg.Wait()
   
    fmt.Println("所有请求已完成")
   }

2. 使用 context リクエストのタイムアウトを制御するには

   package main
   
   import (
    "context"
    "fmt"
    "net/http"
    "time"
   )
   
   func makeRequest(url string, ctx context.Context) {
    req, err := http.NewRequest("GET", url, nil)
    if err != nil {
        fmt.Printf("创建请求 [%s] 失败：%s
   ", url, err.Error())
        return
    }
   
    // 设置请求超时时间为2秒
    ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
    defer cancel()
   
    req = req.WithContext(ctx)
   
    resp, err := http.DefaultClient.Do(req)
    if err != nil {
        fmt.Printf("请求 [%s] 失败：%s
   ", url, err.Error())
        return
    }
    defer resp.Body.Close()
   
    // 处理响应数据
    // ...
   }
   
   func main() {
    urls := []string{
        "https://www.example.com",
        "https://www.example2.com",
        "https://www.example3.com",
    }
   
    ctx := context.Background()
   
    for _, url := range urls {
        go makeRequest(url, ctx)
    }
   
    time.Sleep(5 * time.Second)
   
    fmt.Println("所有请求已超时")
   }

2. 例外処理
リクエストプロセス中に、ネットワーク上の理由やサーバーエラーなどにより、リクエストが失敗したり、リクエストが失敗したりする場合があります。システムの信頼性を確保するためには、異常事態に対処する必要があります。 Go 言語では、defer と recover を使用して例外処理を実装できます。

1. defer と recover 例外を処理する

   package main
   
   import (
    "fmt"
    "net/http"
   )
   
   func makeRequest(url string) {
    defer func() {
        if r := recover(); r != nil {
            fmt.Printf("请求 [%s] 发生异常：%s
   ", url, r)
        }
    }()
   
    resp, err := http.Get(url)
    if err != nil {
        panic(err)
    }
    defer resp.Body.Close()
   
    // 处理响应数据
    // ...
   }
   
   func main() {
    urls := []string{
        "https://www.example.com",
        "https://www.example2.com",
        "https://www.example3.com",
    }
   
    for _, url := range urls {
        go makeRequest(url)
    }
   
    fmt.Println("所有请求已发送")
   }

2. 使用 errgroup複数のリクエストの例外を処理するライブラリ

   package main
   
   import (
    "fmt"
    "net/http"
   
    "golang.org/x/sync/errgroup"
   )
   
   func makeRequest(url string) error {
    resp, err := http.Get(url)
    if err != nil {
        return err
    }
    defer resp.Body.Close()
   
    // 处理响应数据
    // ...
   
    return nil
   }
   
   func main() {
    urls := []string{
        "https://www.example.com",
        "https://www.example2.com",
        "https://www.example3.com",
    }
   
    var eg errgroup.Group
   
    for _, url := range urls {
        url := url
        eg.Go(func() error {
            return makeRequest(url)
        })
    }
   
    if err := eg.Wait(); err != nil {
        fmt.Printf("发生错误：%s
   ", err.Error())
    } else {
        fmt.Println("所有请求已完成")
    }
   }

上記は、Go 言語でのリクエスト サービスの低下と同時ネットワーク リクエストの例外処理の問題を解決するための具体的なコード例です。 sync.WaitGroup、context、defer、recover などの機能を適切に利用することで、同時ネットワークのフローをより適切に制御できます。安定性と信頼性により、より優れたユーザー エクスペリエンスを提供します。

以上がGo 言語でのリクエスト サービスの低下と同時ネットワーク リクエストの例外処理の問題を解決するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。