文中介绍了在 golang 框架中处理限流和熔断异常的两种方法：使用中间件：在 http 请求处理链中插入中间件，如 go-rate，以设置限流。使用封装器：包装外部函数，在内部处理限流和熔断，如使用 gobreaker 创建熔断封装器。

优雅处理 Golang 框架中的限流和熔断异常

在高并发系统中，限流和熔断机制至关重要，可以防止应用程序因过载而崩溃。在 Golang 框架中，优雅地处理这些异常至关重要，以保持应用程序的稳定性和响应能力。

使用中间件

立即学习“go语言免费学习笔记（深入）”；

一种常见的方法是使用中间件来处理限流和熔断异常。中间件是在 HTTP 请求处理链中插入的高级函数，可以为请求执行特定的操作。

以下示例展示了使用 [go-rate](https://github.com/juju/ratelimit) 包为 HTTP 请求设置限流中间件：

import (
    "github.com/juju/ratelimit"
    "net/http"
)

func rateLimitHandler(next http.Handler) http.Handler {
    // 创建一个限流。
    limiter := ratelimit.NewBucket(10, 100)

    return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
        if limiter.TakeAvailable(1) == 0 {
            // 已达到限流，返回错误。
            http.Error(w, "Too Many Requests", http.StatusTooManyRequests)
            return
        }

        // 调用下一个处理程序。
        next.ServeHTTP(w, r)
    })
}

使用封装器

另一种方法是使用封装器。封装器包装其他函数，并在其内部处理限流和熔断。

以下示例展示了使用 [github.com/sony/gobreaker](https://github.com/sony/gobreaker) 包为外部函数创建熔断封装器：

import (
    "context"
    "github.com/sony/gobreaker"
    "time"
)

func circuitBreakerWrapper(f func(ctx context.Context) error) func(ctx context.Context) error {
    // 创建一个熔断器。
    cb := gobreaker.NewCircuitBreaker(gobreaker.Settings{})

    return func(ctx context.Context) error {
        // 执行熔断器调用。
        result, err := cb.Execute(ctx, f)
        if err != nil {
            // 熔断已触发，返回错误。
            return fmt.Errorf("Circuit breaker tripped: %w", err)
        }

        return result.(error)
    }
}

实战案例

假设我们有一个 API 路由来处理用户请求：

router.GET("/user/:id", userHandler)

我们可以使用上述中间件或封装器来为该路由添加限流和熔断功能：

// 使用限流中间件
router.GET("/user/:id", rateLimitHandler(userHandler))

// 使用熔断封装器
func userHandlerWithCircuitBreaker(w http.ResponseWriter, r *http.Request) {
    // 熔断器逻辑...
}
router.GET("/user/:id", circuitBreakerWrapper(userHandlerWithCircuitBreaker))

通过这种方法，我们可以优雅地处理 Golang 框架中限流和熔断引发的异常，确保应用程序的稳定性和响应能力。