[Cache] Use SCAN instead of KEYS with Redis >= 2.8

nicolas-grekas · nicolas-grekas · commit bf57c040dacb · 2016-08-05T21:37:06.000+02:00
diff --git a/src/Symfony/Component/Cache/Adapter/RedisAdapter.php b/src/Symfony/Component/Cache/Adapter/RedisAdapter.php
@@ -181,6 +181,7 @@ protected function doClear($namespace)
                 return false;
             }
         } elseif ($this->redis instanceof \RedisArray) {
+            $hosts = array();
             foreach ($this->redis->_hosts() as $host) {
                 $hosts[] = $this->redis->_instance($host);
             }
@@ -190,13 +191,31 @@ protected function doClear($namespace)
         foreach ($hosts as $host) {
             if (!isset($namespace[0])) {
                 $host->flushDb();
-            } else {
+                continue;
+            }
+
+            $info = $host->info('Server');
+            $info = isset($info['Server']) ? $info['Server'] : $info;
+
+            if (!version_compare($info['redis_version'], '2.8', '>=')) {
                 // As documented in Redis documentation (http://redis.io/commands/keys) using KEYS
                 // can hang your server when it is executed against large databases (millions of items).
-                // Whenever you hit this scale, it is advised to deploy one Redis database per cache pool
-                // instead of using namespaces, so that FLUSHDB is used instead.
+                // Whenever you hit this scale, you should really consider upgrading to Redis 2.8 or above.
                 $host->eval("local keys=redis.call('KEYS',ARGV[1]..'*') for i=1,#keys,5000 do redis.call('DEL',unpack(keys,i,math.min(i+4999,#keys))) end", $evalArgs[0], $evalArgs[1]);
+                continue;
             }
+
+            $cursor = null;
+            do {
+                $keys = $host instanceof \Predis\Client ? $host->scan($cursor, 'MATCH', $namespace.'*', 'COUNT', 5000) : $host->scan($cursor, $namespace.'*', 5000);
+                if (isset($keys[1]) && is_array($keys[1])) {
+                    $cursor = $keys[0];
+                    $keys = $keys[1];
+                }
+                if ($keys) {
+                    $host->del($keys);
+                }
+            } while ($cursor = (int) $cursor);
         }
 
         return true;
