Golang がサーキットブレーカーを実装

マイクロサービス アーキテクチャの人気に伴い、サーキット ブレーカー メカニズムは不可欠な部分になりました。サーキット ブレーカー メカニズムにより、一部のネットワークまたはサービスの障害がシステム全体に及ぼす影響を回避し、システムの信頼性と安定性を確保できます。この記事ではGolangを使ってサーキットブレーカーを実装する方法を紹介します。

サーキットブレーカーとは何ですか?

分散システムでは、サービス間の通信でネットワークの変動、ハードウェア障害、タイムアウトなどの問題が発生する可能性があります。障害による伝送異常が発見されずに対処されなかった場合、システムの一部または全体が崩壊し、重大な結果を引き起こす可能性があります。サーキットブレーカー機構の登場により、この問題は解決されました。

サーキットブレーカーは障害に対処するメカニズムです。サービスが失敗すると、サーキット ブレーカー メカニズムがサービス コールをすぐに切断し、時間枠を設定します。この時間枠内では、サービスに対するリクエストはすべて直接インターセプトされ、エラー メッセージが返されるため、呼び出されたサービスに対する雪崩障害の影響が回避され、サービスが通常に戻るまでシステムは動作を継続できます。

Golang はサーキット ブレーカーを実装します

Golang は、分散システムの開発に適した、効率的で簡潔な学習しやすい言語です。 Go 言語の統合環境には、非常に使いやすいサーキット ブレーカー ライブラリがすでに多数含まれています。

Golangを使ってサーキットブレーカーを実装する方法を紹介します。

サーキット ブレーカー ライブラリをインストールする

Golang では、通常、サーキット ブレーカーのメカニズムはサーキット ブレーカーを使用して実装されます。サーキット ブレーカー メカニズムを使用するには、最初にサーキット ブレーカー ライブラリをインストールする必要があります。より実用的なライブラリには、Netflix の Hystrix や go-kit のサーキット ブレーカー ライブラリなどがあります。

ここでは go-kit のサーキットブレーカーライブラリを例に挙げて説明します。まず、ローカル環境にインストールする必要があります。ターミナルで次のコードを実行します。

go get github.com/go-kit/kit/v2/circuitbreaker

サーキット ブレーカー ライブラリの使用

サーキット ブレーカー ライブラリをインストールした後、サーキット ブレーカーの使用を開始できます。以下では、go-kit のサーキット ブレーカー ライブラリを使用してサーキット ブレーカーを実装する方法について説明します。

ヒューズを定義する

ヒューズを定義するプロセスは非常に簡単で、次のコードを使用するだけです。

breaker := circuitbreaker.NewCircuitBreaker(circuitbreaker.Config{
  Timeout:      2 * time.Second, // 超时时间
  MaxRequests:  1, // 最大请求数
  ReadyToTrip: func(counts circuitbreaker.Counts) bool {
    return counts.ConsecutiveFailures > 3 // 连续3次失败后打开断路器
  },
})

その中で、Timeout は、要求されたタイムアウト; MaxRequests は、期間内のリクエストの最大数を制限します; ReadyToTrip 関数は、サーキット ブレーカーを開く必要があるかどうかを確認するために使用されます。上記のコードでは、リクエストが 3 回以上失敗すると、ReadyToTrip 関数は true を返します。つまり、ヒューズが開きます。

ヒューズの呼び出し

ヒューズを定義した後、サービスの呼び出しを開始できます。サービスを呼び出す場合は、次のように実装できます。

func main() {
  breaker := circuitbreaker.NewCircuitBreaker(circuitbreaker.Config{
    Timeout:      2 * time.Second,
    MaxRequests:  1,
    ReadyToTrip: func(counts circuitbreaker.Counts) bool {
      return counts.ConsecutiveFailures > 3
    },
  })
  
  if err := breaker.Call(func() error {
    // 调用远端服务
    return remoteCall()
  }); err != nil {
    // 熔断后的处理
    fmt.Println("断路器已开启：", err)
  }
}

実際にサービスを呼び出すときは、サービスを breaker.Call() 関数にカプセル化します。呼び出しでエラーが発生した場合、サーキット ブレーカー メカニズムがトリガーされ、フォールト トレランスをコードに実装できます。

概要

この記事では、サーキット ブレーカー メカニズムの基本的な定義と原理を紹介し、Golang を使用してサーキット ブレーカーを実装する方法を詳しく説明します。分散システムの開発において、サーキットブレーカーのメカニズムは非常に重要な機能です。サーキット ブレーカー メカニズムの導入により、システムの高可用性と安定性が確保され、システムのクラッシュを回避する上で重要な役割を果たします。

以上がGolang がサーキットブレーカーを実装の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。