go-resiliency熔断器

2025-3-14 diaba 分布式

go-resiliency 是一个为 Go 语言编写的库，提供了多种容错模式，包括重试（Retry）、熔断器（Circuit Breaker）、限流（Rate Limiter）等功能。以下是一个简单的使用示例，展示如何使用 go-resiliency 的熔断器功能。

安装 go-resiliency

首先，需要安装 go-resiliency 包： 

go get github.com/sony/gobreaker

示例代码：使用熔断器

以下是一个简单的 Go 程序，展示如何使用 go-resiliency 的熔断器功能来保护对外部服务的调用。 

package main

import (
	"fmt"
	"log"
	"net/http"
	"time"

	"github.com/sony/gobreaker"
)

// 模拟一个可能失败的 HTTP 请求
func unreliableHTTPCall(url string) (string, error) {
	resp, err := http.Get(url)
	if err != nil {
		return "", err
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusOK {
		return "", fmt.Errorf("HTTP request failed with status: %d", resp.StatusCode)
	}

	return "success", nil
}

func main() {
	// 设置熔断器的配置
	settings := gobreaker.Settings{
		Name:        "HTTPCallCircuitBreaker",
		Timeout:     5 * time.Second,       // 超时时间
		ReadyToTrip: gobreaker.DefaultReadyToTrip, // 默认熔断条件
		MaxRequests: 3,                     // 允许的最大失败请求数
		Interval:    5 * time.Second,       // 熔断后恢复的时间间隔
	}

	// 创建熔断器
	circuitBreaker := gobreaker.NewCircuitBreaker(settings)

	// 使用熔断器包装 HTTP 调用
	callWithCircuitBreaker := circuitBreaker.Wrap(func() (string, error) {
		return unreliableHTTPCall("http://example.com")
	})

	// 尝试调用
	for i := 0; i < 10; i++ {
		result, err := callWithCircuitBreaker()
		if err != nil {
			log.Printf("Call failed: %v", err)
		} else {
			log.Printf("Call succeeded: %s", result)
		}
		time.Sleep(1 * time.Second)
	}
}

示例说明

  1. 熔断器配置：

    • MaxRequests：允许的最大失败请求数。当达到这个值时，熔断器会触发。
    • Interval：熔断器触发后，恢复的时间间隔。
    • Timeout：每个请求的超时时间。

  2. 包装函数：

    • 使用 circuitBreaker.Wrap 将原始的 HTTP 调用函数包装起来，这样每次调用都会通过熔断器进行控制。

  3. 调用逻辑：

    • 如果下游服务（http://example.com）响应失败或超时，熔断器会阻止后续调用，直到恢复时间结束。
    • 如果调用成功，熔断器会恢复正常。

输出示例

假设 http://example.com 有时会失败，程序的输出可能如下： 

2025/03/14 12:00:00 Call failed: HTTP request failed with status: 500
2025/03/14 12:00:01 Call failed: HTTP request failed with status: 500
2025/03/14 12:00:02 Call failed: circuit breaker is open
2025/03/14 12:00:03 Call failed: circuit breaker is open
2025/03/14 12:00:04 Call failed: circuit breaker is open
2025/03/14 12:00:05 Call failed: circuit breaker is open
2025/03/14 12:00:06 Call succeeded: success

总结

通过 go-resiliency 的熔断器功能，你可以有效地保护系统免受下游服务故障的影响，同时避免资源耗尽和系统崩溃。

« Sentinel 熔断器介绍及应用 | Redis多种部署架构»

发表评论：

Powered by emlog 京ICP备15045175号-1 Copyright © 2022