Go语言中的熔断器实现

go get github.com/sony/gobreaker

package main

import (
    "errors"
    "fmt"
    "github.com/sony/gobreaker"
    "math/rand"
    "time"
)

func main() {
    // 配置熔断器
    settings := gobreaker.Settings{
        Name:        "MyCircuitBreaker",
        MaxRequests: 5, // 半开状态下允许的最大请求数
        Interval:    time.Duration(60) * time.Second, // 熔断器在打开状态下重置计数器的时间间隔
        Timeout:     time.Duration(10) * time.Second, // 熔断器从打开状态到半开状态的超时时间
        ReadyToTrip: func(counts gobreaker.Counts) bool {
            // 当连续失败的请求数超过3个时，触发熔断
            return counts.ConsecutiveFailures > 3
        },
    }

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

    // 模拟请求
    for i := 0; i < 20; i++ {
        result, err := breaker.Execute(func() (interface{}, error) {
            if rand.Float32() < 0.5 {
                return nil, errors.New("request failed")
            }
            return "request succeeded", nil
        })

        if err != nil {
            fmt.Printf("Request %d: failed, error: %v\n", i+1, err)
        } else {
            fmt.Printf("Request %d: succeeded, result: %v\n", i+1, result)
        }

        // 随机延时，模拟真实请求的间隔时间
        time.Sleep(time.Duration(rand.Intn(500)) * time.Millisecond)
    }
}