优化代码

Author: Yurunsoft

src/Driver/RedisQueueDriver.php

@@ -78,7 +78,7 @@ public function push(IMessage $message, float $delay = 0, array $options = []):
                 $args[] = $k;
                 $args[] = $v;
             }
-            $result = $redis->evalEx(<<<LUA
+            $result = $redis->evalEx(<<<'LUA'
 local queueKey = KEYS[1]
 local messageKeyPrefix = KEYS[2]
 local messageIdKey = KEYS[3]
@@ -117,7 +117,7 @@ public function push(IMessage $message, float $delay = 0, array $options = []):
                 $args[] = $k;
                 $args[] = $v;
             }
-            $result = $redis->evalEx(<<<LUA
+            $result = $redis->evalEx(<<<'LUA'
 local queueKey = KEYS[1]
 local messageKeyPrefix = KEYS[2]
 local messageIdKey = KEYS[3]
@@ -183,7 +183,7 @@ public function pop(float $timeout = 0): ?IMessage
             $this->parseDelayMessages();
             $this->parseTimeoutMessages();
             $redis = RedisManager::getInstance($this->poolName);
-            $result = $redis->evalEx(<<<LUA
+            $result = $redis->evalEx(<<<'LUA'
 -- 从列表弹出
 local messageId = redis.call('lpop', KEYS[1])
 if false == messageId then
@@ -249,7 +249,7 @@ public function pop(float $timeout = 0): ?IMessage
     public function delete(IMessage $message): bool
     {
         $redis = RedisManager::getInstance($this->poolName);
-        $result = $redis->evalEx(<<<LUA
+        $result = $redis->evalEx(<<<'LUA'
 local messageId = ARGV[1]
 -- 删除消息
 redis.call('del', KEYS[3] .. messageId)
@@ -310,7 +310,7 @@ public function clear($queueType = null): void
     public function success(IMessage $message): int
     {
         $redis = RedisManager::getInstance($this->poolName);
-        $result = $redis->evalEx(<<<LUA
+        $result = $redis->evalEx(<<<'LUA'
 -- 从工作队列删除
 redis.call('zrem', KEYS[1], ARGV[1])
 -- 从超时队列删除
@@ -349,14 +349,14 @@ public function fail(IMessage $message, bool $requeue = false): int
         $redis = RedisManager::getInstance($this->poolName);
         if ($requeue)
         {
-            $operation = <<<LUA
+            $operation = <<<'LUA'
 -- 加入队列
 redis.call('rpush', KEYS[2], ARGV[1]);
 LUA;
         }
         else
         {
-            $operation = <<<LUA
+            $operation = <<<'LUA'
 -- 加入失败队列
 redis.call('rpush', KEYS[2], ARGV[1])
 LUA;
@@ -421,7 +421,7 @@ public function status(): QueueStatus
     public function restoreFailMessages(): int
     {
         $redis = RedisManager::getInstance($this->poolName);
-        $result = $redis->evalEx(<<<LUA
+        $result = $redis->evalEx(<<<'LUA'
 local result = 0
 while(redis.call('Rpoplpush', KEYS[2], KEYS[1]))
 do
@@ -455,7 +455,7 @@ public function restoreFailMessages(): int
     public function restoreTimeoutMessages(): int
     {
         $redis = RedisManager::getInstance($this->poolName);
-        $result = $redis->evalEx(<<<LUA
+        $result = $redis->evalEx(<<<'LUA'
 local result = 0
 while(redis.call('Rpoplpush', KEYS[2], KEYS[1]))
 do
@@ -491,7 +491,7 @@ public function restoreTimeoutMessages(): int
     protected function parseDelayMessages(int $count = 100): int
     {
         $redis = RedisManager::getInstance($this->poolName);
-        $result = $redis->evalEx(<<<LUA
+        $result = $redis->evalEx(<<<'LUA'
 -- 查询消息ID
 local messageIds = redis.call('zrevrangebyscore', KEYS[2], ARGV[1], 0, 'limit', 0, ARGV[2])
 local messageIdCount = table.getn(messageIds)
@@ -534,7 +534,7 @@ protected function parseDelayMessages(int $count = 100): int
     protected function parseTimeoutMessages(int $count = 100): int
     {
         $redis = RedisManager::getInstance($this->poolName);
-        $result = $redis->evalEx(<<<LUA
+        $result = $redis->evalEx(<<<'LUA'
 -- 查询消息ID
 local messageIds = redis.call('zrevrangebyscore', KEYS[1], ARGV[1], 0, 'limit', 0, ARGV[2])
 local messageIdCount = table.getn(messageIds)