go 用 Redis 来做限流

Go语言可以使用第三方库`go-redis`来操作Redis，以下是一个使用Go语言实现的基于Redis的令牌桶算法的示例：

package main

import (
    "fmt"
    "time"

    "github.com/go-redis/redis/v8"
)

// 令牌桶大小
const BUCKET_SIZE = 100

// 令牌添加速率
const RATE = 10

func main() {
    // 创建Redis客户端
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "",
        DB:       0,
    })

    // 初始化令牌桶
    rdb.Del(ctx, "token_bucket")
    for i := 0; i < BUCKET_SIZE; i++ {
        rdb.ZAdd(ctx, "token_bucket", &redis.Z{Score: 0, Member: fmt.Sprintf("%d", i)})
    }

    // 模拟请求
    for i := 0; i < 150; i++ {
        if get_token(rdb) {
            fmt.Println("Request accepted")
        } else {
            fmt.Println("Request rejected")
        }

        // 等待一段时间，以保证限流速率
        time.Sleep(time.Duration(float64(time.Second) / RATE))
    }
}

func get_token(rdb *redis.Client) bool {
    // 获取当前时间戳
    timestamp := time.Now().Unix()

    // 移除过期的令牌
    rdb.ZRemRangeByScore(ctx, "token_bucket", &redis.ZRangeBy{Min: "0", Max: fmt.Sprintf("%d", timestamp - 1)})

    // 获取当前令牌桶中的令牌数量
    tokens, err := rdb.ZCard(ctx, "token_bucket").Result()
    if err != nil {
        panic(err)
    }

    // 如果令牌桶已空，拒绝请求
    if tokens == 0 {
        return false
    }

    // 移除一个令牌，并允许请求通过
    rdb.ZPopMin(ctx, "token_bucket")

    // 返回允许请求通过
    return true
}

以上示例代码中，我们使用了第三方库`go-redis`来操作Redis，创建了一个Redis客户端，并使用有序集合来存储令牌桶，其中每个元素表示一个令牌，元素的分值表示令牌的到期时间。在每个请求到达时，我们通过Redis操作来检查令牌桶中是否有可用的令牌，并在必要时添加新的令牌。