限流与熔断是Golang微服务中保障稳定性的核心机制，通过rate.Limiter实现令牌桶限流，结合Redis+Lua支持集群限流；使用sony/gobreaker库基于错误率触发熔断，防止服务雪崩；两者可封装为中间件集成到Gin或gRPC拦截器，并配合监控与日志优化策略。
在Golang微服务架构中，限流与熔断是保障系统稳定性的关键机制。面对突发流量或依赖服务异常，合理设计的限流和熔断策略可以防止服务雪崩，提升整体可用性。下面介绍如何在Go项目中实现这两种机制。
限流机制实现
限流用于控制单位时间内请求的处理数量，避免系统过载。常见的限流算法包括令牌桶、漏桶和计数器法。Golang中可借助golang.org/x/time/rate包快速实现基于令牌桶的限流。
使用rate.Limiter示例：
1. 创建限流器，限制每秒最多处理5个请求，允许突发2次：
立即学习“go语言免费学习笔记（深入）”；
limiter := rate.NewLimiter(5, 2)
2. 在HTTP中间件中调用Allow()判断是否放行：
if !limiter.Allow() {
http.Error(w, "too many requests", http.StatusTooManyRequests)
return
}
该方式适用于单机限流。若需集群级限流，建议结合Redis+Lua脚本实现分布式令牌桶，利用原子操作保证一致性。
熔断机制实现
熔断用于在下游服务持续失败时快速拒绝请求，避免资源耗尽。当错误率超过阈值，熔断器进入“打开”状态，后续请求直接失败；一段时间后进入“半开”状态试探服务是否恢复。
Golang社区常用sony/gobreaker库实现熔断。基本用法如下：
1. 定义熔断器配置：
var cb *gobreaker.CircuitBreaker = gobreaker.NewCircuitBreaker(gobreaker.Settings{
Name: "remote-service",
MaxRequests: 3,
Interval: 10 * time.Second,
Timeout: 30 * time.Second,
ReadyToTrip: func(counts gobreaker.Counts) bool {
return counts.ConsecutiveFailures > 5
}
})
2. 包装远程调用：
result, err := cb.Execute(func() (interface{}, error) {
resp, err := http.Get("http://service-a/api")
if err != nil {
return nil, err
}
defer resp.Body.Close()
return parseResponse(resp)
})
配置说明：Interval统计窗口时间，Timeout熔断持续时间，ReadyToTrip定义触发条件。
集成到微服务框架
在实际项目中，可将限流和熔断封装为独立中间件，注入到HTTP或RPC处理链中。例如在Gin框架中：
func RateLimitMiddleware(limiter *rate.Limiter) gin.HandlerFunc {
return func(c *gin.Context) {
if !limiter.Allow() {
c.AbortWithStatus(429)
return
}
c.Next()
}
}
类似地，熔断逻辑也可作为客户端拦截器，在调用前执行Execute方法。
对于gRPC服务，可通过interceptor机制统一处理。同时建议结合监控（如Prometheus）暴露限流和熔断状态，便于观察系统健康度。
基本上就这些。合理配置参数并结合实际压测调整阈值，才能让限流与熔断真正发挥作用。不复杂但容易忽略的是：日志记录被限流或熔断的请求，有助于后续分析和优化策略。
