golang框架限流和熔断的社区支持与生态系统

package main

import (
    "log"
    "time"

    "golang.org/x/time/rate"
)

func main() {
    // 每秒允许 10 个请求
    limiter := rate.NewLimiter(rate.Every(time.Second), 10)
    for i := 0; i < 20; i++ {
        if !limiter.Allow() {
            log.Println("请求被限流")
        } else {
            log.Println("请求已处理")
        }
    }
}

package main

import (
    "context"
    "fmt"
    "io"
    "net/http"
    "time"

    "github.com/sony/gobreaker"
)

func main() {
    // 创建断路器
    cb := gobreaker.NewCircuitBreaker(gobreaker.Settings{
        Name:         "MyCircuitBreaker",
        Interval:     10 * time.Second,
        Timeout:      5 * time.Second,
        ResetTimeout: 30 * time.Second,
    })

    // 创建带有熔断器保护的 HTTP 客户端
    client := &http.Client{
        Timeout: 10 * time.Second,
        Transport: &gobreaker.Transport{
            CB: cb,
        },
    }

    // 发送请求
    for i := 0; i < 10; i++ {
        resp, err := client.Get("http://example.com")
        if err != nil {
            fmt.Println("请求失败：", err)
            continue
        }
        defer resp.Body.Close()
        io.Copy(io.Discard, resp.Body)
        fmt.Println("请求成功")
    }

    // 输出断路器状态
    fmt.Println("断路器状态：", cb.State())
}