golang如何限流？算法详解

PHPz

发布时间：2023-04-11 10:39:40

1676人浏览过

来源于php中文网

原创

随着互联网技术的不断发展，高并发和大流量的需求越来越普遍，这也就使得限流技术的重要性越来越被重视。而对于golang作为一门快速高效的语言，自然也不能忽视其在限流方面的应用。那么，具体来看golang如何限流吧。

1. 漏斗算法

漏斗算法是一种比较常用的限流算法，其核心思想就是维护一个固定容量的漏斗，然后以一定的速率往漏斗里面加水，如果漏斗达到了最高容量，则后面的水就会溢出，而对于进入漏斗的请求，则需要消耗漏斗中的水，如果漏斗中的水不足，则说明此时不能处理该请求。

在golang中，可以使用"rate"包实现漏斗算法进行限流，例如下面的代码：

import (
     "golang.org/x/time/rate"
     "net/http"
)

// 创建一个每秒钟只允许1个请求的漏斗
r := rate.NewLimiter(1, 1)
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
     if r.Method != "GET" {
          http.Error(w, "Method Not Allowed", http.StatusMethodNotAllowed)
          return
     }
     if !r.Limiter.CanAllow() {
          http.Error(w, "Too Many Requests", http.StatusTooManyRequests)
          return
     }
     // 处理业务逻辑
})

2. 令牌桶算法

令牌桶算法也是一种常见的限流算法，其核心思想就是维护一个固定容量的桶，并以一定的速率不断往桶里面放入令牌，而对于进入桶中的请求，则需要消耗桶中的令牌，如果桶中的令牌不足，则说明此时不能处理该请求。

在golang中，可以使用"golang.org/x/time/rate"包实现令牌桶算法进行限流，例如下面的代码：

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

Python精要参考 pdf版

这本书给出了一份关于python这门优美语言的精要的参考。作者通过一个完整而清晰的入门指引将你带入python的乐园，随后在语法、类型和对象、运算符与表达式、控制流函数与函数编程、类及面向对象编程、模块和包、输入输出、执行环境等多方面给出了详尽的讲解。如果你想加入 python的世界，David M beazley的这本书可不要错过哦。 (封面是最新英文版的,中文版貌似只译到第二版)

下载

import (
     "golang.org/x/time/rate"
     "net/http"
)

// 创建一个每秒钟只允许1个请求的令牌桶
r := rate.NewLimiter(1, 1)
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
     if r.Method != "GET" {
          http.Error(w, "Method Not Allowed", http.StatusMethodNotAllowed)
          return
     }
     if !r.Wait(r.Context()) {
          http.Error(w, "Too Many Requests", http.StatusTooManyRequests)
          return
     }
     // 处理业务逻辑
})

3. 滑动窗口算法

滑动窗口算法也是一种常用的限流算法，其核心思想就是将每秒钟的时间划分为多个固定大小的时间段，在每个时间段内，维护一个固定大小的计数器，每当进入一个请求，则对对应时间段的计数器加一，而对于进入计数器数量达到上限的请求，则不能处理该请求。

在golang中，可以使用"github.com/uber-go/ratelimit"包实现滑动窗口算法进行限流，例如下面的代码：

import (
     "github.com/uber-go/ratelimit"
     "net/http"
)

// 创建一个每秒最多只允许1个请求的滑动窗口
rl := ratelimit.New(10) // 表示在一个时间段内最多允许处理10个请求
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
     if r.Method != "GET" {
          http.Error(w, "Method Not Allowed", http.StatusMethodNotAllowed)
          return
     }
     if !rl.TakeAvailable(1) { // 表示当前请求需要消耗1个计数
          http.Error(w, "Too Many Requests", http.StatusTooManyRequests)
          return
     }
     // 处理业务逻辑
})