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

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

PHPz

リリース： 2023-10-09 10:05:07

オリジナル

1114 人が閲覧しました

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

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

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

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

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("所有请求已完成")
}

ログイン後にコピー

使用 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 を使用して例外処理を実装できます。

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("所有请求已发送")
}

ログイン後にコピー

使用 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 サイトの他の関連記事を参照してください。