1. <?php
  3. class RequestThrottler {
  5. private $request_queue = [];
  6. private $throttle_interval = 1; // seconds
  7. private $max_requests_per_interval = 5;
  8. private $lock = \React\Lock::createLock();
  10. public function __construct(int $throttle_interval = 1, int $max_requests_per_interval = 5) {
  11. $this->throttle_interval = $throttle_interval;
  12. $this->max_requests_per_interval = $max_requests_per_interval;
  13. }
  15. public function acquire(): void {
  16. $this->lock->lock();
  17. }
  19. public function release(): void {
  20. $this->lock->unlock();
  21. }
  23. public function process(callable $callback): void {
  24. $this->acquire();
  26. try {
  27. $request_id = uniqid(); // Generate a unique ID for each request
  29. if (count($this->request_queue) >= $this->max_requests_per_interval) {
  30. throw new \Exception("Rate limit exceeded. Waiting.");
  31. }
  33. $this->request_queue[] = $request_id;
  35. $callback($request_id); // Execute the diagnostic log entry function
  37. } catch (\Exception $e) {
  38. error_log("Diagnostic Log Entry Error: " . $e->getMessage());
  39. } finally {
  40. $this->release();
  41. }
  42. }
  44. public function clearQueue(): void {
  45. $this->request_queue = [];
  46. }
  47. }
  49. // Example usage:
  51. // Define a function for your diagnostic log entry
  52. function logDiagnosticEntry(string $request_id): void {
  53. error_log("Diagnostic Log Entry: Request ID - " . $request_id . " - Data: Some diagnostic data.");
  54. }
  57. // Create a throttler instance
  58. $throttler = new RequestThrottler(throttle_interval: 1, max_requests_per_interval: 3);
  60. // Simulate multiple diagnostic log entries
  61. for ($i = 0; $i < 10; $i++) {
  62. $throttler->process(function ($request_id) use ($i) {
  63. logDiagnosticEntry($request_id);
  64. });
  65. }
  67. ?>

Add your comment