限流策略实战指南:从算法选择到阈值设置,打造高可用系统

embedded/2025/2/9 4:05:55/

前言

本文将深入探讨常见的限流算法及其适用场景,并详细解析基于 QPS 的限流方案。从如何设置合理的限流阈值,到请求被限流后的处理策略。

常见的限流算法

漏桶

  • 核心原理
    请求以任意速率进桶,以 恒定速率 出桶。若桶满则丢弃或排队等待
  • 适用场景
    需要 严格平滑流量 的场景,如支付系统、金融交易
  • 优点
    实现简单,适合流量整形。输出的流量绝对平滑
  • 缺点
    无法应对突发流量
  • 工具支持
    Sentinel 限流行为 RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER,使用示例详见 PaceFlowDemo

令牌桶

  • 核心原理
    以固定速率向桶中添加令牌,请求前需要获取令牌。若桶中存在令牌则处理,否则限流
  • 适用场景
    允许突发流量,但服务不会被流量压垮。如秒杀场景
  • 优点
    能处理突发流量,用户体验相对漏桶好
  • 缺点
    突发流量可能会导致瞬时资源占用过高
    相比于漏桶实现更复杂
  • 工具支持
    Google Guava 的 RateLimiter
    Sentinel 限流行为 RuleConstant.CONTROL_BEHAVIOR_WARM_UP,使用示例详见 WarmUpFlowDemo

固定窗口

  • 核心原理
    将时间划分为固定长度的窗口(如1分钟),统计窗口内的请求数。若请求数超过阈值,则后续时间窗口内的请求均会被拒绝
  • 适用场景
    限流精度要求不高的简单场景
  • 优点
    实现简单,内存占用低
  • 缺点
    临界值问题:在窗口切换时,可能存在2倍流量(如1:59 和 2:00 的请求可能分属2个窗口)

滑动窗口

  • 核心原理
    将时间划分为更细粒度的子窗口,统计当前时间点向前滑动的时间窗口内总请求数
  • 适用场景
    高精准的限流。如 API 接口
  • 优点
    精准限流
    可动态调整窗口大小,适应流量波形
  • 缺点
    实现复杂;内存和计算成本较高
  • 工具支持
    详见 Sentinel LeapArray 实现

基于 QPS 限流

基于 QPS 限流是业内最常用的限流方案,常应用于接口限流限流的关键在于回答2个问题。

  1. 限流阈值如何设置?
  2. 限流后如何处理?

下面将对这 2 个问题进行深入探讨

限流阈值如何设置

阈值的设置一般有以下4种方式:压测、服务性能数据、借鉴已有功能、手动计算预估接口响应时间。

服务性能数据

需要服务接入可观测,例如 Promethues。根据业务高峰期的QPS,以及服务其他性能数据,例如 CPU、内存等,冗余 20% ~ 30% 的量。
不过业务高峰期的 QPS 是一个动态值,会随着业务发展的变化而变化。当变化较大时,需要及时调整阈值。

全链路压测

这里的压测指的是全链路压测,而非针对单接口的压测。
基于全链路压测,得到的接口 QPS 阈值会更加准确。
不管是全链路压测、还是单接口压测随着 QPS 不断增加我们都能得到以下 3 个值

在这里插入图片描述

A点: 性能最好,响应时间最快
B点: 吞吐量最高
C点: 并发最高,资源利用率最高,但是系统处于崩溃临界点

一般而言,我们会在 [B,C] 之间选择一个阈值,作为限流阈值。

借鉴

如果该接口无法做压测,或者需求急时间紧,那么可以考虑借鉴类似相关已有接口的限流阈值。
例如 A 接口的调用场景与 B 接口一致,那么就可以用 B 接口的限流阈值来确定 A 接口的限流阈值。

手动计算

如果是一个全新的业务那怎么办?
这个时候可以考虑手动计算。
例如,一个查询接口,只会查询数据库,且数据库查询平均响应时间为 10ms,再增加 10ms 作为 CPU 计算时间,且实例的 CPU 为 4核,那么该接口的 QPS 可以简单计算为: 1000ms / 20ms * 4 = 200

限流后的处理策略

服务端角度

  1. 直接拒绝
    例如,返回限流特定状态码
  2. 排队等待
    例如,允许等待 20ms,如果 20ms 内未能被处理,则返回限流特定状态码。如 Sentinel 的限流行为 RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER
  3. 冷启动
    让通过的流量缓慢增加,在一定时间内逐渐增加到阈值上限,给冷系统一个预热的时间。如 Sentinel 的限流行为 RuleConstant.CONTROL_BEHAVIOR_WARM_UP
  4. 同步转异步
    可以同步转异步的场景并不多。常见于数据上报类型的接口,客户端不关注服务端的返回。

客户端角度
客户端要根据服务端返回的特定状态码提示用户,提升用户体验。


http://www.ppmy.cn/embedded/160707.html

相关文章

【3分钟极速部署】在本地快速部署deepseek

第一步,找到网站,下载: 首先找到Ollama , 根据自己的电脑下载对应的版本 。 我个人用的是Windows 我就先尝试用Windows版本了 ,文件不是很大,下载也比较的快 第二部就是安装了 : 安装完成后提示…

将Deepseek接入pycharm 进行AI编程

目录 专栏导读1、进入Deepseek开放平台创建 API key 2、调用 API代码 3、成功4、补充说明多轮对话 总结 专栏导读 🌸 欢迎来到Python办公自动化专栏—Python处理办公问题,解放您的双手 🏳️‍🌈 博客主页:请点击——…

RabbitMQ的安装

1、官网地址 下载地址:Installing RabbitMQ | RabbitMQhttp://www.rabbitmq.com/download.htmlhttp://www.rabbitmq.com/download.html RabbitMQ Documentation | RabbitMQhttps://www.rabbitmq.com/docshttps://www.rabbitmq.com/docs 2、Windows上安装 2.1 安装…

《机器学习数学基础》补充资料:矩阵基本子空间

秩-零化度定理是线性代数中第一个基本定理,本文介绍的“矩阵基本子空间”,是第二定理。 定理2:矩阵基本子空间 对于 m n m\times n mn 的矩阵 A \pmb{A} A (仅讨论实数矩阵),用线性变换表示 A : R n …

【搜索文章】:搜索(es)+ 搜索记录(mongodb)+ 搜索联想词

需求 用户输入关键字时,可以检索出结果, 并且可以查看历史搜索情况, 还可以进行联想词展示。 ElasticSearch(搜索) 准备工作 使用docker安装es,配置ik分词器重新建一个search模块,用来写搜…

利用deepseek参与软件测试 基本架构如何 又该在什么环节接入deepseek

利用DeepSeek参与软件测试,可以考虑以下基本架构和接入环节: ### 基本架构 - **数据层** - **测试数据存储**:用于存放各种测试数据,包括正常输入数据、边界值数据、异常数据等,这些数据可以作为DeepSeek的输入&…

DeepSeek-R1:开源机器人智能控制系统的革命性突破

目录 引言 一、DeepSeek-R1 的概述 1.1 什么是 DeepSeek-R1? 1.2 DeepSeek-R1 的定位 二、DeepSeek-R1 的核心特性 2.1 实时控制能力 2.2 多传感器融合 2.3 路径规划与导航 2.4 人工智能集成 2.5 开源与模块化设计 2.6 跨平台支持 三、DeepSeek-R1 的技术…

Java并发编程笔记

Java并发基础知识补全 启动 启动线程的方式只有: 1、X extends Thread;,然后X.start 2、X implements Runnable;然后交给Thread运行 线程的状态 Java中线程的状态分为6种: 1. 初始(NEW):新创建了一个线程对象&…