微服务过载保护原理与实战

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1439 天前的主题，其中的信息可能已经有所发展或是发生改变。

在微服务中由于服务间相互依赖很容易出现连锁故障，连锁故障可能是由于整个服务链路中的某一个服务出现故障，进而导致系统的其他部分也出现故障。例如某个服务的某个实例由于过载出现故障，导致其他实例负载升高，从而导致这些实例像多米诺骨牌一样一个个全部出现故障，这种连锁故障就是所谓的雪崩现象

比如，服务 A 依赖服务 C，服务 C 依赖服务 D，服务 D 依赖服务 E，当服务 E 过载会导致响应时间变慢甚至服务不可用，这个时候调用方 D 会出现大量超时连接资源被大量占用得不到释放，进而资源被耗尽导致服务 D 也过载，从而导致服务 C 过载以及整个系统雪崩

某一种资源的耗尽可以导致高延迟、高错误率或者相应数据不符合预期的情况发生，这些的确是在资源耗尽时应该出现的情况，在负载不断上升直到过载时，服务器不可能一直保持完全的正常。而 CPU 资源的不足导致的负载上升是我们工作中最常见的，如果 CPU 资源不足以应对请求负载，一般来说所有的请求都会变慢，CPU 负载过高会造成一系列的副作用，主要包括以下几项：

正在处理的(in-flight) 的请求数量上升
服务器逐渐将请求队列填满，意味着延迟上升，同时队列会用更多的内存
线程卡住，无法处理请求
cpu 死锁或者请求卡主
rpc 服务调用超时
cpu 的缓存效率下降

由此可见防止服务器过载的重要性不言而喻，而防止服务器过载又分为下面几种常见的策略：

提供降级结果
在过载情况下主动拒绝请求
调用方主动拒绝请求
提前进行压测以及合理的容量规划

今天我们主要讨论的是第二种防止服务器过载的方案，即在过载的情况下主动拒绝请求，下面我统一使用”过载保护“来表述，过载保护的大致原理是当探测到服务器已经处于过载时则主动拒绝请求不进行处理，一般做法是快速返回 error

很多微服务框架中都内置了过载保护能力，本文主要分析go-zero中的过载保护功能，我们先通过一个例子来感受下 go-zero 的中的过载保护是怎么工作的

首先，我们使用官方推荐的goctl生成一个 api 服务和一个 rpc 服务，生成服务的过程比较简单，在此就不做介绍，可以参考官方文档，我的环境是两台服务器，api 服务跑在本机，rpc 服务跑在远程服务器

远程服务器为单核 CPU，首先通过压力工具模拟服务器负载升高，把 CPU 打满

stress -c 1 -t 1000

此时通过 uptime 工具查看服务器负载情况，-d 参数可以高亮负载的变化情况，此时的负载已经大于 CPU 核数，说明服务器正处于过载状态

watch -d uptime

19:47:45 up 5 days, 21:55,  3 users,  load average: 1.26, 1.31, 1.44

此时请求 api 服务，其中 ap 服务内部依赖 rpc 服务，查看 rpc 服务的日志，级别为 stat，可以看到 cpu 是比较高的

"level":"stat","content":"(rpc) shedding_stat [1m], cpu: 986, total: 4, pass: 2, drop: 2"

并且会打印过载保护丢弃请求的日志，可以看到过载保护已经生效，主动丢去了请求

adaptiveshedder.go:185 dropreq, cpu: 990, maxPass: 87, minRt: 1.00, hot: true, flying: 2, avgFlying: 2.07

这个时候调用方会收到 "service overloaded" 的报错

通过上面的试验我们可以看到当服务器负载过高就会触发过载保护，从而避免连锁故障导致雪崩，接下来我们从源码来分析下过载保护的原理，go-zero 在 http 和 rpc 框架中都内置了过载保护功能，代码路径分别在 go-zero/rest/handler/sheddinghandler.go 和 go-zero/zrpc/internal/serverinterceptors/sheddinginterceptor.go 下面，我们就以 rpc 下面的过载保护进行分析，在 server 启动的时候回 new 一个 shedder 代码路径: go-zero/zrpc/server.go:119，然后当收到每个请求都会通过 Allow 方法判断是否需要进行过载保护，如果 err 不等于 nil 说明需要过载保护则直接返回 error

promise, err = shedder.Allow()
if err != nil {
  metrics.AddDrop()
  sheddingStat.IncrementDrop()
  return
}

实现过载保护的代码路径为: go-zero/core/load/adaptiveshedder.go ，这里实现的过载保护基于滑动窗口可以防止毛刺，有冷却时间防止抖动，当 CPU>90%的时候开始拒绝请求，Allow 的实现如下

func (as *adaptiveShedder) Allow() (Promise, error) {
	if as.shouldDrop() {
		as.dropTime.Set(timex.Now())
		as.droppedRecently.Set(true)

		return nil, ErrServiceOverloaded  // 返回过载错误
	}

	as.addFlying(1) // flying +1

	return &promise{
		start:   timex.Now(),
		shedder: as,
	}, nil
}

sholdDrop 实现如下，该函数用来检测是否符合触发过载保护条件，如果符合的话会记录 error 日志

func (as *adaptiveShedder) shouldDrop() bool {
	if as.systemOverloaded() || as.stillHot() {
		if as.highThru() {
			flying := atomic.LoadInt64(&as.flying)
			as.avgFlyingLock.Lock()
			avgFlying := as.avgFlying
			as.avgFlyingLock.Unlock()
			msg := fmt.Sprintf(
				"dropreq, cpu: %d, maxPass: %d, minRt: %.2f, hot: %t, flying: %d, avgFlying: %.2f",
				stat.CpuUsage(), as.maxPass(), as.minRt(), as.stillHot(), flying, avgFlying)
			logx.Error(msg)
			stat.Report(msg)
			return true
		}
	}

	return false
}

判断 CPU 是否达到预设值，默认 90%

systemOverloadChecker = func(cpuThreshold int64) bool {
	return stat.CpuUsage() >= cpuThreshold
}

CPU 的负载统计代码如下，每隔 250ms 会进行一次统计，每一分钟没记录一次统计日志

func init() {
	go func() {
		cpuTicker := time.NewTicker(cpuRefreshInterval)
		defer cpuTicker.Stop()
		allTicker := time.NewTicker(allRefreshInterval)
		defer allTicker.Stop()

		for {
			select {
			case <-cpuTicker.C:
				threading.RunSafe(func() {
					curUsage := internal.RefreshCpu()
					prevUsage := atomic.LoadInt64(&cpuUsage)
					// cpu = cpuᵗ⁻¹ * beta + cpuᵗ * (1 - beta)
					usage := int64(float64(prevUsage)*beta + float64(curUsage)*(1-beta))
					atomic.StoreInt64(&cpuUsage, usage)
				})
			case <-allTicker.C:
				printUsage()
			}
		}
	}()
}

其中 CPU 统计实现的代码路径为: go-zero/core/stat/internal，在该路径下使用 linux 结尾的文件，因为在 go 语言中会根据不同的系统编译不同的文件，当为 linux 系统时会编译以 linux 为后缀的文件

func init() {
	cpus, err := perCpuUsage()
	if err != nil {
		logx.Error(err)
		return
	}

	cores = uint64(len(cpus))
	sets, err := cpuSets()
	if err != nil {
		logx.Error(err)
		return
	}

	quota = float64(len(sets))
	cq, err := cpuQuota()
	if err == nil {
		if cq != -1 {
			period, err := cpuPeriod()
			if err != nil {
				logx.Error(err)
				return
			}

			limit := float64(cq) / float64(period)
			if limit < quota {
				quota = limit
			}
		}
	}

	preSystem, err = systemCpuUsage()
	if err != nil {
		logx.Error(err)
		return
	}

	preTotal, err = totalCpuUsage()
	if err != nil {
		logx.Error(err)
		return
	}
}

在 linux 中，通过 /proc 虚拟文件系统向用户控件提供了系统内部状态的信息，而 /proc/stat 提供的就是系统的 CPU 等的任务统计信息，这里主要原理就是通过 /proc/stat 来计算 CPU 的使用率

本文主要介绍了过载保护的原理，以及通过实验触发了过载保护，最后分析了实现过载保护功能的代码，相信通过本文大家对过载保护会有进一步的认识，过载保护不是万金油，对服务来说是有损的，所以在服务上线前我们最好是进行压测做好资源规划，尽量避免服务过载

写作不易，如果觉得文章不错，欢迎 github star 🤝

项目地址：https://github.com/tal-tech/go-zero

过载

err

CPU

error

15 条回复 • 2020-12-24 12:44:08 +08:00