title: Distributed current limiter meta:

  • name: description content: Easyswoole provides an Atomic counter-based current limiter that limits the total number of requests in a given time period to achieve a base current limit.
  • name: keywords content: swoole|swoole extension|swoole framework|EasySwoole Distributed | AtomicLimit|Distributed Current Limiter

AtomicLimit

Easyswoole provides a current limiter based on Atomic counters.

Principle

The basic current limit is achieved by limiting the total number of requests in a certain time period. For example, if the maximum number of requests allowed is 200 in 5 seconds, then the theoretical average is 40 and the peak is 200.

Installation

  1. composer require easyswoole/atomic-limit

Sample code

  1. /*
  2.  * egUrl http://127.0.0.1:9501/index.html?api=1
  3.  */
  5. use EasySwoole\AtomicLimit\AtomicLimit;
  6. AtomicLimit::getInstance()->addItem('default')->setMax(200);
  7. AtomicLimit::getInstance()->addItem('api')->setMax(2);
  9. $http = new swoole_http_server("127.0.0.1", 9501);
  11. AtomicLimit::getInstance()->enableProcessAutoRestore($http,10*1000);
  13. $http->on("request", function ($request, $response) {
  14.     if(isset($request->get['api'])){
  15.         if(AtomicLimit::isAllow('api')){
  16.             $response->write('api success');
  17.         }else{
  18.             $response->write('api refuse');
  19.         }
  20.     }else{
  21.         if(AtomicLimit::isAllow('default')){
  22.             $response->write('default success');
  23.         }else{
  24.             $response->write('default refuse');
  25.         }
  26.     }
  27.     $response->end();
  28. });
  30. $http->start();

Note that this example uses a custom process plus timer to implement the count timing reset. In fact, it is not worthwhile to use a process to do this. Therefore, the actual production can specify a worker and set a timer to implement.