侯体宗的博客
  • 首页
  • Hyperf版
  • beego仿版
  • 人生(杂谈)
  • 技术
  • 关于我
  • 更多分类
    • 文件下载
    • 文字修仙
    • 中国象棋ai
    • 群聊
    • 九宫格抽奖
    • 拼图
    • 消消乐
    • 相册

Redis应用场景限流算法之一,计数器算法代码

Redis  /  管理员 发布于 2年前   965

众所周知,现在常见的限流算法有三种

1.计数器

2.漏桶

3.令牌桶

这仨种。


本文介绍的就是第一种:计数器限流算法的编写与测试

原理:

确定方法的最大访问量MAX,每次进入方法前计数器+1,将结果和最大并发量MAX比较,如果大于等于MAX,则直接返回;
如果小于MAX,则继续执行。


测试环境:

hyperf2.1框架

redis 有序集合


计数器算法编写,这里我专门创建一下控制器用来运行:

<?php
declare(strict_types=1);
namespace App\Controller;
use Hyperf\HttpServer\Contract\RequestInterface;
use Hyperf\HttpServer\Contract\ResponseInterface;
use Hyperf\View\RenderInterface;

use Hyperf\Utils\ApplicationContext;

use Hyperf\HttpServer\Annotation\AutoController;

/**
 * @AutoController()
 */
class TestController
{

    public function index(RenderInterface $render,ResponseInterface $response,RequestInterface $request)
    {
        return $response->json('测试专用控制器');
    }
   
    public function test(RenderInterface $render,ResponseInterface $response)
    {
        //return $response->json('test', ['name' => 'ttttttttHyperf']);
        for ($i=0; $i<10; $i++){
       
            //执行可以发现只有前5次是通过的
            var_dump($this->Calculator("1", "reply", 60, 5));
           
                //这里做个秒限制 太快了会有漏网之鱼
            sleep (1);
        }
        return $response->json('执行完');
    }
   
    /**计数器限流算法
     * @param $uid          客户端id
     * @param $action     动作
     * @param $second       时间秒
     * @param $num       数量
     */
    public function Calculator($uid,$action,$second,$num)
    {
        $redis = ApplicationContext::getContainer()->get(\Hyperf\Redis\Redis::class);
        $key = sprintf('hist:%s:%s', $uid, $action);
       
        //当前的毫秒时间戳
        list($msec, $sec) = explode(' ', microtime());
        $now = (float)sprintf('%.0f', (floatval($msec) + floatval($sec)) * 1000);
       
        //使用管道提升性能
        $pipe = $redis->multi(\Redis::PIPELINE);
       
        //value 和 score 都使用毫秒时间戳
        $pipe->zAdd($key, $now, $now);
       
        //移除时间窗口之前的行为记录,剩下的都是时间窗口内的
        $pipe->zRemRangeByScore($key, '0',(string)($now - $second * 1000));
       
        //获取窗口内的行为数量
        $pipe->zCard($key);
       
        //多加一秒过期时间
        $pipe->expire($key, $second  + 1);
        $replies = $pipe->exec();
       
           //打印出来看看 等下截图用
        print_r($replies);
       
        return $replies[2] <= $num;
    }
}


运行起来测试一下

1.png


上面变量$replies打印出来的值 , 观看起来更直观  

看每个数组后面的布尔值,前面5个是true  后面的为false

这结果就是我们计数器限流算法运行的结果


Array
(
    [0] => 1
    [1] => 0
    [2] => 1
    [3] => 1
)
bool(true)
Array
(
    [0] => 1
    [1] => 0
    [2] => 2
    [3] => 1
)
bool(true)
Array
(
    [0] => 1
    [1] => 0
    [2] => 3
    [3] => 1
)
bool(true)
Array
(
    [0] => 1
    [1] => 0
    [2] => 4
    [3] => 1
)
bool(true)
Array
(
    [0] => 1
    [1] => 0
    [2] => 5
    [3] => 1
)
bool(true)
Array
(
    [0] => 1
    [1] => 0
    [2] => 6
    [3] => 1
)
bool(false)
Array
(
    [0] => 1
    [1] => 0
    [2] => 7
    [3] => 1
)
bool(false)
Array
(
    [0] => 1
    [1] => 0
    [2] => 8
    [3] => 1
)
bool(false)
Array
(
    [0] => 1
    [1] => 0
    [2] => 9
    [3] => 1
)
bool(false)
Array
(
    [0] => 1
    [1] => 0
    [2] => 10
    [3] => 1
)
bool(false)


总结

该算法需要限制一下运行速度,太快会有漏网之鱼,所以上面我用了sleep(1) 确保万无一失

你要根据需求选择该限流计数器算法



后面我会编写后面两种限流算法: 2.漏桶  3.令牌桶  并进行场景测试


完



  • 上一条:
    Hyperf2.1框架定时任务的创建流程步骤
    下一条:
    佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法
  • 昵称:

    邮箱:

    0条评论 (评论内容有缓存机制,请悉知!)
    最新最热
    • 分类目录
    • 人生(杂谈)
    • 技术
    • linux
    • Java
    • php
    • 框架(架构)
    • 前端
    • ThinkPHP
    • 数据库
    • 微信(小程序)
    • Laravel
    • Redis
    • Docker
    • Go
    • swoole
    • Windows
    • Python
    • 苹果(mac/ios)
    • 相关文章
    • 在redis中三种特殊数据类型:地理位置、基数(cardinality)估计、位图(Bitmap)使用场景介绍浅析(0个评论)
    • Redis 删除 key用 del 和 unlink 有啥区别?(0个评论)
    • 用redis中的Zset(有序集合)实现热度排行版及场景示例(0个评论)
    • Redis集群之主从复制错误:NOAUTH Authentication required解决方式(0个评论)
    • redis数据同步工具redis-shake之两服务器之间数据实时同步案例(0个评论)
    • 近期文章
    • 在Nuxt3中如何减少import model声明及初始化加载models快速开发秘诀(0个评论)
    • 适用于 Laravel 的表单请求测试程序包(0个评论)
    • Laravel 10.25版本发布(0个评论)
    • 在go语言中实现生成文件的校验和功能代码示例(0个评论)
    • Laravel 11版本抢先看,看将有什么新功能发布(0个评论)
    • goose数据库迁移工具介绍及使用流程步骤(0个评论)
    • 中国程序员“翻墙”为海外软件公司打工,105.8万工资被罚没!转知乎(0个评论)
    • 在go语言gin框架中使用Sharding(Gorm分表中间件)实现分表流程步骤(0个评论)
    • 在PHP提高性能方式之开启OPCache扩展及OPCache配置参数详解(0个评论)
    • 在js的websocket客户端开发中遇到代码割裂情况解决方案(0个评论)
    • 近期评论
    • 路人 在

      php中使用hyperf框架调用讯飞星火大模型实现国内版chatgpt功能示例中评论 教程很详细,如果加个前端chatgpt对话页面就完美了..
    • 博主 在

      科学上网翻墙之v2rayN-Core客户端免费公益节点使用教程中评论 @ mashrdn 多切换几个节点测试,免费ssr是没那么稳..
    • mashrdn 在

      科学上网翻墙之v2rayN-Core客户端免费公益节点使用教程中评论 V2rayn免费节点添加上去了,youtobe无法打开网页,是怎么回事..
    • 张伟 在

      科学上网翻墙之v2rayN-Core客户端免费公益节点使用教程中评论 3q!有用,不过免费节点隔天就要去git上复制新的导进去..
    • 博主 在

      科学上网翻墙访问Google , 上外网神器佛跳墙VPN(永久免费)使用流程步骤中评论 该篇教程已不能用了,告知大家,免的老有老铁问我!..
    • 2017-12
    • 2020-03
    • 2020-05
    • 2021-04
    • 2022-03
    • 2022-05
    • 2022-08
    • 2023-02
    • 2023-04
    • 2023-07
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客