golang框架如何利用限流和熔断实现微服务保护？

// 使用漏桶算法限制请求
package main

import (
    "context"
    "fmt"
    "time"

    leakybucket "github.com/juju/ratelimit"
    "google.golang.org/grpc"
)

const (
    bucketSize = 10 // 允许的最大并发请求数
    fillRate   = 5   // 每秒添加令牌的速率
)

func main() {
    // 创建漏桶限流器
    bucket := leakybucket.NewBucketWithRate(bucketSize, fillRate)

    // 定义 gRPC 服务端
    grpcServer := grpc.NewServer()
    RegisterMyServiceServer(grpcServer, &myServer{bucket: bucket})

    // 启动 gRPC 服务
    go func() {
        fmt.Println("gRPC 服务已启动")
        if err := grpcServer.Serve(lis); err != nil {
            log.Fatalf("gRPC 服务启动失败: %v", err)
        }
    }()

    // 持续从漏桶中提取令牌
    for {
        select {
        case <-bucket.Wait(context.Background()):
            fmt.Println("已成功获取令牌")
            // 允许处理一个请求
        default:
            fmt.Println("超过并发请求限制")
            // 拒绝处理请求
        }
    }
}

// 使用熔断器保护微服务
package main

import (
    "context"
    "fmt"
    "sync"
    "time"

    "github.com/sony/gobreaker"
)

// 定义熔断器配置
const (
    maxRequests = 5           // 在熔断发生之前的最大连续失败请求数
    interval    = 5 * time.Second // 熔断器状态保持打开的时间间隔
)

// 初始化熔断器
var cb = gobreaker.NewCircuitBreaker(gobreaker.Settings{
    Name:        "myService",
    MaxRequests: maxRequests,
    Interval:    interval,
})

func main() {
    // 获取熔断器当前状态
    state := cb.State()
    fmt.Printf("熔断器当前状态: %s\n", state)

    // 执行受熔断器保护的代码
    cb.Execute(context.Background(), func() (interface{}, error) {
        // 尝试调用外部系统
        result, err := callExternalSystem()
        if err != nil {
            cb.MarkFailure(err) // 记录调用失败
            return nil, err
        }
        cb.MarkSuccess() // 记录调用成功
        return result, nil
    })

    // 获取熔断器更新后的状态
    state = cb.State()
    fmt.Printf("熔断器更新后的状态: %s\n", state)
}