golang框架限流和熔断在大型互联网业务中的应用案例

package main

import (
    "context"
    "fmt"
    "golang.org/x/time/rate"
    "time"
)

func main() {
    // 创建速率限制器，限制每秒最多 10 个请求
    limiter := rate.NewLimiter(10, 10)

    for {
        ctx := context.Background()
        if err := limiter.Wait(ctx); err != nil {
            // 达到限流，拒绝请求
            fmt.Println("限流了")
            continue
        }

        // 处理请求
        fmt.Println("处理请求")
        time.Sleep(time.Second)
    }
}

package main

import (
    "context"
    "fmt"
    "golang.org/x/sync/errgroup"
    "sync/atomic"
    "time"
)

func main() {
    // 熔断器状态
    var熔断 atomic.Bool

    for {
        // 创建错误组，用于收集请求结果
        g := new(errgroup.Group)

        // 发送 10 个请求
        for i := 0; i < 10; i++ {
            g.Go(func() error {
                // 模拟请求
                time.Sleep(time.Second)
                if random.Intn(10) == 0 {
                    // 随机产生错误
                    returnfmt.Errorf("请求失败")
                }
                return nil
            })
        }

        // 如果错误率超过 50%，则触发熔断
        if errorRate >= 0.5 {
            熔断.Store(true)
            fmt.Println("熔断了")
            continue
        }

        // 如果熔断状态为 true，则拒绝请求
        if 熔断.Load() {
            fmt.Println("熔断中，拒绝请求")
            continue
        }

        // 等待请求结果
        if err := g.Wait(); err != nil {
            // 计算错误率
            errorRate = float64(errgroup.Wrap(err).NumFailures) / float64(g.N())

            // 如果错误率超过 50%，则触发熔断
            if errorRate >= 0.5 {
                熔断.Store(true)
                fmt.Println("熔断了")
            }
        }
    }
}