Laravel使用队列处理
本文主要讲述如何利用 Laravel 框架的队列系统来管理异步任务和设置周期性执行的任务，从而增强应用程序的效能和可靠性。
Laravel队列的优势
异步执行：将任务添加到队列中后，可以立即返回响应给用户，而任务会在后台异步执行。
提高并发：由于任务被放入队列，可以同时处理多个任务，提高了应用的并发处理能力。
容错处理：当任务执行失败时，Laravel会将任务重新放入队列，确保任务能够被成功执行。
安全稳定：通过将任务放入队列，能够避免一些敏感操作或者耗时操作阻塞正常的请求流程。
微服务化支持：可以通过队列服务与其他微服务进行解耦合，提高应用的可扩展性。
配置驱动
根目录 config 文件夹下 queue.php ，配置 redis 驱动
//框架默认驱动我们设置为redis
'default' => env('QUEUE_CONNECTION', 'redis'),
//connections里面有多种驱动 文件 数据库 redis，这里我们使用redis
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => env('REDIS_QUEUE', 'default'),
'retry_after' => env('QUEUE_RETRY_AFTER',90),
'block_for' => null,
'after_commit' => false,
],
使用队列
使用 Laravel 自带的 Artisan 命令创建任务类
php artisan make:job Test
组装任务类
<?php
namespace App\Jobs;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
class Test implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
protected $test;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($test)
{
$this->test = $test;
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
//处理队列的逻辑
echo $this->test;
}
}
使用队列的 dispatch 方法来将任务分发到队列中，等待异步处理
//传入任务类需要的参数
Test::dispatch($test);
启动队列，设置需要启动的队列名称，tries=3 是指队列失败后重试三次
php artisan queue:work --queue=test --tries=3
防止队列在后台被杀死，我们可以安装 supervisor 然后配置队列命令即可
注： 每次修改队列代码后，需要重新启动队列不然代码不生效，这个坑是大家非常容易遇到的
结论
Laravel的队列处理可以显著提升应用程序的并发性和用户体验，通过异步执行耗时任务，使用户响应更快。
– 欢迎点赞、关注、转发、收藏【我码玄黄】，gonghao同名
