1. <?php
  3. class RequestThrottler {
  5. private $queue = []; // Queue of requests
  6. private $limit; // Maximum number of requests allowed
  7. private $timeWindow; // Time window for the limit
  8. private $lastTimestamp = 0; // Timestamp of the last request within the window
  10. public function __construct(int $limit, int $timeWindow) {
  11. $this->limit = $limit;
  12. $this->timeWindow = $timeWindow;
  13. }
  15. /**
  16. * Checks if a request is allowed based on the throttling rules.
  17. *
  18. * @return bool True if the request is allowed, false otherwise.
  19. */
  20. public function isAllowed(): bool {
  21. $currentTime = time();
  23. // Remove requests older than the time window
  24. $this->queue = array_filter($this->queue, function ($request) use ($currentTime, $this->timeWindow) {
  25. return $currentTime - $request['timestamp'] < $this->timeWindow;
  26. });
  28. // Check if the queue is full
  29. if (count($this->queue) >= $this->limit) {
  30. return false; // Throttled
  31. }
  33. $this->queue[] = ['timestamp' => $currentTime]; // Add current request to queue
  34. return true; // Allowed
  35. }
  37. /**
  38. * Processes a request.
  39. *
  40. * @param callable $callback The function to execute for the request.
  41. * @param array $data Optional data to pass to the callback.
  42. * @return mixed The result of the callback, or null on failure.
  43. * @throws Exception If the request is throttled.
  44. */
  45. public function processRequest(callable $callback, array $data = []): mixed
  46. {
  47. if (!$this->isAllowed()) {
  48. throw new Exception("Request throttled. Too many requests in a short period.");
  49. }
  51. try {
  52. return $callback($data);
  53. } catch (Exception $e) {
  54. //Handle exceptions from the callback
  55. error_log("Error processing request: " . $e->getMessage());
  56. throw $e;
  57. }
  58. }
  59. }
  62. //Example Usage
  63. /*
  64. $throttler = new RequestThrottler(5, 60); // Allow 5 requests per minute
  66. try {
  67. for ($i = 0; $i < 10; $i++) {
  68. $result = $throttler->processRequest(function ($data) use ($i) {
  69. return "Request " . $i . " processed";
  70. });
  71. echo $result . "\n";
  72. }
  73. } catch (Exception $e) {
  74. echo "Error: " . $e->getMessage() . "\n";
  75. }
  76. */
  77. ?>

Add your comment