安装扩展 `composer -vvv require topthink/think-queue` 将`config/queue.php`切换为redis模式. ~~~ 'default' => 'redis', ~~~ `config`下新建 <details> <summary>job.php</summary> ~~~ <?php //think-queue类名别名 return [ 'job1' => 'app\job\Job1' ]; ~~~ </details> `app\job`下新建 <details> <summary>Job1.php</summary> ~~~ <?php namespace app\job; use think\facade\Log; use think\queue\Job; class Job1 { public function fire(Job $job, $data) { try { $data['now']=time(); // 日志 Log::info(json_encode($data, 320)); // 如果任务执行成功后 记得删除任务,不然这个任务会重复执行,直到达到最大重试次数后失败后,执行failed方法 $job->delete(); // 也可以重新发布这个任务 // $job->release($delay = 0); // $delay 为延迟时间,单位为秒 } catch (\Exception $e) { echo $e->getMessage(); } } public function failed($data) { // ...任务达到最大重试次数后,失败了 } } ~~~ </details> 在控制器中进行消息投递 ~~~ dump(Queue::push(config('job.job1'), ['push' => time()])); //延迟任务(秒) dump(Queue::later(5, config('job.job1'), ['push' => time()])); ~~~ 在项目根目录执行`php think queue:work`或者`php think queue:listen`即开始消费队列. 两种,具体的可选参数可以输入命令加 --help 查看 > 可配合supervisor使用,保证进程常驻 更多内容请参考 https://blog.csdn.net/will5451/article/details/80434174