Refactor Redis driver to improve expiration handling

Removed the timer for clearing expired keys and refactored the increase method to handle expiration more efficiently.

Author: walkor

src/Driver/Redis.php

@@ -5,7 +5,6 @@
 use RedisException;
 use support\Redis as RedisClient;
 use Workerman\Worker;
-use Workerman\Timer;
 
 class Redis implements DriverInterface
 {
@@ -16,20 +15,28 @@ class Redis implements DriverInterface
      */
     public function __construct(?Worker $worker, protected string $connection)
     {
-        if ($worker) {
-            Timer::add(24 * 60 * 60, function () {
-                $this->clearExpire();
-            });
-        }
-        $this->clearExpire();
+        
     }
-
+    
     /**
      * @throws RedisException
      */
     public function increase(string $key, int $ttl = 24 * 60 * 60, $step = 1): int
     {
-        return RedisClient::connection($this->connection)->hIncrBy('rate-limiter-' . date('Y-m-d'), "$key-" . $this->getExpireTime($ttl) . '-' . $ttl, $step) ?: 0;
+        static $lastExpiredHashKey = null;
+        $connection = RedisClient::connection($this->connection);
+        $hashKey = 'rate-limiter-' . date('Y-m-d');
+        $field = $key . '-' . $this->getExpireTime($ttl) . '-' . $ttl;
+
+        $count = $connection->hIncrBy($hashKey, $field, $step) ?: 0;
+
+        if ($lastExpiredHashKey !== $hashKey) {
+            $expireAt = strtotime(date('Y-m-d') . ' 23:59:59') + 300;
+            $connection->expireAt($hashKey, $expireAt);
+            $lastExpiredHashKey = $hashKey;
+        }
+
+        return $count;
     }
 
     /**
@@ -40,19 +47,4 @@ protected function getExpireTime($ttl): int
     {
         return ceil(time() / $ttl) * $ttl;
     }
-
-    /**
-     * @return void
-     * @throws RedisException
-     */
-    protected function clearExpire(): void
-    {
-        $keys = RedisClient::connection($this->connection)->keys('rate-limiter-*');
-        foreach ($keys as $key) {
-            if (!str_contains($key, 'rate-limiter-' . date('Y-m-d'))) {
-                $key = str_replace(config('redis.' . $this->connection . '.prefix', ''), '', $key);
-                RedisClient::connection($this->connection)->del($key);
-            }
-        }
-    }
-}
+}