thinkphp6 安装了think-queue和redis 为什么任务没有延迟20秒执行？

Question

thinkphp6 安装了think-queue和redis
生产者Queue::later 20秒执行，
消费者 执行任务
执行：/www/server/php/72/bin/php think queue:work --queue Money > /www/wwwroot/log.txt

访问生产者。

queue.php

<?phpreturn [    'default' => 'redis',    'connections' => [        'sync' => [            'driver' => 'sync',        ],        'database' => [            'driver' => 'database',            'queue' => 'default',            'table' => 'jobs',        ],        'redis' => [            'driver' => 'redis',            'queue' => 'default',            'host' => '127.0.0.1',            'port' => 6379,            'password' => '',            'select' => 1,            'timeout' => 0,            'persistent' => false,        ],    ],    'failed' => [        'type' => 'none',        'table' => 'failed_jobs',    ],];

生产者代码：

 $jobHandlerClassName = 'app\queue\job\Money';            $jobDataArr = ['submit' => time()];            $jobQueueName = "money";                        // $isPushed=Queue::push($jobHandlerClassName, $jobDataArr, $jobQueueName);            $isPushed=Queue::later(20,$jobHandlerClassName, $jobDataArr, $jobQueueName);            echo '===';            echo '<br>';            echo $isPushed;            echo '<br>';            if( $isPushed !== false ){                echo date('Y-m-d H:i:s') . " a new Hello Job is Pushed to the MQ"."<br>";            }else{              echo 'Oops, something went wrong.';            }

消费者：

    public function fire(Job $job, $data)    {        Db::name('text')->insert(['content'=>'fire','create_time'=>time()]);        // job        $isJobDone = $this->doJob($job, $data);        $attempts = $job->attempts() + 1;        if ($isJobDone) {            print('<info>[' . date('Y-m-d H:i:s', time()) . ""  . "任务完成</info>\n");            $job->delete();        } else {            $release = strtotime(date('Y-m-d H:', time()) . '00') + 3599 + date('i', $data['submit']) * 60 + date('s', $data['submit']) - time();            print('<info>[' . date('Y-m-d H:i:s', time()) . "] " . $release . "秒后执行主机" . $data['host_name'] . "第" . $attempts . "次扣费任务</info>\n");            $job->release($release);        }    }    /**     * @throws DataNotFoundException     * @throws ModelNotFoundException     * @throws DbException     * @throws Exception     */    private function doJob($job, $data): bool    {            print("<info>Hello Job has been done and deleted"."</info>\n");        Db::name('text')->insert(['content'=>'doJob','create_time'=>time()]);                // 返回        return true;    }

我想要的是异步执行，20秒后执行doJob业务逻辑 插入数据
但是同步执行了

/www/server/php/72/bin/php think queue:work --queue Money > /www/wwwroot/log.txt

Answer 1

根据您提供的信息，问题可能在于您的队列工作器没有正确运行。在ThinkPHP 6中，您需要确保队列工作器正在运行，并且它正在监听所需的队列。

您可以尝试以下步骤来解决您的问题：

1. 确保Redis服务器正在运行，并且可以从您的应用程序访问。您可以在配置文件中检查Redis连接信息是否正确。
2. 确保ThinkPHP 6的队列驱动程序已正确配置。在队列配置文件（例如queue.php）中，您需要确保已正确配置所需的队列连接信息。对于Redis连接，您需要确保主机和端口正确无误，并且Redis服务器正在运行。
3. 确保您的队列工作器正在运行。您可以通过运行以下命令来启动队列工作器：

/www/server/php/72/bin/php think queue:work --queue Money

该命令将启动一个工作进程，它将监听指定的队列并执行队列中的任务。

4. 如果您的队列工作器正在运行但问题仍然存在，请确保您的任务处理器类（Money）具有正确的命名空间和类定义，并且可以在应用程序中正确加载。
5. 检查日志文件以查看是否有任何错误或异常。在您的代码中，您可以使用Log类将调试信息写入日志文件，以便更好地了解问题所在。

请注意，以上步骤仅提供了一些常见的故障排除步骤。要获得更具体的帮助，您可能需要提供更多关于您的应用程序和配置的详细信息。