龙行博客

走路看风景,经历看人生,岁月留痕迹,人生留轨迹,17的历史,18的豪情,时间的匆忙,人生的风景,放开心胸往前走,成功再远行,放开理想往前走,梦想再行动。
现在位置:首页 > 编程语言 > PHP > Hyperf漏斗计数器限流

Hyperf漏斗计数器限流

龙行    PHP    2022-11-10    156    0评论    

Hyperf漏斗计数器限流

此项目移植于laravel Cache组件 的rete-limiter

对于\Psr\SimpleCache\CacheInterface有了补充,增加方法

  • increment

  • decrement

  • add

  • put

安装

composer require wilbur-yu/hyperf-cache-ext

配置

修改配置文件cache.php

'default' => [
   'driver' => WilburYu\HyperfCacheExt\Driver\RedisDriver::class,
   'packer' => WilburYu\HyperfCacheExt\Utils\Packer\PhpSerializerPacker::class,
   'prefix' => env('APP_NAME', 'skeleton').':cache:',
],
'limiter' => [
   'prefix' => 'rate-limit:',    // key前缀
   'max_attempts' => 20,         // 最大允许数
   'decay_minutes' => 60,        // 限流单位时间
   'wait' => 250,                // 并发时, 获取锁最大等待毫秒数
   'timeout' => 1,               // 并发时, 获取锁超时秒数
   'for' => [
       'common' => static function (\Hyperf\HttpServer\Contract\RequestInterface $request) {
           return Limit::perMinute(3);
       },
   ],
   'key' => ThrottleRequest::key(),
],
  • for 即对应 Laravel Facade RateLimiter::for(callable),

在服务启动时,监听器会收集该命名限制器数组,供在注解中使用 for 参数引用。在注解切面执行时,会将当前请求 \Hyperf\HttpServer\Contract\RequestInterface

实例注入到该命名闭包.

2 .可捕获异常

适用于计数器限流

WilburYu\HyperfCacheExt\Exception\CounterRateLimiterException::class

该异常自带一个 getHeaders 方法,值为: array (‘X-RateLimit-Limit’, ‘X-RateLimit-Remaining’, ‘Retry-After’,
X-RateLimit-Reset’)

使用

在控制器中使用

  • 计数器限流详解

#[CounterRateLimiterWithRedis(maxAttempts: 5, decayMinutes: 1)]
or
#[CounterRateLimiter(for: "common")]
  • 漏斗限流详解

use WilburYu\HyperfCacheExt\Annotation\ConcurrencyRateLimiter;
// 1秒内最高支持并发请求5次
#[ConcurrencyRateLimiter(key: 'get.posts', maxAttempts: 5, decayMinutes: 1, timeout: 1, wait: 250)]
  • 时间窗口限流详解

use WilburYu\HyperfCacheExt\Annotation\DurationRateLimiter;
// 每 10 秒最多支持 100 个请求
#[DurationRateLimiter(key: 'get.posts', maxAttempts: 100, decayMinutes: 10, timeout: 1, wait: 750)]
- ```

> 注解参数同配置文件, 优先级为注解>配置>默认.
>
> 1. 在计数器注解中使用 `for` , `max_attempts` `decay_minutes` 不起作用.
> 2. `timeout` `wait` 参数, 适用于`漏斗`和`时间窗口`

如果你的缓存驱动不是 `redis`, 只可以使用 `CounterRateLimit` 注解.

反之则可以使用 `CounterRateLimitWithRedis/ConcurrencyRateLimiter/DurationRateLimiter` 注解.

在其他地方使用限速时, 可以使用辅助函数

1. counter_limiter()

使用方法同 `Laravel`中的 `RateLimiter Facade`,
可参考 [Laravel 限流文档](https://learnku.com/docs/laravel/8.5/current-limiting/11453)

```php
$executed = counter_limiter()->attempt('send-sms:'.$user->id,2,function(){
   // send sms logic
});
if (!$executed) {
   return 'Too many messages sent!';
}

3.concurrency_limiter()

使用方法同 Laravel 中的 Redis::funnel 门面代理方法 可参考高级限流器:限定并发请求访问上限

$executed = concurrency_limiter('key')->limit(100)->then(function(){
   // send sms logic
}, function(){
   // 异常上时调用
   abort(429);
});
  1. duration_limiter()

使用方法同 Laravel 中的 Redis::throttle 门面代理方法 可参考高级限流器:限定单位时间访问上限

$executed = duration_limiter('key')->allow(100)->every(10)->then(function(){
   // send sms logic
}, function(){
   // 异常上时调用
   abort(429);
});

感谢

Laravel Cache

Hyperf Rate-Limit

感谢原链:https://learnku.com/articles/64115

分享分享


评论一下 分享本文 赞助站长

赞助站长X

扫码赞助站长
联系站长
龙行博客
  • 版权申明:此文如未标注转载均为本站原创,自由转载请表明出处《龙行博客》。
  • 本文网址:https://www.liaotaoo.cn/420.html
  • 上篇文章:Hyperf自定义进程-mqtt使用做个记录
  • 下篇文章:Hyperf 操作 Elasticsearch 协程客户端
  • Laravel docker hyperf
快捷导航
联系博主
在线壁纸
给我留言
四四五五
音乐欣赏
返回顶部