Golang限流器实现 令牌桶与漏桶算法

令牌桶允许突发流量,漏桶保证恒定输出;Go中用rate.Limiter实现令牌桶,漏桶需手动实现并注意并发安全。

golang限流器实现 令牌桶与漏桶算法

在高并发系统中,限流是保护服务稳定性的重要手段。Golang中常用的限流算法是令牌桶和漏桶。它们都能控制请求的处理速率,但实现思路不同,适用场景也略有区别。下面分别介绍这两种算法的原理与Go语言实现方式。

令牌桶算法(Token Bucket)

令牌桶的核心思想是:系统以固定速率向桶中添加令牌,每个请求需要先从桶中获取一个令牌才能被处理。如果桶中没有令牌,请求就会被拒绝或等待。

它的特点是允许一定程度的突发流量——只要桶中有足够的令牌,多个请求可以短时间内集中处理。

使用 golang.org/x/time/rate 包可以轻松实现令牌桶:

立即学习“go语言免费学习笔记(深入)”;

rate.Limiter 是基于令牌桶的实现支持突发(burst)配置,即桶的容量可设置每秒生成的令牌数(r)和桶大小(b)

示例代码:

package main

import ("fmt""time""golang.org/x/time/rate")

func main() {// 每秒生成10个令牌,桶最多容纳50个limiter := rate.NewLimiter(10, 50)

for i := 0; i < 100; i++ {    if limiter.Allow() {        fmt.Printf("请求 %d 被允许n", i)    } else {        fmt.Printf("请求 %d 被限流n", i)    }    time.Sleep(50 * time.Millisecond) // 模拟请求间隔}

}

上面代码中,Allow() 非阻塞判断是否放行,也可用 Wait() 阻塞等待令牌。

漏桶算法(Leaky Bucket)

漏桶算法将请求看作水流入桶中,桶以固定速率漏水(处理请求)。如果流入速度超过漏水速度,水就会溢出(请求被拒绝)。

与令牌桶不同,漏桶强调的是恒定的输出速率,即使短时间内涌入大量请求,处理速度也不会变化,因此更平滑但不支持突发。

Go中可以手动实现一个简单的漏桶:

type LeakyBucket struct {    capacity  int       // 桶容量    water     int       // 当前水量(请求数)    rate      int       // 漏水速率(每秒处理数)    lastLeak  time.Time // 上次漏水时间}

func NewLeakyBucket(capacity, rate int) *LeakyBucket {return &LeakyBucket{capacity: capacity,rate: rate,lastLeak: time.Now(),}}

func (lb LeakyBucket) Allow() bool {now := time.Now()// 计算从上次漏水到现在漏了多少水elapsed := now.Sub(lb.lastLeak).Seconds()leakAmount := int(elapsed) lb.rateif leakAmount > 0 {lb.water = max(0, lb.water-leakAmount)lb.lastLeak = now}

// 如果加水后不超过容量,则允许if lb.water < lb.capacity {    lb.water++    return true}return false

}

使用示例:

bucket := NewLeakyBucket(10, 2) // 容量10,每秒处理2个for i := 0; i < 20; i++ {    if bucket.Allow() {        fmt.Printf("请求 %d 放行n", i)    } else {        fmt.Printf("请求 %d 被拒绝n", i)    }    time.Sleep(300 * time.Millisecond)}

令牌桶 vs 漏桶:如何选择?

两者本质都是控制流量,但行为不同:

令牌桶 更灵活,支持突发,适合大多数Web服务限流(如API网关)漏桶 输出更平稳,适合对处理速率要求严格的场景(如音视频流控)实际开发中,令牌桶更常用,因为多数系统希望在资源允许时快速处理突发请求

基本上就这些。Golang标准生态中虽然没有内置限流器,但通过 x/time/rate 能快速实现高效令牌桶限流。漏桶则可根据业务需要自行实现,逻辑清晰且易于控制。选择哪种算法,取决于你更看重突发处理能力还是输出平滑性。不复杂但容易忽略细节,比如时间计算精度和并发安全。如果在多协程环境下使用,记得加锁或使用原子操作保护状态。基本上就这些。

以上就是Golang限流器实现 令牌桶与漏桶算法的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1399594.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月15日 16:20:18
下一篇 2025年12月15日 16:20:43

相关推荐

  • Golang实现云原生消息队列 NATS集成

    首先安装NATS服务器并启动,再通过Go的nats.go库连接:nc, err := nats.Connect(“nats://localhost:4222”);接着使用nc.Publish(“topic”, data)发布消息,nc.Subscrib…

    2025年12月15日
    000
  • Golang实现反向代理服务 通过httputil.ReverseProxy转发请求

    答案:使用Golang的net/http/httputil包可快速实现反向代理。1. 通过url.Parse解析目标地址,httputil.NewSingleHostReverseProxy创建代理,http.ListenAndServe启动服务;2. 自定义Director函数可修改请求头、路径等…

    2025年12月15日
    000
  • Golang基本数据类型有哪些 对比整型浮点型布尔型特点

    Golang数据类型包括整型、浮点型和布尔型,分别用于存储整数、浮点数和布尔值;整型有int8到int64及uint系列,rune和byte为别名;浮点型有float32和float64,后者精度更高;bool类型用于逻辑判断;选择类型时需考虑范围、内存和性能;浮点运算避免精度问题可采用误差范围比较…

    2025年12月15日
    000
  • Golang云原生最佳实践 生产环境经验总结

    采用模块化结构提升可维护性,结合功能或DDD分层;2. 用viper管理配置,环境变量注入敏感信息;3. 使用zap等结构化日志并集成Prometheus与追踪系统;4. 实现健康检查探针与优雅关闭;5. 多阶段Docker构建轻量镜像,CI/CD集成静态检查与安全扫描;6. 规范错误处理与重试熔断…

    2025年12月15日
    000
  • Golang性能监控集成 pprof可视化分析

    pprof通过采样捕获程序运行时的CPU、内存、goroutine等数据,利用火焰图、调用图和列表视图等可视化方式,帮助开发者定位性能瓶颈。 Golang性能监控的核心利器之一就是pprof,它能帮助我们深入洞察程序运行时资源消耗,通过可视化图表快速定位性能瓶颈。集成了pprof,你就能像拥有了一双…

    2025年12月15日
    000
  • Golang表格驱动测试怎么做 高效测试多组输入输出方案

    表格驱动测试通过将测试用例组织为结构体切片,用单个测试函数遍历执行,提升代码可读性与维护性。它适用于多输入场景,如验证正常值、边界值和错误处理,避免重复代码。以Divide函数为例,测试用例包含输入a、b,预期结果want及是否出错hasError。使用t.Run创建子测试,为每个用例生成独立名称,…

    2025年12月15日
    000
  • Golang指针与map配合使用 修改map元素值技巧

    在Go语言中,map的元素不能直接取地址,这是导致指针与map配合使用时容易出错的核心原因。当你想通过指针修改map中的值,尤其是值类型为结构体时,必须格外注意操作方式,否则修改可能不会生效。 map元素不可寻址的问题 Go规定,不能对map中的元素直接取地址,例如下面的代码会编译报错: var m…

    2025年12月15日
    000
  • Golang模板渲染实践 html/template用法详解

    html/template是Go语言中用于安全生成HTML的模块,能自动转义用户输入以防范XSS攻击。其核心流程包括定义模板文件、解析模板、准备数据和执行渲染。与text/template不同,html/template具备上下文感知的自动转义功能,适用于HTML内容生成,而text/templat…

    2025年12月15日
    000
  • Golang并发编程陷阱 常见错误与规避

    多个goroutine并发读写共享变量未同步会引发数据竞争,导致程序行为不可预测,应使用互斥锁或原子操作确保同步访问。 Go语言以简洁高效的并发模型著称,goroutine和channel是其核心。但即便语法简单,开发者在实际使用中仍容易陷入一些常见陷阱。理解这些错误并掌握规避方法,对编写稳定、可维…

    2025年12月15日
    000
  • Mac环境下如何配置Golang开发工具链 使用Homebrew一键安装

    使用Homebrew安装Go并配置GOPATH后,可通过goenv管理多版本,结合VS Code的Go扩展实现高效开发,启用Go Modules进行依赖管理,确保项目构建稳定。 总的来说,在Mac上配置Golang开发环境,最便捷的方式就是使用Homebrew,它能帮你搞定一切依赖,省去手动下载和配…

    2025年12月15日
    000
  • Golang指针传递性能优势 减少大对象拷贝开销

    Go函数参数默认值传递,大对象传参应使用指针以避免内存拷贝开销。1. 值传递复制整个结构体,开销大;2. 指针传递仅传递地址,性能更优;3. 对大结构体或含slice、map的类型优先用指针;4. 小对象值传递更高效,避免过度使用指针。 在 Go 语言中,函数参数传递默认是值传递,也就是说,传递的是…

    2025年12月15日
    000
  • Golang性能监控方案 实时指标收集

    答案:Golang性能监控需结合内置工具、第三方库与自定义逻辑,核心是采集CPU、内存、GC、goroutine等指标。使用net/http/pprof可进行CPU、内存、goroutine分析;通过Prometheus client库暴露指标并集成Grafana可视化;可借助中间件监控请求耗时;设…

    2025年12月15日
    000
  • Golang中间件开发指南 链式处理请求逻辑

    Golang中间件通过将日志、认证等通用功能与业务逻辑解耦,实现请求的链式处理,提升代码复用性、可维护性和灵活性。 Golang中间件的核心作用,在于它提供了一种优雅的方式,将HTTP请求处理流程中的通用功能(比如日志、认证、CORS、错误恢复等)与核心业务逻辑解耦。通过将这些功能封装成独立的、可插…

    2025年12月15日
    000
  • Golang序列化性能对比 protobufvsJSON

    Protobuf在性能和数据体积上优于JSON,因其为二进制协议且避免反射,适用于内部服务通信;JSON因可读性和兼容性,更适合对外API。 在Golang中进行数据序列化时,Protobuf与JSON的性能对比是一个老生常谈的话题,但其核心结论依然明确:在绝大多数需要高性能和数据紧凑性的场景下,P…

    2025年12月15日
    000
  • 使用 Go 语言将命令行输入管道至 Bash 解释器

    本文介绍如何使用 Go 语言将任意命令行输入传递给 Bash 解释器执行,并获取其输出结果。通过 exec.Command 函数调用 Bash,并使用 -c 选项执行传入的命令字符串,可以方便地实现与 Bash 交互的功能,从而扩展 Go 程序的命令行处理能力。本文将提供详细的代码示例和使用说明,帮…

    2025年12月15日
    000
  • Go语言:通过Bash解释器执行任意命令行并捕获输出

    本文详细介绍了如何在Go语言中实现将任意命令行输入转发给Bash解释器执行,并捕获其标准输出。这对于构建自定义shell或解释器,需要处理未内置命令的场景尤为有用。我们将通过exec.Command调用bash -c “command_string”的方式,确保命令以标准终端…

    2025年12月15日
    000
  • 在Go语言中通过Bash执行外部命令并捕获输出的教程

    本教程详细阐述了如何在Go语言中,利用exec包通过bash -c命令安全地执行任意外部命令行并捕获其标准输出。针对传统exec.Command无法直接解析复杂shell语法的局限性,文章提供了构建可执行命令字符串并传递给bash的实用方法,确保命令行为与在终端中执行一致,并讨论了相关注意事项。 1…

    2025年12月15日
    000
  • Go语言中向可变参数函数追加固定参数的优雅实践

    本文探讨了在Go语言中包装可变参数函数时,如何高效且优雅地在参数列表前追加固定参数。针对手动创建切片并循环复制的冗余做法,文章介绍了使用Go内置的append函数作为一种简洁、高效且符合Go语言习惯的解决方案,避免了显式内存分配的复杂性,提升了代码的可读性和维护性。 包装可变参数函数的挑战 在go语…

    2025年12月15日
    000
  • 执行Go程序中的任意Shell命令:Bash解释器的高级应用

    本文详细介绍了如何在Go语言中利用`os/exec`包,通过Bash解释器执行包含复杂语法(如管道、重定向)的任意Shell命令。我们将探讨`bash -c “command_string”`的工作原理,提供一个Go函数实现来捕 以上就是执行Go程序中的任意Shell命令:B…

    2025年12月15日
    000
  • Go语言中变长参数函数前置固定参数的高效处理

    本文旨在解决Go语言中封装变长参数(variadic function)时,如何在原始参数列表前高效且优雅地添加固定参数的问题。通过对比手动创建切片等传统方法,文章详细阐述并推荐使用append函数结合切片字面量(slice literal)的简洁高效方案,此方法不仅提升了代码的可读性,也符合Go语…

    2025年12月15日
    000

发表回复

登录后才能评论
关注微信