0

0

Go语言中使用Ticker实现并发请求限流的正确方法

霞舞

霞舞

发布时间:2026-01-17 15:42:13

|

501人浏览过

|

来源于php中文网

原创

Go语言中使用Ticker实现并发请求限流的正确方法

本文介绍如何用time.ticker替代手动时间检查,在多goroutine场景下稳定实现api调用限流(如20次/10秒),避免竞态与时间漂移问题。

Mike 遇到的问题非常典型:在结构体中通过 LastCallTime 手动维护调用时间戳并循环 Sleep,看似合理,但在并发环境下存在严重缺陷——多个 goroutine 同时读写 c.LastCallTime 未加锁,导致竞态(race condition);且 time.Sleep() 的唤醒时机不精确、无法阻塞“抢占式”调用,造成实际调用间隔远小于预期(例如本应 ≥500ms,却出现连续毫秒级爆发)。

更优雅、更可靠的方案是使用 Go 标准库的 time.Ticker,它以恒定周期发送时间信号,天然适合节流(throttling)场景。关键在于:所有 goroutine 共享同一个 ticker,并在发起请求前同步接收一个 tick 信号——这相当于将并发请求“排队”到一个逻辑上的时间槽中。

以下是一个生产就绪的示例:

package main

import (
    "fmt"
    "net/http"
    "sync"
    "time"
)

// Throttler 封装限流逻辑,支持并发安全调用
type Throttler struct {
    ticker *time.Ticker
    // 可选:添加 context 支持取消,或熔断机制
}

func NewThrottler(interval time.Duration) *Throttler {
    return &Throttler{
        ticker: time.NewTicker(interval),
    }
}

func (t *Throttler) Wait() {
    <-t.ticker.C // 阻塞直到下一个时间槽到达
}

func (t *Throttler) Close() {
    t.ticker.Stop()
}

func main() {
    // 20次/10秒 → 平均间隔 500ms(注意:这是*最小平均间隔*,非硬性窗口)
    throttler := NewThrottler(500 * time.Millisecond)
    defer throttler.Close()

    var wg sync.WaitGroup
    for i := 0; i < 30; i++ {
        wg.Add(1)
        go func(id int) {
            defer wg.Done()
            throttler.Wait() // ✅ 所有 goroutine 统一在此同步
            // 此处发起真实 API 请求(如 http.Get)
            fmt.Printf("Request %d sent at %s\n", id, time.Now().Format("15:04:05.000"))
        }(i)
    }
    wg.Wait()
}

⚠️ 注意事项:

医真AI+开放平台
医真AI+开放平台

医真AI+ 医学AI开放平台

下载

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

  • time.Tick() 简洁但不可关闭,推荐使用 time.NewTicker() 配合 defer ticker.Stop(),避免资源泄漏;
  • 上述方案实现的是平滑速率限制(smooth rate limiting),即请求均匀分布(≈500ms间隔)。若需严格遵守「每10秒最多20次」的滚动窗口(rolling window),应改用令牌桶(token bucket)或漏桶(leaky bucket)算法,例如借助 golang.org/x/time/rate 包;
  • 若 API 调用本身耗时较长(如 >500ms),Wait() 应放在请求之前(如上例),确保两次请求发起时间间隔 ≥ 间隔;若放在响应后,则可能退化为串行。

总结:用 time.Ticker 替代手动时间管理,不仅代码更简洁、线程安全,而且语义清晰——它把“等待”转化为对时间事件的同步等待,从根本上规避了竞态与精度偏差,是 Go 并发限流的最佳实践之一。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

178

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

226

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

338

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

209

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

391

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

196

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

191

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

192

2025.06.17

高德地图升级方法汇总
高德地图升级方法汇总

本专题整合了高德地图升级相关教程,阅读专题下面的文章了解更多详细内容。

27

2026.01.16

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 3.8万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号