2023-01-06T05:46:39.png

问题：

如上图所示官方说的queue已经在think-swoole中集成了，但是我们将此配置在swoole.php中更改后，创建完任务后，队列不执行。

原因：

queue.php的配置和swoole.php的配置不一致造成的。

• queue配置

'connections' => [
        'sync'     => [
            'type' => 'sync',
        ],
        'database' => [
            'type'       => 'database',
            'queue'      => 'zimuoo',
            'table'      => 'jobs',
            'connection' => null,
        ],
        'redis'    => [
            'type'       => 'redis',
            'queue'      => "zimuoo",
            'host'       => env('REDIS.REDIS_HOST', '127.0.0.1'),
            'port'       => env('REDIS.PORT', 6379),
            'password'   => env('REDIS.REDIS_PASSWORD', ''),
            'select'     => env('REDIS.SELECT', 0),
            'timeout'    => 0,
            'persistent' => false,
        ],
    ],

• swoole配置

//队列
    'queue'      => [
        'enable'  => true,
        //键名是队列名称
        'workers' => [
            //下面参数是不设置时的默认配置
            'default'            => [
                'delay'      => 0,
                'sleep'      => 3,
                'tries'      => 0,
                'timeout'    => 60,
                'worker_num' => 3,
            ],
            //使用@符号后面可指定队列使用驱动
            'default@connection' => [
                //此处可不设置任何参数，使用上面的默认配置
            ],
        ],
    ],

代码分析

• 先看看think-swoole的启动命令文件中的queue监听,分析代码可以发现队列是queue [$queue]，但是咱们两边配置不一样，一个是zimuoo，一个是default，造成任务创建了，但是不执行。

protected function createQueueWorkers()
    {
        $workers = $this->getConfig('queue.workers', []);

        foreach ($workers as $queue => $options) {

            if (strpos($queue, '@') !== false) {
                [$queue, $connection] = explode('@', $queue);
            } else {
                $connection = null;
            }

            $workerNum = Arr::get($options, 'worker_num', 1);

            $this->addBatchWorker($workerNum, function (Process\Pool $pool) use ($options, $connection, $queue) {
                $delay   = Arr::get($options, 'delay', 0);
                $sleep   = Arr::get($options, 'sleep', 3);
                $tries   = Arr::get($options, 'tries', 0);
                $timeout = Arr::get($options, 'timeout', 60);

                /** @var Worker $worker */
                $worker = $this->app->make(Worker::class);

                while (true) {
                    $timer = Timer::after($timeout * 1000, function () use ($pool) {
                        $pool->getProcess()->exit();
                    });

                    $this->runWithBarrier([$this, 'runInSandbox'], function () use ($connection, $queue, $delay, $sleep, $tries, $worker) {
                        $worker->runNextJob($connection, $queue, $delay, $sleep, $tries);
                    });

                    Timer::clear($timer);
                }
            }, "queue [$queue]");
        }
    }

解决

只需要将 swoole.php中的队列驱动更改为一直即可。default=>zimuoo