A5sh.com - 全球挚爱极客社区

标题: 实例讲解Laravel队列的简单使用 [打印本页]
作者: simonzhd    时间: 2022-2-27 10:48
标题: 实例讲解Laravel队列的简单使用
本文将介绍如何在 Laravel 中使用队列，以及了解了为什么使用队列

什么情况使用队列？
耗时的，比如上传一个文件后进行一些格式的转化等。

需要保证送达率的，比如发送短信，因为要调用别人的 api，总会有几率失败，那么为了保证送达，重试就必不可少了。

记录使用过程：

一、配置队列存储
队列配置文件存放在 config/queue.php，默认为 sync 同步处理，这里可以选择 redis,database 等，使用方法如下。

数据库

创建数据表存储任务，执行完 artisan 命令后运行数据迁移
  1. php artisan queue:table

  3. php artisan migrate
复制代码


Redis

为了使用 redis 队列驱动，你需要在你的配置文件 config/database.php 中配置Redis的数据库连接。

如果你的 Redis 队列连接使用的是 Redis 集群，你的队列名称必须包含 key hash tag。这是为了确保所有的 Redis 键对于一个给定的队列都置于同一哈希中：
  1. 'redis' => [

  3. 'driver' => 'redis',

  5. 'connection' => 'default',

  7. 'queue' => 'default',

  9. 'retry_after' => 90,

  11. ],
复制代码


二、创建任务类
队列的任务类在 app/Jobs/ 目录下

php artisan make:job SaveBusLine

修改文件如下：
  1. namespace App\Jobs;

  3. use App\Http\Repository\BusRepository;

  5. use Illuminate\Bus\Queueable;

  7. use Illuminate\Queue\SerializesModels;

  9. use Illuminate\Queue\InteractsWithQueue;

  11. use Illuminate\Contracts\Queue\ShouldQueue;

  13. use Illuminate\Foundation\Bus\Dispatchable;

  15. class SaveBusLine implements ShouldQueue

  17. {

  19. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

  21. /**

  23. * 任务最大尝试次数。

  25. *

  27. * @var int

  29. */

  31. public $tries = 3;

  33. /**

  35. * 任务运行的超时时间。

  37. *

  39. * @var int

  41. */

  43. public $timeout = 60;

  45. private $datum;

  47. /**

  49. * Create a new job instance.

  51. * @param array|object $datum

  53. *

  55. * @return void

  57. */

  59. public function __construct($datum)

  61. {

  63. $this->datum = $datum;

  65. }

  67. /**

  69. * Execute the job.

  71. *

  73. * @return void

  75. */

  77. public function handle()

  79. {

  81. BusRepository::getInstent()->updateBusLine($this->datum);

  83. }

  85. }
复制代码


在控制器或仓库中调用队列方法：
  1. use App\Jobs\SaveBusLine;

  3. use Carbon\Carbon;

  5. /***************** 队列操作 start *******************/

  7. SaveBusLine::dispatch($arrayData)->delay(Carbon::now()->addMinute(1));

  9. /***************** 队列操作 end *******************/
复制代码


三、启动队列任务
php artisan queue:work

四、Supervisor 配置
安装 Supervisor

Supervisor 是一个 Linux 操作系统上的进程监控软件，它会在 queue:listen 或 queue:work 命令发生失败后自动重启它们。在 Ubuntu 安装 Supervisor，可以用以下命令：
  1. sudo apt-get install supervisor
复制代码


{tip} 如果自己手动配置 Supervisor 听起来有点难以应付，可以考虑使用 Laravel Forge，它能给你的 Laravel 项目自动安装与配置 Supervisor。

配置 Supervisor

Supervisor 的配置文件一般是放在 /etc/supervisor/conf.d 目录下。在这个目录中你可以创建任意数量的配置文件来要求 Supervisor 怎样监控你的进程。例如我们创建一个 laravel-worker.conf 来启动与监控一个 queue:work 进程：
  1. [program:laravel-worker]

  3. process_name=%(program_name)s_%(process_num)02d

  5. command=php ~/laravel/artisan queue:work redis --sleep=3 --tries=3

  7. autostart=true

  9. autorestart=true

  11. user=lisgroup

  13. numprocs=8

  15. redirect_stderr=true

  17. stdout_logfile=/home/lisgroup/logs/worker.log
复制代码


这个例子里的 numprocs 命令会要求 Supervisor 运行并监控 8 个 queue:work 进程，并且在它们运行失败后重新启动。当然，你必须更改 command 命令的 queue:work redis ，以显示你所选择的队列驱动。还需要修改执行的用户 user=XXX

启动 Supervisor

当这个配置文件被创建后，你需要更新 Supervisor 的配置，并用以下命令来启动该进程：
  1. sudo supervisorctl reread

  3. sudo supervisorctl update

  5. sudo supervisorctl start laravel-worker:*
复制代码


更多有关 Supervisor 的设置与使用，请参考 Supervisor 官方文档。

五、处理失败的任务
有时候你队列中的任务会失败。不要担心，本来事情就不会一帆风顺。Laravel 内置了一个方便的方式来指定任务重试的最大次数。当任务超出这个重试次数后，它就会被插入到 failed_jobs 数据表里面。要创建 failed_jobs 表的迁移文件，你可以用 queue:failed-table 命令，接着使用 migrate Artisan 命令生成 failed_jobs 表：
  1. php artisan queue:failed-table

  3. php artisan migrate
复制代码


然后运行队列处理器，在调用 queue worker，命令时你应该通过 --tries 参数指定任务的最大重试次数。如果不指定，任务就会永久重试：
  1. php artisan queue:work redis --tries=3
复制代码


六、清除失败任务
你可以在任务类里直接定义 failed 方法，它能在任务失败时运行任务的清除逻辑。这个地方用来发一条警告给用户或者重置任务执行的操作等再好不过了。导致任务失败的异常信息会被传递到 failed 方法：
  1. namespace App\Jobs;

  3. use Exception;

  5. use App\Podcast;

  7. use App\AudioProcessor;

  9. use Illuminate\Bus\Queueable;

  11. use Illuminate\Queue\SerializesModels;

  13. use Illuminate\Queue\InteractsWithQueue;

  15. use Illuminate\Contracts\Queue\ShouldQueue;

  17. class ProcessPodcast implements ShouldQueue

  19. {

  21. use InteractsWithQueue, Queueable, SerializesModels;

  23. protected $podcast;

  25. /**

  27. * 创建一个新的任务实例。

  29. *

  31. * @param Podcast $podcast

  33. * @return void

  35. */

  37. public function __construct(Podcast $podcast)

  39. {

  41. $this->podcast = $podcast;

  43. }

  45. /**

  47. * 执行任务。

  49. *

  51. * @param AudioProcessor $processor

  53. * @return void

  55. */

  57. public function handle(AudioProcessor $processor)

  59. {

  61. // 处理上传播客...

  63. }

  65. /**

  67. * 要处理的失败任务。

  69. *

  71. * @param Exception $exception

  73. * @return void

  75. */

  77. public function failed(Exception $exception)

  79. {

  81. // 给用户发送失败通知，等等...

  83. }

  85. }
复制代码






欢迎光临 A5sh.com - 全球挚爱极客社区 (https://a5sh.com/) Powered by Discuz! X3.4