go-zero高并发架构实战：如何应对流量冲击（一）

时间：2026-08-21 15:30

go-zero 如何扛住流量冲击（一）无论是单体架构还是微服务架构，开发者向前端提供的 API 接口都存在一定的访问上限。一旦请求频率或并发量超出系统承载范围，就必须考虑接口限流策略，以保障接口的可用性，或在必要时实现降级可用。换句话说，API 接口也需要装上一道“保险丝”，避免突发或异常请求对系统

go-zero 如何扛住流量冲击（一）

无论是单体架构还是微服务架构，开发者向前端提供的 API 接口都存在一定的访问上限。一旦请求频率或并发量超出系统承载范围，就必须考虑接口限流策略，以保障接口的可用性，或在必要时实现降级可用。换句话说，API 接口也需要装上一道“保险丝”，避免突发或异常请求对系统造成过大压力，进而引发服务雪崩甚至系统瘫痪。

go-zero如何扛住流量冲击（一）

go-zero 集成了开箱即用的 限流器，非常适合在高并发、分布式服务治理场景中使用。其中内置了两种限流器，也分别对应两类常见的限流场景：

种类原理场景periodlimit单位时间内限制访问次数适用于需要强制限制数据传输速率的场景tokenlimit令牌桶限流适合限制数据平均传输速率，同时允许一定程度的突发流量

本文重点介绍 periodlimit 的实现原理与使用方式。

使用

const (
    seconds = 1
    total   = 100
    quota   = 5
)
// New limiter
l := NewPeriodLimit(seconds, quota, redis.NewRedis(s.Addr(), redis.NodeType), "periodlimit")

// take source
code, err := l.Take("first")
if err != nil {
    logx.Error(err)
    return true
}

// switch val => process request
switch code {
    case limit.OverQuota:
        logx.Errorf("OverQuota key: %v", key)
        return false
    case limit.Allowed:
        logx.Infof("AllowedQuota key: %v", key)
        return true
    case limit.HitQuota:
        logx.Errorf("HitQuota key: %v", key)
        // todo: maybe we need to let users know they hit the quota
        return false
    default:
        logx.Errorf("DefaultQuota key: %v", key)
        // unknown response, we just let the sms go
        return true
}

periodlimit

go-zero 采用 滑动窗口 计数方式，统计一段时间内同一个资源的访问次数。如果访问量超过设定的 limit，系统就会拒绝后续访问。当然，如果你在同一时间段内访问的是不同资源，并且每个资源的访问次数都没有超过 limit，那么这种情况下依然可以允许大量请求进入。

在分布式系统中，通常会有多个微服务实例同时对外提供服务。那么当大量瞬时流量同时访问同一个资源时，如何保证计数器在分布式环境下依然准确？此外，在统计资源访问次数时，往往涉及多步计算，又该如何保证整个计算过程具备原子性？

go-zero 借助 redis 的 incrby 实现资源访问计数
通过 lua script 完成整个窗口计算，从而保证计算过程的原子性

下面来看看这段 lua script 中控制限流逻辑的几个关键属性：

argument含义key[1]被访问资源的标识ARGV[1]limit => 请求总数，超过该值则触发限速，可理解为 QPS 阈值ARGV[2]window 大小 => 滑动时间窗口，通过 ttl 模拟滑动窗口效果

-- to be compatible with aliyun redis,
-- we cannot use `local key = KEYS[1]` to reuse thekey
local limit = tonumber(ARGV[1])
local window = tonumber(ARGV[2])
-- incrbt key 1 => key visis++
local current = redis.call("INCRBY", KEYS[1], 1)
-- 如果是第一次访问，设置过期时间 => TTL = window size
-- 因为是只限制一段时间的访问次数
if current == 1 then
    redis.call("expire", KEYS[1], window)
    return 1
elseif current < limit then
    return 1
elseif current == limit then
    return 2
else
    return 0
end