feat(pic):队列分离

application/Job/CompressJob.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace app\Job;
+
+use app\common\Service\CompressService;
+use think\facade\App;
+use think\facade\Cache;
+
+class CompressJob extends JobBase {
+    public function handle(): void {
+
+        $root = App::getRootPath() . '/public/';
+        $redis = Cache::store('redis')->handler();
+        $redis->select(9);
+        $data = $redis->lpop('imgCompress');
+        if ($data) {
+            /**
+             * @var string $data
+             */
+            $picInfo = json_decode($data, true);
+            $source = $root . $picInfo['pathname'];
+            $percent = 1;  #原图压缩，不缩放，但体积大大降低
+            //echo $root . $source;
+            (new CompressService($source, $percent))->compressImg($source);
+            echo '处理-' . $picInfo['pathname'] . '完成' . PHP_EOL;
+        }
+    }
+}

application/Job/JobBase.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace app\Job;
+
+abstract class JobBase {
+    protected $data;
+
+    public function __construct(array $data) {
+        $this->data = $data;
+    }
+
+    abstract public function handle(): void ;
+}

application/command.php

@@ -9,8 +9,8 @@
 // | Author: yunwuxin <[email protected]>
 // +----------------------------------------------------------------------
 
-use app\command\Compress;
+use app\command\Queue;
 
 return [
-    'compress' => Compress::class
+    'queue' => Queue::class
 ];

application/command/Queue.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace app\command;
+
+//use think\Cache;
+use app\Job\CompressJob;
+use app\Job\JobBase;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+
+class Queue extends Command {
+    private function getQueueJob(): array {
+        return [
+            [
+                'class' => CompressJob::class,
+                'data'  => []
+            ]
+        ];
+    }
+
+    protected function configure() {
+        // 指令配置
+        $this->setName('queue');
+        // 设置参数
+
+    }
+
+    protected function execute(Input $input, Output $output) {
+        // 指令输出
+        //$output->writeln('compress');
+        while (true) {
+            foreach ($this->getQueueJob() as $job) {
+                $class = new $job['class']($job['data']);
+                /**
+                 * @var JobBase $class
+                 */
+                $class->handle();
+            }
+        }
+    }
+
+}

application/common/Cache/CompressJob.php → application/common/Cache/CompressPush.php

@@ -2,7 +2,7 @@
 
 namespace app\common\Cache;
 
-class CompressJob extends BaseCache {
+class CompressPush extends BaseCache {
     public function __construct() {
         parent::__construct();
     }

application/index/controller/Upload.php

@@ -8,7 +8,7 @@
 
 namespace app\index\controller;
 
-use app\common\Cache\CompressJob;
+use app\common\Cache\CompressPush;
 use app\common\model\Folders;
 use app\common\model\Images;
 use app\common\model\Users;
@@ -169,7 +169,7 @@ public function execute($user = null)
             $data['quota'] = sprintf('%.2f', (float)$user->quota);
             $data['use_quota'] = sprintf('%.2f', (float)$user->use_quota);
         }
-        (new CompressJob())->addCompressJob($imageData);
+        (new CompressPush())->addCompressJob($imageData);
         return $data;
     }